如何以整洁架构风格实现本地ObjectBox/Hive数据库流数据处理？

最近遇到了搭建ObjectBox流时，需要将数据库数据模型转换为领域实体的问题，整理了一套可行的实现方案，部分思路也适用于Hive等其他本地数据库。

问题背景 #

在使用ObjectBox做本地数据持久化时，通常会定义数据库专属的数据模型类，但业务逻辑层更依赖独立的领域实体类。需要在ObjectBox提供的数据流中，自动完成两者的转换，同时保证流的实时性。

实现步骤 #

1. 定义数据库模型与领域实体 #

首先分别定义ObjectBox实体类和业务层的领域实体类：

// ObjectBox数据模型
@Entity()
class TodoBoxModel {
  int id;
  String title;
  bool isCompleted;

  TodoBoxModel({this.id = 0, required this.title, required this.isCompleted});
}

// 业务层领域实体
class Todo {
  final String id;
  final String title;
  final bool isCompleted;

  Todo({required this.id, required this.title, required this.isCompleted});
}

2. 实现模型转换扩展方法 #

通过Dart扩展方法，给两类模型添加互相转换的工具方法，让转换逻辑更清晰：

extension TodoBoxModelX on TodoBoxModel {
  Todo toDomain() {
    return Todo(
      id: id.toString(),
      title: title,
      isCompleted: isCompleted,
    );
  }
}

extension TodoX on Todo {
  TodoBoxModel toBoxModel() {
    return TodoBoxModel(
      id: int.tryParse(id) ?? 0,
      title: title,
      isCompleted: isCompleted,
    );
  }
}

3. 构建带转换逻辑的ObjectBox流 #

利用ObjectBox的query().watch()方法获取数据库变更流，再通过map操作符完成模型到领域实体的转换：

Stream<List<Todo>> getTodosStream() {
  // 获取ObjectBox的实例box
  final box = ObjectBox.instance.box<TodoBoxModel>();
  // 监听查询结果变化，触发时自动转换为领域实体列表
  return box.query().watch(triggerImmediately: true)
      .map((querySnapshot) => querySnapshot.find()
          .map((boxModel) => boxModel.toDomain())
          .toList());
}

• triggerImmediately: true参数确保流订阅时会立即返回当前数据库的所有数据

4. 适配其他数据库的思路 #

这套转换逻辑同样适用于Hive等其他本地数据库，核心是监听数据库的变更流，再在流中完成模型转换：

// Hive示例
Stream<List<Todo>> getHiveTodosStream() {
  final box = Hive.box<TodoHiveModel>('todos');
  return box.watch().map((_) {
    return box.values.map((hiveModel) => hiveModel.toDomain()).toList();
  });
}

内容的提问来源于stack exchange，提问作者w461