Neo4j - Как синхронизировать локальную базу данных с удаленным сервером базы данных neo4j

Question

Я работаю над проектом, в котором мы используем Neo4j в качестве базы данных. У меня есть удаленная база данных, созданная для приложения и размещенная в Cloud. Существует другая база данных (локальная база данных), которая размещается на месте клиента.

Вопрос: есть ли способ синхронизации двух баз данных? Существуют ли какие-либо прямые продукты COTS, которые могут использоваться для этой синхронизации?

Answer 1

Это зависит от того, какая версия работает. Если вы используете Enterprise Edition, вы можете синхронизировать его из коробки, однако, если вы используете Community, вы должны сделать это самостоятельно.

Я делаю это, записывая все запросы, которые изменяют данные в локальной базе данных и затем воспроизводятся в удаленной базе данных. Приведенный ниже код является примером делать это в C#

var query = _client.Cypher 
       .Match("(p:Person)") 
       .Where((Person p) => p.Id == id) 
       .Set("p = {person}") 
       .WithParam("person", person); 
      query.ExecuteWithoutResults(); 
      RecordQuery(query); 

private static void RecordQuery(dynamic query) 
     { 
      var syncStore = new SynchronisationStore(); 
      var replayQuery = syncStore.Create(); 
      replayQuery.TimeStamp = DateTime.Now; 
      var queryText = query.Query.QueryText.Replace("\r\n", " "); 
      replayQuery.CypherQueryText = queryText; 
      replayQuery.CypherQueryParameters = query.Query.QueryParameters; 
      syncStore.Store(replayQuery); 
     } 

Вы можете использовать любой метод, который вы хотите передать строковые данные между серверами (я использую RESTful службы) и воспроизведения с помощью:

public void ReplayQuery(ReplayQuery replayQuery) 
     { 
       foreach (var pair in replayQuery.CypherQueryParameters) 
       { 
        replayQuery.CypherQueryText = replayQuery.CypherQueryText.Replace("{" + pair.Key + "}", SerializeWithoutQuote(pair.Value)); 
       } 
       var query = new CypherQuery(replayQuery.CypherQueryText, new Dictionary<string, object>(), CypherResultMode.Set, null); 

       _client.Connect(); 
       ((IRawGraphClient) _client).ExecuteCypher(query); 
      } 
     } 

ПРИМЕЧАНИЕ. Вам нужно убедиться, что вы только воспроизводите один раз и что вы воспроизводите запросы по порядку.