Neo4j - 로컬 데이터베이스를 원격 neo4j 데이터베이스 서버와 동기화하는 방법

Question

Neo4j를 데이터베이스로 사용하는 프로젝트에서 작업 중입니다. 원격 데이터베이스를 응용 프로그램 용으로 빌드하고 Cloud에서 호스팅합니다. 클라이언트의 위치에서 호스팅되는 다른 데이터베이스 (로컬 데이터베이스)가 있습니다.

질문 : 두 데이터베이스를 동기화하는 방법이 있습니까? 이 동기화에 사용할 수있는 직접 COTS 제품이 있습니까?

Answer 1

실행중인 버전에 따라 다릅니다. Enterprise Edition을 사용하는 경우 즉시 사용할 수 있지만 커뮤니티를 사용하는 경우 직접 수행해야합니다.

로컬 데이터베이스의 데이터를 수정 한 다음 모든 쿼리를 기록한 다음 원격 데이터베이스에서 재생하면됩니다. 아래 코드는 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); 
      } 
     } 

참고 - 한 번만 재생하고 질의를 순서대로 재생해야합니다.