sqlite - flutter sqlite 事务使用错误警告数据库已被锁定

Question

我正在开发一个使用 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

Answer 1

已解决: 确保您不在事务中使用数据库实例，如下所示

await db.query(tableName, where: "id =?", whereArgs: [order.id]);

而不是像下面这样使用

await txn.query(tableName, where: "id =?", whereArgs: [order.id]);

flutter 不会警告您任何事务使用错误。