[flutter] 플러터 objectbox의 데이터 동기화 방법은?

05 Dec 2023

flutter

ObjectBox는 데이터 영구 저장소로서 사용되는 NoSQL 데이터베이스입니다. 데이터를 저장하고 검색하며, Flutter 프로젝트에서도 ObjectBox를 사용할 수 있습니다. 그러나 데이터가 실시간으로 동기화되도록 하려면 몇 가지 추가적인 작업이 필요합니다.

스트림을 사용하여 데이터 업데이트 감지: ObjectBox는 변경된 데이터를 감지하는 스트림을 제공합니다. 따라서 스트림을 사용하여 데이터 수정 및 업데이트 사항을 실시간으로 감지할 수 있습니다.

Stream<List<Entity>> getEntitiesStream() {
  var query = Entity_.query();
  return query.watch().map((querySubscription) => querySubscription.results);
}

웹 소켓 또는 실시간 데이터베이스와의 통합: ObjectBox 자체적으로 실시간 동기화를 지원하지 않으므로, 웹 소켓이나 실시간 데이터베이스와 ObjectBox를 통합하여 데이터를 동기화시킬 수 있습니다. 예를 들어, Firestore와 같은 실시간 데이터베이스를 사용하여 데이터를 동기화할 수 있습니다.

Stream<List<Entity>> getEntitiesStream() {
  var query = Entity_.query();
  return query.watch().map((querySubscription) => querySubscription.results);
}

void syncFirestoreWithObjectBox() {
  Firestore.instance.collection('entities').snapshots().listen((QuerySnapshot snapshot) {
    for (var documentChange in snapshot.documentChanges) {
      if (documentChange.type == DocumentChangeType.added) {
        var entity = Entity.fromMap(documentChange.document.data);
        ObjectBox.get().box<Entity>().put(entity);
      } else if (documentChange.type == DocumentChangeType.modified) {
        var entity = Entity.fromMap(documentChange.document.data);
        ObjectBox.get().box<Entity>().put(entity);
      } else if (documentChange.type == DocumentChangeType.removed) {
        var entity = Entity.fromMap(documentChange.document.data);
        ObjectBox.get().box<Entity>().remove(entity.id);
      }
    }
  });
}

수동으로 데이터 동기화: ObjectBox를 사용하여 데이터를 로컬 영역에 저장한 후에는 데이터베이스 세션을 열어 원격 디바이스에서 데이터를 다시 읽어와 수동으로 동기화해야 합니다. 이는 데이터 수정 시에 로컬과 원격 데이터 간의 일관성을 유지하는 데 도움이 됩니다.

void syncData() async {
  var entitiesOnLocal = ObjectBox.get().box<Entity>().getAll();
  
  for (var entity in entitiesOnLocal) {
    // 원격 디바이스와 동기화
    // ...
  }
}

이러한 방법으로 ObjectBox의 데이터 동기화를 구현할 수 있습니다. 선택한 방법은 프로젝트의 요구 사항과 데이터 처리 흐름에 따라 다를 수 있습니다. 따라서 상황에 맞게 적절한 방법을 선택하여 사용하시면 됩니다.

참고 자료: