Database API

const response = await api.getDatabaseData('orders', {
  fields: ['orderId', 'customerId', 'amount', 'createdAt'],
  filter: {
    and: [
      { field: 'status', op: 'eq', value: 'CONFIRMED' },
      { field: 'amount', op: 'gte', value: 100, filterType: 'number' },
    ],
  },
  sort: { createdAt: 'DESC' },
  take: 100,
});

return { rows: response.data, next: response.next };

await api.updateDatabaseDataRequest(
  'orders',
  { filter: { field: 'status', op: 'eq', value: 'NEW' }, take: 1000 },
  { status: 'QUEUED' },
);

const created = await api.transactionDatabase(async (tx) => {
  const customerId = api.input('customerId');
  const existing = await tx.getDatabaseData(
    'customers',
    { filter: { field: 'customerId', op: 'eq', value: customerId }, take: 1 },
    { lock: 'update' },
  );

  if (existing.results === 0) {
    await tx.insertDatabaseData('customers', [{ customerId, status: 'ACTIVE' }]);
  }
  return existing.results === 0;
});