-
分析数据需求 请暂停并询问用户： "数据层需要管理哪些具体的数据实体，它们的持久化需求是什么（例如，大小、关系复杂度、离线优先能力）？" 等待用户回复后再继续步骤 2。
-
配置依赖项 根据决策逻辑，添加所需的依赖项。对于标准的 SQLite 实现，请执行：
flutter pub add sqflite path
-
定义领域模型 创建代表领域模型的纯 Dart 数据类。这些模型应仅包含应用程序其他部分所需的信息。
class Todo {
final int? id;
final String title;
final bool isCompleted;
const Todo({this.id, required this.title, required this.isCompleted});
Map<String, dynamic> toMap() {
return {
'id': id,
'title': title,
'isCompleted': isCompleted ? 1 : 0,
};
}
factory Todo.fromMap(Map<String, dynamic> map) {
return Todo(
id: map['id'] as int?,
title: map['title'] as String,
isCompleted: map['isCompleted'] == 1,
);
}
}
-
实现数据库服务 创建一个无状态的服务类来处理与 SQLite 数据库的直接交互。
import 'package:path/path.dart';
import 'package:sqflite/sqflite.dart';
class DatabaseService {
Database? _database;
Future<void> open() async {
if (_database != null && _database!.isOpen) return;
_database = await openDatabase(
join(await getDatabasesPath(), 'app_database.db'),
onCreate: (db, version) {
return db.execute(
'CREATE TABLE todos(id INTEGER PRIMARY KEY AUTOINCREMENT, title TEXT, isCompleted INTEGER)',
);
},
version: 1,
);
}
bool get isOpen => _database != null && _database!.isOpen;
Future<int> insertTodo(Todo todo) async {
return await _database!.insert(
'todos',
todo.toMap(),
conflictAlgorithm: ConflictAlgorithm.replace,
);
}
Future<List<Todo>> fetchTodos() async {
final List<Map<String, dynamic>> maps = await _database!.query('todos');
return maps.map((map) => Todo.fromMap(map)).toList();
}
Future<void> deleteTodo(int id) async {
await _database!.delete(
'todos',
where: 'id = ?',
whereArgs: [id],
);
}
}
-
实现 API 客户端服务（可选/如果适用） 创建一个用于远程数据获取的无状态服务。
class ApiClient {
Future<List<dynamic>> fetchRawTodos() async {
// Implementation for HTTP GET request
return [];
}
}
-
实现 Repository 创建 Repository 类。这是应用程序数据的单一数据源。它必须将服务封装为私有成员。
class TodoRepository {
final DatabaseService _databaseService;
final ApiClient _apiClient;
TodoRepository({
required DatabaseService databaseService,
required ApiClient apiClient,
}) : _databaseService = databaseService,
_apiClient = apiClient;
Future<List<Todo>> getTodos() async {
await _ensureDbOpen();
// 离线优先逻辑示例：获取本地数据，可选地与远程同步
return await _databaseService.fetchTodos();
}
Future<void> createTodo(Todo todo) async {
await _ensureDbOpen();
await _databaseService.insertTodo(todo);
// 如有必要，在此处触发 API 同步
}
Future<void> removeTodo(int id) async {
await _ensureDbOpen();
await _databaseService.deleteTodo(id);
}
Future<void> _ensureDbOpen() async {
if (!_databaseService.isOpen) {
await _databaseService.open();
}
}
}
-
验证与修复 根据以下检查项审查生成的实现：
- 检查： 服务（
_databaseService、_apiClient）是否是 Repository 的私有成员？如果不是，请重构以限制 UI 层访问。
- 检查： Repository 在执行查询前是否明确确保数据库已打开？如果没有，请注入
_ensureDbOpen() 模式。
- 检查： 在 SQLite 查询中是否有效使用了主键（
id）以优化更新/删除时间？
