openTransaction method

  1. @override
Future<DBMySqlConnectionWrapper> openTransaction(
  1. Transaction transaction
)
override

Implementation

@override
Future<DBMySqlConnectionWrapper> openTransaction(Transaction transaction) =>
    openTransactionWithPool<DBMySqlConnectionWrapper>(
      transaction,
      (connection, onTransactionContext) =>
          connection.openTransaction((transactionWrap) {
            onTransactionContext(transactionWrap);

            return transaction.transactionFuture.then(
              (res) => resolveTransactionResult(res, transaction, connection),
              onError: (e, s) {
                cancelTransaction(transaction, connection, e, s);
                throw e;
              },
            );
          }),
    );