Simplify your stack and build anything. Or everything.
Build tomorrow’s web with a modern solution you truly own.
Code-based nature means you can build on top of it to power anything.
It’s time to take back your content infrastructure.

Transactions

Database transactions allow your application to make a series of database changes in an all-or-nothing commit. Consider an HTTP request that creates a new Order and has an afterChange hook to update the stock count of related Items. If an error occurs when updating an Item and an HTTP error is returned to the user, you would not want the new Order to be persisted or any other items to be changed either. This kind of interaction with the database is handled seamlessly with transactions.

By default, Payload will use transactions for all operations, as long as it is supported by the configured database. Database changes are contained within all Payload operations and any errors thrown will result in all changes being rolled back without being committed. When transactions are not supported by the database, Payload will continue to operate as expected without them.

The initial request made to Payload will begin a new transaction and attach it to the req.transactionID. If you have a hook that interacts with the database, you can opt-in to using the same transaction by passing the req in the arguments. For example:

1
const afterChange: CollectionAfterChangeHook = async ({ req }) => {
2
// because req.transactionID is assigned from Payload and passed through,
3
// my-slug will only persist if the entire request is successful
4
await req.payload.create({
5
req,
6
collection: 'my-slug',
7
data: {
8
some: 'data',
9
},
10
})
11
}

Async Hooks with Transactions

Since Payload hooks can be async and be written to not await the result, it is possible to have an incorrect success response returned on a request that is rolled back. If you have a hook where you do not await the result, then you should not pass the req.transactionID.

1
const afterChange: CollectionAfterChangeHook = async ({ req }) => {
2
// WARNING: an async call made with the same req, but NOT awaited,
3
// may fail resulting in an OK response being returned with response data that is not committed
4
const dangerouslyIgnoreAsync = req.payload.create({
5
req,
6
collection: 'my-slug',
7
data: {
8
some: 'other data',
9
},
10
})
11
12
// Should this call fail, it will not rollback other changes
13
// because the req (and its transactionID) is not passed through
14
const safelyIgnoredAsync = req.payload.create({
15
collection: 'my-slug',
16
data: {
17
some: 'other data',
18
},
19
})
20
}

Direct Transaction Access

When writing your own scripts or custom endpoints, you may wish to have direct control over transactions. This is useful for interacting with your database in something like a background job, outside the normal request-response flow.

The following functions can be used for managing transactions:

payload.db.beginTransaction - Starts a new session and returns a transaction ID for use in other Payload Local API calls. Note that if your database does not support transactions, this will return null.
payload.db.commitTransaction - Takes the identifier for the transaction, finalizes any changes.
payload.db.rollbackTransaction - Takes the identifier for the transaction, discards any changes.

You can then use the transaction ID with Payload's local API by passing it inside the PayloadRequest object.

Here is an example for a "background job" function, which utilizes the direct transaction API to make sure it either succeeds completely or gets rolled back in case of an error.

1
async function allOrNothingJob() {
2
const req = {} as PayloadRequest;
3
req.transactionID = await payload.db.beginTransaction();
4
try {
5
await payload.create({
6
req, // use our manual transaction
7
collection: 'my-slug',
8
data: {
9
some: 'data'
10
}
11
});
12
13
await payload.create({
14
req, // use our manual transaction
15
collection: 'something-else',
16
data: {
17
some: 'data'
18
}
19
});
20
console.log('Everything done.');
21
if (req.transactionID) await payload.db.commitTransaction(req.transactionID);
22
} catch (e) {
23
console.error('Oh no, something went wrong!');
24
if (req.transactionID) await payload.db.rollbackTransaction(req.transactionID);
25
}
26
27
}
Next

MongoDB