c# - c# 类图到 Neo4j
问题描述
我希望将内存中的普通旧 C# 类转换为 neo4j 数据库。(类类型是节点类型并派生自,节点具有“linkedTo”的列表)
与其编写一长串密码查询来创建节点和属性,然后将它们与关系联系起来,我想知道是否有什么更聪明的方法可以做。
例如,我可以将它们序列化为 json,然后将其直接导入 neo4j 吗?我知道 C# neo4j 驱动程序中的 .unwind 函数在这里可能会有所帮助,但没有看到很好的使用示例,然后需要单独匹配和创建关系
有没有这样做的最佳方法?我希望有大约 50k 个节点
解决方案
好的,首先,我为此使用 Neo4jClient,并使用以下方法INDEX
向数据库添加了一个:
CREATE INDEX ON :MyClass(Id)
这对于它的工作方式很重要,因为它可以更快地插入数据。
我有一堂课:
public class MyClass
{
public int Id {get;set;}
public string AValue {get;set;}
public ICollection<int> LinkToIds {get;set;} = new List<int>();
}
其中有一个Id
我将要关闭的属性和一个string
属性 - 只是因为。该LinkToIds
属性是此实例链接到的 Id 的集合。
要生成我的MyClass
实例,我使用此方法随机生成它们:
private static ICollection<MyClass> GenerateMyClass(int number = 50000){
var output = new List<MyClass>();
Random r = new Random((int) DateTime.Now.Ticks);
for (int i = 0; i < number; i++)
{
var mc = new MyClass { Id = i, AValue = $"Value_{i}" };
var numberOfLinks = r.Next(1, 10);
for(int j = 0; j < numberOfLinks; j++){
var link = r.Next(0, number-1);
if(!mc.LinkToIds.Contains(link) && link != mc.Id)
mc.LinkToIds.Add(link);
}
output.Add(mc);
}
return output;
}
然后我使用另一种方法将其拆分为更小的“批次”:
private static ICollection<ICollection<MyClass>> GetBatches(ICollection<MyClass> toBatch, int sizeOfBatch)
{
var output = new List<ICollection<MyClass>>();
if(sizeOfBatch > toBatch.Count) sizeOfBatch = toBatch.Count;
var numBatches = toBatch.Count / sizeOfBatch;
for(int i = 0; i < numBatches; i++){
output.Add(toBatch.Skip(i * sizeOfBatch).Take(sizeOfBatch).ToList());
}
return output;
}
然后实际添加到数据库中:
void Main()
{
var gc = new GraphClient(new Uri("http://localhost:7474/db/data"), "neo4j", "neo");
gc.Connect();
var batches = GetBatches(GenerateMyClass(), 5000);
var now = DateTime.Now;
foreach (var batch in batches)
{
DateTime bstart = DateTime.Now;
var query = gc.Cypher
.Unwind(batch, "node")
.Merge($"(n:{nameof(MyClass)} {{Id: node.Id}})")
.Set("n = node")
.With("n, node")
.Unwind("node.LinkToIds", "linkTo")
.Merge($"(n1:{nameof(MyClass)} {{Id: linkTo}})")
.With("n, n1")
.Merge("(n)-[:LINKED_TO]->(n1)");
query.ExecuteWithoutResults();
Console.WriteLine($"Batch took: {(DateTime.Now - bstart).TotalMilliseconds} ms");
}
Console.WriteLine($"Total took: {(DateTime.Now - now).TotalMilliseconds} ms");
}
在我老化(现在 5-6 岁)的机器上,大约需要 20 秒才能将 50,000 个节点放入大约 500,000 个关系中。
让我们打破上面对 Neo4j 的重要调用。正如您正确建议的那样,关键是UNWIND
-在这里我UNWIND
是一个批次,并为该集合中的每个“行”赋予node
. 然后我可以访问属性 ( node.Id
) 并将其用于MERGE
节点。在第一次展开时 - 我总是SET
将新创建的节点 ( n
) 设置为node
所有属性(在本例AValue
中为 )。
因此,直到第一个,With
我们已经创建了一个带有MyClass
标签的新节点,并设置了所有属性。现在。这确实包括有一个数组LinkToIds
,如果你是一个整洁的人 - 你可能想要删除。我会把它留给你自己。
在第二个UNWIND
中,我们利用LinkToIds
属性是一个数组这一事实,并使用它来创建一个稍后将填充的“占位符”节点,然后我们在n
和n1
占位符之间创建关系。注意 - 如果我们已经创建了一个与n1
我们将使用该节点具有相同 id 的节点,并且当我们在第一次获得相同的 Id 时,UNWIND
我们将设置占位符的所有属性。
这不是最容易解释的,但最好看的是MERGE
Neo4jUNWIND
文档。
推荐阅读
- javascript - 验证字符串的正则表达式是否被 HTML 标记包围
- laravel - Laravel 5.7 - 如何使用 axios.get 从 API 检索数据?
- react-native - react native如何在材质日期选择器中实现材质文本输入?
- dns - CNAME 记录是否公开
- ruby-on-rails - 收听另一个 rails actioncable 服务器
- c++ - C++ 方法中的静态变量
- laravel - 在 Laravel 中从模型中添加多个 Where 子句
- lstm - RuntimeError: Expected hidden[0] size (2, 20, 256), got (2, 50, 256)
- java - 删除所有不起作用的java换行符(如emacs所示)
- c - 以下代码如何出现堆栈粉碎错误?