Fix insertReturning not updating streams

* test case not possible due to sqlite version
This commit is contained in:
Peter Leibiger 2021-05-25 12:23:23 +02:00
parent 61cb03ad35
commit bc2aaee2f3
No known key found for this signature in database
GPG Key ID: 855A3ADD4CC39135
1 changed files with 2 additions and 0 deletions

View File

@ -87,6 +87,8 @@ class InsertStatement<T extends Table, D> {
return database.doWhenOpened((e) async {
final result = await e.runSelect(ctx.sql, ctx.boundVariables);
database
.notifyUpdates({TableUpdate.onTable(table, kind: UpdateKind.insert)});
return table.map(result.single);
});
}