我正在运行下面的MERGE
从客户端应用程序在 10 个并行线程中查询我的 Neo4j 服务器,newFoo
and id
所有 10 次运行的参数均相同:
MERGE (foo:Foo { id: {id} })
ON MATCH
SET foo = {newFoo}
运行此命令后,我运行以下查询以期望1
但我反而得到10
:
match (f:Foo)
return count(f)
我以为MERGE
在原子事务中运行,但显然不是。我在这里做错了什么吗?
Update
下面是我用来重现该问题的代码:
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());
}
MERGE
(本身)不保证唯一性。使用时MERGE
(在独特的财产上)你应该总是创建一个唯一性约束 http://neo4j.com/docs/stable/query-constraints.html对于指定的属性:
CREATE CONSTRAINT ON (f:Foo) ASSERT f.id IS UNIQUE
这将确保您不会创建任何重复项。
Edit
MERGE
没有唯一性约束不是线程安全的。添加唯一性约束可确保在写入之前持有索引锁,从而使操作线程安全。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)