Драйвер Neo4j C# Раскрутить список объектов

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

Клиент Neo4jClient (старый)

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

Драйвер Neo4j (на данный момент готово)

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();
        }

c# neo4j neo4j-driver
person Liam    schedule 16.04.2020    source источник

Ответы (1)


arrow_upward
1
arrow_downward

К сожалению, драйвер 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();
}
person Pablissimo    schedule 18.04.2020