Transactions and migrations

await this.prisma.$transaction(async (tx) => {
  // 1. Update order status
  await tx.order.update({
    where: { id: orderId },
    data: { status: 'APPROVED' },
  });

  // 2. Record consumption against the entitlement period
  await tx.orderItem.update({
    where: { id: itemId },
    data: { entitlementQuantityConsumed: quantity },
  });

  // 3. Create status history record
  await tx.orderStatusHistory.create({
    data: {
      orderId,
      fromStatus: 'SUBMITTED',
      toStatus: 'APPROVED',
      changedById: userId,
    },
  });
});

for (const row of validRows) {
  await this.prisma.employee.upsert({
    where: { employeeNumber: row.employeeNumber },
    update: { /* changed fields */ },
    create: { ...row },
  });
}