@override Future<QueryExecutor> startTransaction() async { await connection!.execute('begin'); return this; }