run method

Future<int> run(
  1. Connection connection
)

Implementation

Future<int> run(Connection connection) async {
  //return connection.execute(compile());
  var result = await connection.runTx((ctx) async {
    var sql = compile();
    var result = await ctx.execute(sql).catchError((e) {
      _log.severe('Failed to run query: [ $sql ]', e);
      throw Exception(e);
    });
    return result.affectedRows;
  });

  return result;
}