Transactions

You may use the transaction method provided by the Arquebus ORM connection to run a set of operations within a database transaction. If an exception is thrown within the transaction closure, the transaction will automatically be rolled back and the exception is re-thrown. If the closure executes successfully, the transaction will automatically be committed. You don't need to worry about manually rolling back or committing while using the transaction method:

import { arquebus } from '@h3ravel/arquebus';

const db = arquebus.fire();

await db.transaction(async (trx) => {
  await User.query().transacting(trx).create(/* ... */);

  await db.table('users').transacting(trx).insert(/* ... */);

  const user = new User();
  user.name = 'Sally';

  await user.save({
    client: trx,
  });
});

Manually Using Transactions

If you would like to begin a transaction manually and have complete control over rollbacks and commits, you may use the beginTransaction method provided by the arquebus:

import { arquebus } from '@h3ravel/arquebus';

const db = arquebus.fire();
const trx = await db.beginTransaction();

You can rollback the transaction via the rollback method:

await trx.rollback();

Lastly, you can commit a transaction via the commit method:

await trx.commit();

Here is a complete example:

import { arquebus } from '@h3ravel/arquebus';

const db = arquebus.fire();
const trx = await db.beginTransaction();

try {
  const user = new User();
  user.name = 'Sally';

  await user.save({
    client: trx,
  });

  await trx.commit();
} catch (e) {
  await trx.rollback();

  console.log(e.stack);
}