写一个TODO|写一个TODO App学习Flutter数据库工具Moor

写一个TODO App学习Flutter数据库工具Moor Flutter的数据库存储, 官方文档: https://flutter.dev/docs/cookbook/persistence/sqlite
中写的是直接操纵SQLite数据库的方法.
有没有什么package可以像Android的Room一样, 帮助开发者更加方便地做数据库存储呢?
Moor就是这种目的: https://pub.dev/packages/moor.
它的名字是把Room反过来. 它是一个第三方的package.
为了学习一下怎么用, 我做了一个小的todo app: https://github.com/mengdd/more_todo.
本文是一个工作记录.
TL; DR 用Moor做TODO app:

  • 基本使用: 依赖添加, 数据库和表的建立, 对表的基本操作.
  • 问题解决: 插入数据注意类型; 多个表的文件组织.
  • 常用功能: 外键和join, 数据库升级, 条件查询.
代码: Todo app: https://github.com/mengdd/more_todo
Moor基本使用 官方这里有个文档:
Moor Getting Started
Step 1: 添加依赖
pubspec.yaml中:
dependencies: flutter: sdk: fluttermoor: ^2.4.0 moor_ffi: ^0.4.0 path_provider: ^1.6.5 path: ^1.6.4 provider: ^4.0.4dev_dependencies: flutter_test: sdk: flutter moor_generator: ^2.4.0 build_runner: ^1.8.1

这里我是用的当前(2020.4)最新版本, 之后请更新各个package版本号到最新的版本.
对各个packages的解释:
* moor: This is the core package defining most apis * moor_ffi: Contains code that will run the actual queries * path_provider and path: Used to find a suitable location to store the database. Maintained by the Flutter and Dart team * moor_generator: Generates query code based on your tables * build_runner: Common tool for code-generation, maintained by the Dart team

现在推荐使用moor_ffi而不是moor_flutter.
网上的一些例子是使用moor_flutter的, 所以看那些例子的时候有些地方可能对不上了.
Step 2: 定义数据库和表
新建一个文件, 比如todo_database.dart:
import 'dart:io'; import 'package:moor/moor.dart'; import 'package:moor_ffi/moor_ffi.dart'; import 'package:path/path.dart' as p; import 'package:path_provider/path_provider.dart'; part 'todo_database.g.dart'; // this will generate a table called "todos" for us. The rows of that table will // be represented by a class called "Todo". class Todos extends Table { IntColumn get id => integer().autoIncrement()(); TextColumn get title => text().withLength(min: 1, max: 50)(); TextColumn get content => text().nullable().named('description')(); IntColumn get category => integer().nullable()(); BoolColumn get completed => boolean().withDefault(Constant(false))(); }@UseMoor(tables: [Todos]) class TodoDatabase extends _$TodoDatabase { // we tell the database where to store the data with this constructor TodoDatabase() : super(_openConnection()); @override int get schemaVersion => 1; }LazyDatabase _openConnection() { // the LazyDatabase util lets us find the right location for the file async. return LazyDatabase(() async { // put the database file, called db.sqlite here, into the documents folder // for your app. final dbFolder = await getApplicationDocumentsDirectory(); final file = File(p.join(dbFolder.path, 'db.sqlite')); return VmDatabase(file, logStatements: true); }); }

几个知识点:
  • 要加part 'todo_database.g.dart'; , 等一下要生成这个文件.
  • 这里定义的class是Todos, 生成的具体实体类会去掉s, 也即Todo. 如果想指定生成的类名, 可以在类上加上注解, 比如: @DataClassName("Category"), 生成的类就会叫"Category".
  • 惯例: $是生成类类名前缀. .g.dart是生成文件.
Step 3: 生成代码
运行:
flutter packages pub run build_runner build

or:
flutter packages pub run build_runner watch

来进行一次性(build)或者持续性(watch)的构建.
如果不顺利, 有可能还需要加上--delete-conflicting-outputs:
flutter packages pub run build_runner watch --delete-conflicting-outputs

