Neo4j Driver C# Размотка списка объектов - PullRequest
Новая
       30

Neo4j Driver C# Размотка списка объектов

1 голос
/ 16 апреля 2020

Я смотрю, как раскрутить список объектов (в памяти) в Neo4j 4.0. Ниже приведено то, что я ранее использовал с помощью ньюгета Neo4jClient, но вместо этого мне нужно переключиться на нюжет Neo4j.Driver.

Neo4jClient (old) 

graphClient.Cypher
    .Unwind(towns, "tp")
    .Merge("t:Town {Name: tp.Id})")
    .OnCreate()
    .Set("t = tp")
    .ExecuteWithoutResults();

Neo4j Driver (сделано до сих пор) 

var session = driver.AsyncSession(o => o.WithDatabase("neo4j"));
        try
        {
            towns = towns.OrderBy(tt => tt.Id).ToList();
            foreach (var t in towns.Split(5000))
            {
                    Console.WriteLine($"Saving {t.Count:N0} of {town.Count:N0} Towns...");    
        **//STUCK HERE DOING UNWIND**  
            }
        }
        catch (Exception ex)
        {
            string error = $"ERROR (ADD TOWNS): {ex.ToString()}";           
            Console.WriteLine(error);
        }
        finally
        {
            await session.CloseAsync();
        }

1 Ответ

1 голос
/ 18 апреля 2020

К сожалению, драйвер Neo4j довольно прост - вам нужно создать запрос Cypher вручную, ссылаясь на параметры там, где это необходимо, а затем передать эти параметры в запрос. 

var session = driver.AsyncSession(o => o.WithDatabase("neo4j"));
try
{
    towns = towns.OrderBy(tt => tt.Id).ToList();
    foreach (var t in towns.Split(5000))
    {
        Console.WriteLine($"Saving {t.Count:N0} of {town.Count:N0} Towns...");

        // Just return the town name - in your case, you'd MERGE or whatever, this is 
        // just an example
        var query = new Query("UNWIND {towns} AS town RETURN town", new Dictionary<string, object>
        {
            { "towns", towns }
        });

        var result = await session.RunAsync(query);
    }
}
catch (Exception ex)
{
    string error = $"ERROR (ADD TOWNS): {ex.ToString()}";
    Console.WriteLine(error);
}
finally
{
    await session.CloseAsync();
}
...