runInTransaction method

@override Future<RunResult> runInTransaction(List<Statement> statements)

Implementation

@override
Future<RunResult> runInTransaction(List<Statement> statements) async {
  return db.transaction(() async {
    int rowsAffected = 0;
    for (final statement in statements) {
      final changes = await _wrapUpdate(db, statement);
      rowsAffected += changes;
    }
    return RunResult(rowsAffected: rowsAffected);
  });
}