java - CREATE UNIQUE 导致与 Neo4j 和 JDBC 的重复关系

Question

我在 Storm 中的亮点之一是一个为 Neo4j 增添优势的模块。如果我使用并行性，我就会有重复项。代码如下:

  try {
        Connection connection = getNeo4jConnection();
        try {
            Trip trip = (Trip) tuple.getValueByField("trip");
            try (Statement stmt = connection.createStatement()) {
                String query = "MATCH (u:Airport {name:'" +
                        trip.getOutgoingAirport() + "'}), (r:Airport {name:'" +
                        trip.getIngoingAirport() + "'})" +
                        " CREATE UNIQUE (u)-[:FLIGHT_TO { amount: '"+ 1 +"' }]->(r)";
                System.out.println("QUERY " + query);
                stmt.execute(query);
            }
        } finally {
            connection.close();
        }
    } catch (SQLException e) {
        System.out.println(e.getMessage());
    }

    collector.ack(tuple);

我正在试验，所以不要介意丑陋的 try catch，它不是生产代码。连接是通过以下方式创建的:

private static Connection getNeo4jConnection() throws SQLException {
    Driver driver = new org.neo4j.jdbc.Driver();
    Properties properties = new Properties();
    properties.put("user", "neo4j");
    properties.put("password", "neo4j");
    String url = "jdbc:neo4j://localhost:7474/";
    return driver.connect(url, properties);
}

如您所见，查询类似于:MATCH (u:Airport {name:'CIA'}), (r:Airport {name:'STN'}) CREATE UNIQUE (u)-[:FLIGHT_TO { amount: '1' }]->(r)。现在，正如您可以在文档中阅读的那样，我预计 Neo4j 具有酸性事务，因此我假设我没有重复项，但在使用并发 bolt 时我有它们。我认为这是一种竞争情况，因为如果我使用 1 个线程，这种情况就不会发生。

你能帮我找出我做错了什么吗？

Answer 1

每个线程可以使用一个连接，因此不必为每个语句重新创建它们。

实际上，多线程 CREATE UNIQUE 操作没有唯一性保证。

您必须锁定有问题的两个节点。例如。通过删除不存在的属性。

MATCH (u:Airport {name:{1}}), (r:Airport {name:{2}})
REMOVE u._lock_, r._lock_
MERGE (u)-[:FLIGHT_TO]->(r) ON CREATE SET f.amount = {3}

PS:您还需要使用机场名称和金额的参数。使用准备好的语句和 pst.setString(1,trip.getOutgoingAirport());