Neo4j 合并和原子事务

Question

我运行在 10 个并行线程中从客户端应用程序对我的 Neo4j 服务器执行以下 MERGE 查询，newFoo 和 id 参数相同所有 10 运行s:

MERGE (foo:Foo { id: {id} })
ON MATCH
SET foo = {newFoo}

在运行之后，我运行下面的查询期望 1 但我却得到 10:

match (f:Foo)
return count(f)

我认为 MERGE 运行在原子事务中，但显然不是。我是不是做错了什么？

更新

下面是我用来重现问题的代码：

public static async Task RunInParallel()
{
    var client = new GraphClient(new Uri("http://localhost:7474/db/data"), "neo4j", "1234567890")
    {
        JsonContractResolver = new CamelCasePropertyNamesContractResolver()
    };

    client.Connect();

    var foo = new Foo
    {
        Id = "1",
        Name = "Foo",
        Slug = "foo-bar-foo"
    };

    List<Task> tasks = new List<Task>();
    for (int i = 0; i < 10; i++)
    {
        var task = client.Cypher
            .Merge("(foo:Foo { id: {id} })")
            .OnMatch()
            .Set("foo = {newFoo}")
            .WithParams(new
            {
                Id = foo.Id,
                NewFoo = foo
            })
            .ExecuteWithoutResultsAsync();

        tasks.Add(task);
    }

    await Task.WhenAll(tasks.ToArray());
}

Answer 1

MERGE（本身）不保证唯一性。使用 MERGE（在唯一属性上）时，您应该始终为指定的属性创建一个 uniqueness constraint：

CREATE CONSTRAINT ON (f:Foo) ASSERT f.id IS UNIQUE

这将确保您不会创建任何重复项。

编辑

没有唯一性约束的

MERGE 不是线程安全的。添加唯一性约束可确保在写入之前持有索引锁，从而使操作线程安全。

Neo4j 合并和原子事务

Neo4j Merge and Atomic Transaction

neo4j

atomic

graph-databases

neo4jclient

更新