我正在开发一个使用 sqlite 和事务的移动应用程序。
下面的代码是通过使用sqlite事务保存模型到多个数据库表来从用户那里获取订单信息。
Future<AppResult<int>> save(Order order) async {
Database db;
var dbReturn = BaseService();
try {
db = await databaseOpen();
int dbSaveResult = 0;
await db.transaction((txn) async {
var batch = txn.batch();
final List<Map<String, dynamic>> exist = await db.query(tableName, where: "id =?", whereArgs: [order.id]);
if (exist.length == 0) {
await _insert(order, txn, batch);
} else {
await _update(order, txn, batch);
}
await batch.commit(continueOnError: true).then((value) {
if (value.length > 0) dbSaveResult = value.length;
});
});
return dbReturn.success<int>(dbSaveResult, "Kaydedildi", 1, 1);
} on Exception catch (e) {
return dbReturn.failed<int>(-1, "OrderDbService -> save", 0, 0, e);
} finally {
if (db != null && db.isOpen) {
await db.close();
}
}
}
Future<void> _insert(Order order, Transaction txn, Batch batch) async {
try {
order = setEntityValue(order, false);
order = _setOrder(order, order.lines);
batch.insert(tableName, order.toMap(), conflictAlgorithm: ConflictAlgorithm.replace);
await _saveLines(order.lines, txn, batch);
await _saveDescriptions(order.descriptions, txn, batch);
await _saveDetail(order.detail, txn, batch);
await _saveDiscounts(order.discounts, txn, batch);
await _saveExchangeRates(order.exchangeRates, txn, batch);
} on Exception catch (e) {
throw e;
}
}
调用 sqlite 方法后抛出一条消息，如下所示
D/Sqflite ( 8938): [57,main(2)] starting threadThread[Sqflite,5,main] priority 10
D/Sqflite ( 8938): [57,main(2)] opened 57 /data/user/0/com.tttt.mobileApp/databases/tttt.db
D/Sqflite ( 8938): [57,Sqflite(484)] opened 57 /data/user/0/com.tttt.mobileApp/databases/tttt.db
D/Sqflite ( 8938): [57,Sqflite(484)] BEGIN IMMEDIATE
I/flutter ( 8938): Warning database has been locked for 0:00:10.000000. Make sure you always use the transaction object for database operations during a transaction
