如何在 Neo4j v2 中使用 Neo4jClient 创建节点
本文关键字:Neo4jClient 创建 节点 Neo4j v2 | 更新日期: 2023-09-27 18:36:33
在Neo4j v1.9.x下,我使用了以下代码。
private Category CreateNodeCategory(Category cat)
{
var node = client.Create(cat,
new IRelationshipAllowingParticipantNode<Category>[0],
new[]
{
new IndexEntry(NeoConst.IDX_Category)
{
{ NeoConst.PRP_Name, cat.Name },
{ NeoConst.PRP_Guid, cat.Nguid.ToString() }
}
});
cat.Nid = node.Id;
client.Update<Category>(node, cat);
return cat;
}
原因是节点 ID 是自动生成的,我可以稍后使用它进行快速查找、在其他查询中启动位等。如下所示:
private Node<Category> CategoryGet(long nodeId)
{
return client.Get<Category>((NodeReference<Category>)nodeId);
}
这使得以下看起来效果很好。
public Category CategoryAdd(Category cat)
{
cat = CategoryFind(cat);
if (cat.Nid != 0) { return cat; }
return CreateNodeCategory(cat);
}
public Category CategoryFind(Category cat)
{
if (cat.Nid != 0) { return cat; }
var node = client.Cypher.Start(new {
n = Node.ByIndexLookup(NeoConst.IDX_Category, NeoConst.PRP_Name, cat.Name)})
.Return<Node<Category>>("n")
.Results.FirstOrDefault();
if (node != null) { cat = node.Data; }
return cat;
}
现在密码维基,示例和坏习惯建议使用.ExecuteWithoutResults() in all the CRUD.
所以我的问题是你如何获得节点 ID 的自动增量值?
首先,对于 Neo4j 2 及更高版本,您始终需要从参考框架开始"我将如何在 Cypher 中执行此操作?然后,也只有这样,你才会担心 C#。
现在,提炼您的问题,听起来您的主要目标是创建一个节点,然后返回对它的引用以进行进一步的工作。
您可以在密码中执行此操作:
CREATE (myNode)
RETURN myNode
在 C# 中,这将是:
var categoryNode = graphClient.Cypher
.Create("(category {cat})")
.WithParams(new { cat })
.Return(cat => cat.Node<Category>())
.Results
.Single();
但是,这仍然不是您在原始CreateNodeCategory
方法中所做的 100%。您正在数据库中创建节点,获取 Neo4j 的内部标识符,然后将该标识符保存回同一节点。基本上,您正在使用Neo4j为您生成自动递增的数字。这是功能性的,但并不是一个好方法。我会解释更多...
首先,Neo4j甚至给你节点ID的概念正在消失。它是一个内部标识符,实际上恰好是磁盘上的文件偏移量。它可以改变。它是低水平的。如果您考虑一下 SQL,您是否使用 SQL 查询来获取行的文件字节偏移量,然后引用它以供将来更新?答:没有;您编写一个查询,该查询一次查找和操作所有行。
现在,我注意到您在节点上已经有一个 Nguid
属性。为什么不能使用它作为 id?或者,如果名称始终是唯一的,请使用它?(域相关 ID 始终优于幻数。如果两者都不合适,您可能需要查看像SnowMaker这样的项目来帮助您。
接下来,我们需要查看索引。您使用的索引类型在 2.0 文档中称为"旧版索引",并且错过了一些很酷的 Neo4j 2.0 功能。
对于这个答案的其余部分,我将假设您的Category
类如下所示:
public class Category
{
public Guid UniqueId { get; set; }
public string Name { get; set; }
}
让我们首先创建一个带有标签的类别节点:
var category = new Category { UnqiueId = Guid.NewGuid(), Name = "Spanners" };
graphClient.Cypher
.Create("(category:Category {category})")
.WithParams(new { category })
.ExecuteWithoutResults();
并且,作为一次性操作,让我们在具有Category
标签的任何节点的 Name
属性上建立一个基于架构的索引:
graphClient.Cypher
.Create("INDEX ON :Category(Name)")
.ExecuteWithoutResults();
现在,我们无需担心手动使索引保持最新。
我们还可以在UniqueId
上引入索引和唯一约束:
graphClient.Cypher
.Create("CONSTRAINT ON (category:Category) ASSERT category.UniqueId IS UNIQUE")
.ExecuteWithoutResults();
查询现在非常简单:
graphClient.Cypher
.Match("(c:Category)")
.Where((Category c) => c.UniqueId == someGuidVariable)
.Return(c => c.As<Category>())
.Results
.Single();
与其查找类别节点,然后执行另一个查询,只需一次性完成所有查询:
var productsInCategory = graphClient.Cypher
.Match("(c:Category)<-[:IN_CATEGORY]-(p:Product)")
.Where((Category c) => c.UniqueId == someGuidVariable)
.Return(p => p.As<Product>())
.Results;
如果要更新类别,也可以一次性更新:
graphClient.Cypher
.Match("(c:Category)")
.Where((Category c) => c.UniqueId == someGuidVariable)
.Update("c = {category}")
.WithParams(new { category })
.ExecuteWithoutResults();
最后,您的CategoryAdd
方法当前 1) 执行一次数据库命中以查找现有节点,2) 第二次数据库命中以创建新节点,3) 第三次数据库命中以更新其上的 ID。相反,您也可以使用 MERGE
关键字将所有这些压缩为单个调用:
public Category GetOrCreateCategoryByName(string name)
{
return graphClient.Cypher
.WithParams(new {
name,
newIdIfRequired = Guid.NewGuid()
})
.Merge("(c:Category { Name = {name})")
.OnCreate("c")
.Set("c.UniqueId = {newIdIfRequired}")
.Return(c => c.As<Category>())
.Results
.Single();
}
基本上
不要使用Neo4j的内部ID来管理自己的身份。(但他们将来可能会发布某种形式的自动编号。即使他们这样做,域名身份,如电子邮件地址或SKU或机场代码或......是首选。你甚至并不总是需要一个id:你通常可以根据它在图中的位置来推断一个节点。
一般来说,
Node<T>
会随着时间的推移而消失。如果你现在使用它,你只是在积累遗留代码。查看标签和基于架构的索引。它们会让你的生活更轻松。
尝试在一个查询中执行操作。它会快得多。
希望对您有所帮助!