事务
SQL 事务是一个或多个 SQL 语句的组合，这些语句与数据库进行交互。 整个事务可以作为一个单一的逻辑单元提交到数据库， 或者回滚（恢复为未执行状态）为一个单一的逻辑单元。
Drizzle ORM 提供了在事务中运行 SQL 语句的 API：
const db = drizzle(...)
await db.transaction(async (tx) => {
await tx.update(accounts).set({ balance: sql`${accounts.balance} - 100.00` }).where(eq(users.name, 'Dan'));
await tx.update(accounts).set({ balance: sql`${accounts.balance} + 100.00` }).where(eq(users.name, 'Andrew'));
});Drizzle ORM 通过嵌套事务 API 支持 savepoints：
const db = drizzle(...)
await db.transaction(async (tx) => {
await tx.update(accounts).set({ balance: sql`${accounts.balance} - 100.00` }).where(eq(users.name, 'Dan'));
await tx.update(accounts).set({ balance: sql`${accounts.balance} + 100.00` }).where(eq(users.name, 'Andrew'));
await tx.transaction(async (tx2) => {
await tx2.update(users).set({ name: "Dan 先生" }).where(eq(users.name, "Dan"));
});
});你可以将业务逻辑嵌入事务中，并在需要时随时回滚：
const db = drizzle(...)
await db.transaction(async (tx) => {
const [account] = await tx.select({ balance: accounts.balance }).from(accounts).where(eq(users.name, 'Dan'));
if (account.balance < 100) {
// 这会抛出一个异常，从而回滚事务。
tx.rollback()
}
await tx.update(accounts).set({ balance: sql`${accounts.balance} - 100.00` }).where(eq(users.name, 'Dan'));
await tx.update(accounts).set({ balance: sql`${accounts.balance} + 100.00` }).where(eq(users.name, 'Andrew'));
});你可以从事务中返回值：
const db = drizzle(...)
const newBalance: number = await db.transaction(async (tx) => {
await tx.update(accounts).set({ balance: sql`${accounts.balance} - 100.00` }).where(eq(users.name, 'Dan'));
await tx.update(accounts).set({ balance: sql`${accounts.balance} + 100.00` }).where(eq(users.name, 'Andrew'));
const [account] = await tx.select({ balance: accounts.balance }).from(accounts).where(eq(users.name, 'Dan'));
return account.balance;
});你可以将事务与 关系查询 一起使用：
const db = drizzle({ schema })
await db.transaction(async (tx) => {
await tx._query.users.findMany({
with: {
accounts: true
}
});
});我们提供了与方言相关的事务配置 API：
await db.transaction(
async (tx) => {
await tx.update(accounts).set({ balance: sql`${accounts.balance} - 100.00` }).where(eq(users.name, "Dan"));
await tx.update(accounts).set({ balance: sql`${accounts.balance} + 100.00` }).where(eq(users.name, "Andrew"));
}, {
isolationLevel: "read committed",
}
);
interface MsSqlTransactionConfig {
isolationLevel?:
| "read uncommitted"
| "read committed"
| "repeatable read"
| "serializable"
| "snapshot";
}