运行成功之后, 生成todo_database.g.dart文件.
所有的代码中报错应该消失了.
Step 4: 添加增删改查方法
对于简单的例子, 把方法直接写在数据库类里:
@UseMoor(tables: [Todos]) class TodoDatabase extends _$TodoDatabase { // we tell the database where to store the data with this constructor TodoDatabase() : super(_openConnection()); @override int get schemaVersion => 1; Future> getAllTodos() => select(todos).get(); Stream> watchAllTodos() => select(todos).watch(); Future insertTodo(TodosCompanion todo) => into(todos).insert(todo); Future updateTodo(Todo todo) => update(todos).replace(todo); Future deleteTodo(Todo todo) => delete(todos).delete(todo); }

数据库的查询不但可以返回Future还可以返回Stream, 保持对数据的持续观察.
这里注意插入的方法用了Companion对象. 后面会说为什么.
上面这种做法把数据库操作方法都写在一起, 代码多了之后显然不好.
改进的方法就是写DAO:
https://moor.simonbinder.eu/docs/advanced-features/daos/
后面会改.
Step 5: 把数据提供到UI中使用
提供数据访问方法涉及到程序的状态管理.
方法很多, 之前写过一个文章: https://www.cnblogs.com/mengdd/p/flutter-state-management.html
这里先选一个简单的方法用Provider直接提供数据库对象, 包在程序外层:
void main() => runApp(MyApp()); class MyApp extends StatelessWidget { @override Widget build(BuildContext context) { return Provider( create: (_) => TodoDatabase(), child: MaterialApp( title: 'Flutter Demo', theme: ThemeData( primarySwatch: Colors.blue, ), home: MyHomePage(), ), ); } }

需要的时候:
TodoDatabase database = Provider.of(context, listen: false);

就拿到database对象, 然后可以调用它的方法了.
之后就是UI怎么用的问题了, 这里不再多说.
我的代码中tag: v0.1.1就是这种最简单的方法.
可以checkout过去看这个最简单版本的实现.
Step 6: 改进: 抽取方法到DAO, 重构
增删改查的方法从数据库中抽取出来, 写在DAO里:
part 'todos_dao.g.dart'; // the _TodosDaoMixin will be created by moor. It contains all the necessary // fields for the tables. The type annotation is the database class // that should use this dao. @UseDao(tables: [Todos]) class TodosDao extends DatabaseAccessor with _$TodosDaoMixin { // this constructor is required so that the main database can create an instance // of this object. TodosDao(TodoDatabase db) : super(db); Future> getAllTodos() => select(todos).get(); Stream> watchAllTodos() => select(todos).watch(); Future insertTodo(TodosCompanion todo) => into(todos).insert(todo); Future updateTodo(Todo todo) => update(todos).replace(todo); Future deleteTodo(Todo todo) => delete(todos).delete(todo); }

运行命令行重新生成一下(如果是watch就不用).
其实就生成了个这:
part of 'todos_dao.dart'; mixin _$TodosDaoMixin on DatabaseAccessor { $TodosTable get todos => db.todos; }

这里的todos是其中的table对象.
所以如果不是改table, 只改变DAO中的方法实现的话, 不用重新生成.
这时候我们提供给UI的部分也要改了.
之前是Provider直接提供了database对象, 虽然可以直接换成提供DAO对象, 但是DAO会有很多个, 硬要这么提供的话代码很快就乱了.
怎么解决也有多种方法, 这是一个架构设计问题, 百花齐放, 答案很多.
我这里简单封装一下:
class DatabaseProvider { TodosDao _todosDao; TodosDao get todosDao => _todosDao; DatabaseProvider() { TodoDatabase database = TodoDatabase(); _todosDao = TodosDao(database); } }

最外层改成提供这个:
return Provider( create: (_) => DatabaseProvider(), //... );

用的时候把DAO get出来用就可以了.
如果有其他DAO也可以加进去.
Troubleshooting 插入的时候应该用Companion对象
插入数据的方法:
如果这样写:
Future insertTodo(Todo todo) => into(todos).insert(todo);

就坑了.
因为按照定义, 我们的id是自动生成并自增的:
IntColumn get id => integer().autoIncrement()();

但是生成的这个Todo类, 里面所有非空的字段都是@required的:
Todo( {@required this.id, @required this.title, this.content, this.category, @required this.completed});

要新建一个实例并插入, 我自己是无法指定这个递增的id的. (先查询再自己手动递增是不是太tricky了. 一般不符合直觉的古怪的做法都是不对的.)
可以看这两个issue中, 作者的解释也是用Companion对象:
  • https://github.com/simolus3/moor/issues/62
  • https://github.com/simolus3/moor/issues/68
所以insert方法最后写成了这样:
Future insertTodo(TodosCompanion todo) => into(todos).insert(todo);

还有一种写法是这样:
Future insertTodo(Insertable todo) => into(todos).insert(todo);

添加数据:
final todo = TodosCompanion( title: Value(input), completed: Value(false), ); todosDao.insertTodo(todo);

【写一个TODO|写一个TODO App学习Flutter数据库工具Moor】这里构建对象的时候, 只需要把需要的值用Value包装起来. 没有提供的会是Value.absent().
表定义必须和数据库类写在一起? 多个表怎么办?
实际的项目中肯定有多个表, 我想着一个表一个文件这样比较好.
于是当我天真地为我的新数据表, 比如Category, 新建一个categories.dart文件, 里面继承了Table类, 也指定了生成文件的名字.
part 'categories.g.dart'; @DataClassName('Category') class Categories extends Table { //... }

运行生成build之后代码中这行是红的:
part 'categories.g.dart';

没有生成这个文件.
查看后发现Category类仍然被生成在了databse的.g.dart文件中.
关于这个问题的讨论: https://github.com/simolus3/moor/issues/480
解决方法有两种思路:
  • 简单解决: 源码仍然分开写, 只不过所有的生成代码放一起.
去掉part语句.
@DataClassName('Category') class Categories extends Table { //... }

生成的代码仍然是方法database的生成文件中, 但是我们的源文件看起来是分开了.
之后使用具体数据类型的时候, import的还是database文件对应类.
  • 使用.moor文件.
进阶需求 外键和join
把两个表关联起来这个需求还挺常见的.
比如我们的todo实例, 增加了Category类之后, 想把todo放在不同的category中, 没有category的就放在inbox里, 作为未分类.
moor对外键不是直接支持, 而是通过customStatement来实现的.
这里Todos类里的这一列, 加上自定义限制, 关联到categories表:
IntColumn get category => integer() .nullable() .customConstraint('NULL REFERENCES categories(id) ON DELETE CASCADE')();

要用主键id.
这里指定了两遍可以null: 一次是nullable(), 另一次是在语句中.
实际上customConstraint中的会覆盖前者. 但是我们仍然需要前者, 用来表明在生成类中改字段是可以为null的.
另外还指定了删除category的时候删除对应的todo.
外键默认不开启, 需要运行:
customStatement('PRAGMA foreign_keys = ON');

join查询的部分, 先把两个类包装成第三个类.
class TodoWithCategory { final Todo todo; final Category category; TodoWithCategory({@required this.todo, @required this.category}); }

之后更改TODO的DAO, 注意这里添加了一个table, 所以要重新生成一下.
之前的查询方法改成这样:
Stream> watchAllTodos() { final query = select(todos).join([ leftOuterJoin(categories, categories.id.equalsExp(todos.category)), ]); return query.watch().map((rows) { return rows.map((row) { return TodoWithCategory( todo: row.readTable(todos), category: row.readTable(categories), ); }).toList(); }); }

join返回的结果是List, 这里用map操作符转换一下.
数据库升级
数据库升级, 在数据库升级的时候添加新的表和列.
由于外键默认是不开启的, 所以也要开启一下.
PS: 这里Todo中的category之前已经建立过了.
迁移的时候不能修改已经存在的列. 所以只能弃表重建了.
@UseMoor(tables: [Todos, Categories]) class TodoDatabase extends _$TodoDatabase { // we tell the database where to store the data with this constructor TodoDatabase() : super(_openConnection()); @override int get schemaVersion => 2; @override MigrationStrategy get migration => MigrationStrategy( onUpgrade: (migrator, from, to) async { if (from == 1) { migrator.deleteTable(todos.tableName); migrator.createTable(todos); migrator.createTable(categories); } }, beforeOpen: (details) async { await customStatement('PRAGMA foreign_keys = ON'); }, ); }

没想到报错了: Unhandled Exception: SqliteException: near "null": syntax error,
出错的是drop table的这句:
Moor: Sent DROP TABLE IF EXISTS null; with args []

说todos.tableName是null.
这个get的设计用途原来是用来指定自定义名称的:
https://pub.dev/documentation/moor/latest/moor_web/Table/tableName.html
因为我没有设置自定义名称, 所以这里返回了null.
这里我改成了:
migrator.deleteTable(todos.actualTableName);

条件查询
查某个分类下:
Stream> watchTodosInCategory(Category category) { final query = select(todos).join([ leftOuterJoin(categories, categories.id.equalsExp(todos.category)), ]); if (category != null) { query.where(categories.id.equals(category.id)); } else { query.where(isNull(categories.id)); }return query.watch().map((rows) { return rows.map((row) { return TodoWithCategory( todo: row.readTable(todos), category: row.readTable(categories), ); }).toList(); }); }

多个条件的组合用&, 比如上面的查询组合未完成:
query.where( categories.id.equals(category.id) & todos.completed.equals(false));

总结 Moor是一个第三方的package, 用来帮助Flutter程序的本地存储. 由于开放了SQL语句查询, 所以怎么定制都行. 作者很热情, 可以看到很多issue下都有他详细的回复.
本文是做一个TODO app来练习使用moor.
包括了基本的增删改查, 外键, 数据库升级等.
代码: https://github.com/mengdd/more_todo
参考
  • Moor github
  • Moor website
  • package: moor_ffi
  • Moor Getting Started
  • Moor (Room for Flutter) #1 – Tables & Queries – Fluent SQLite Database
  • Moor (Room for Flutter) #3 – Foreign Keys, Joins & Migrations – Fluent SQLite Database
  • SQLite Foreign Key Support
最后, 欢迎订阅公众号: 圣骑士Wind:

写一个TODO|写一个TODO App学习Flutter数据库工具Moor
文章图片
圣骑士Wind微信公众号.png

    推荐阅读