参考
https://drift.simonbinder.eu/dart_api/schema_inspection/
正文运行时模式检查
得益于 Drift 生成的类型安全表类，在 Dart 中编写 SQL 查询既简单又安全。然而，这些查询通常针对特定的表。虽然 Drift 支持表的继承，但有时通过反射访问表会更容易。幸运的是，Drift 生成的代码实现了可用于执行此操作的接口。
由于大多数漂移用户并不需要这个主题，因此本页面主要提供一些启发性的示例以及相关漂移类文档的链接。例如，您可能有多个包含同一id列的独立表。并且您可能希望按列筛选行id。当针对单个表（例如入门Todos页面中所示的表）编写此查询时，操作非常简单：
个人理解：其实就是针对数据库操作相关代码进行二次封装；
Selectable<Todo> findTodoEntryById(int id) {
return select(todos)..where((row) => row.id.equals(id));
}
但是，假设我们想将此查询推广到每个数据库表，该怎么办呢？以下代码片段展示了如何实现这一点（请注意，代码片段中的链接直接指向相关文档）：
extension FindById<Table extends HasResultSet, Row>
on ResultSetImplementation<Table, Row> {
Selectable<Row> findById(int id) {
return select()
..where((row) {
final idColumn = columnsByName['id'];
if (idColumn == null) {
throw ArgumentError.value(
this, 'this', 'Must be a table with an id column');
}
if (idColumn.type != DriftSqlType.int) {
throw ArgumentError('Column `id` is not an integer');
}
return idColumn.equals(id);
});
}
}
由于这比仅适用于单个表的查询要复杂得多，让我们详细看看每一行有趣的内容：
- FindById是ResultSetImplementation的扩展。此类是 Drift
生成的每个表或视图的超类。它定义了一些有用的方法来检查模式，或将Map表示数据库行的原始数据转换为生成的数据类。 - ResultSetImplementation使用两个类型参数进行实例化：原始表类和生成的行类。例如，如果您定义了一个表class
Todos extends Table，drift 会生成一个继承自该表的类Todos，同时实现该类。 - ResultSetImplementation<Todos, Todo>（其中，driftTodo是生成的数据类）。
- ResultSetImplementation有两个子类：TableInfo和ViewInfo，分别混合到生成的表和视图类中。
- HasResultSetTable是和的超类View，这两个类用于在drift 中声明表和视图。
- **Selectable表示一个查询，您可以使用get()、watch()和getSingle()等方法watchSingle()**来运行该查询。
- select()所使用的扩展可findById用于启动选择语句，而无需引用数据库类 - 您所需要的只是表实例。
- 在 SQL 中，我们可以columnsByName通过名称查找列。这里，我们期望int存在一个列。
- GeneratedColumn类表示数据库中的一列。可以从列实例中读取诸如列约束、类型或默认值等信息。
- 具体来说，我们使用它来断言该表确实有一个IntColumn名为的id。
更新和插入
同样的方法也适用于构造更新、删除和插入语句（尽管 由于视图是只读的，这些语句需要TableInfo而不是ResultSetImplementationInsertable ）。此外，更新和插入分别使用一个对象来表示更新或插入列的部分行。对于已知表，可以使用生成的类型化Companion对象来实现。但这也可以通过模式自省来实现，这要归功于RawValuesInsertable，它可以用作Insertable由列名到值的映射支持的泛型。
此示例在前一个示例的基础上，title根据id列的过滤器来更新通用表的列：
extension UpdateTitle on DatabaseConnectionUser {
Future<Row?> updateTitle<T extends TableInfo<Table, Row>, Row>(
T table, int id, String newTitle) async {
final columnsByName = table.columnsByName;
final stmt = update(table)
..where((tbl) {
final idColumn = columnsByName['id'];
if (idColumn == null) {
throw ArgumentError.value(
this, 'this', 'Must be a table with an id column');
}
if (idColumn.type != DriftSqlType.int) {
throw ArgumentError('Column `id` is not an integer');
}
return idColumn.equals(id);
});
final rows = await stmt.writeReturning(RawValuesInsertable({
'title': Variable<String>(newTitle),
}));
return rows.singleOrNull;
}
}
在数据库或数据库访问器类中，可以像这样调用该方法：
Future<Todo?> updateTodoTitle(int id, String newTitle) {
return updateTitle(todos, id, newTitle);
}
具体详细使用方法，可以去学习源码