事务

Deno KV 目前处于测试阶段

Deno 的 KV 及其相关的云基元 API，如队列和定时任务，目前仍处于实验性阶段，可能会发生变化。尽管我们尽力确保数据持久性，但特别是在 Deno 更新时，仍然存在数据丢失的可能性。

在启动使用 KV 的 Deno 程序时，需要添加--unstable标志，如下所示：

deno run -A --unstable my_kv_code.ts

Deno KV 存储使用 乐观并发控制事务 而不是像许多 SQL 系统（如 PostgreSQL 或 MySQL）那样使用 交互式事务。这种方法使用版本戳，表示给定键的当前版本，以管理共享资源的并发访问而不使用锁。当发生读取操作时，系统将返回与关联键一起的版本戳以及值。

要执行事务，需要执行原子操作，可以包含多个变异操作（如设置或删除）。除了这些操作之外，还提供键+版本戳对作为事务成功的条件。只有在指定的版本戳与数据库中相应键的值的当前版本匹配时，乐观并发控制事务才会提交。这种事务模型确保了数据的一致性和完整性，同时允许在 Deno KV 存储中进行并发交互。

因为 OCC 事务是乐观的，所以在提交时可能会失败，因为原子操作中指定的版本约束被违反。这发生在代理在读取和提交之间更新了事务中使用的键时。当发生这种情况时，执行事务的代理必须重试事务。

为了说明如何在 Deno KV 中使用 OCC 事务，以下示例展示了如何为账户分类帐实现 transferFunds(from: string, to: string, amount: number) 函数。账户分类帐在键值存储中存储每个账户的余额。键以 "account" 为前缀，后跟账户标识符：["account", "alice"]。每个键存储的值是表示账户余额的数字。

以下是实现 transferFunds 函数的逐步示例：

async function transferFunds(sender: string, receiver: string, amount: number) {
  if (amount <= 0) throw new Error("Amount must be positive");

  // 构造发送方和接收方帐户的 KV 键。
  const senderKey = ["account", sender];
  const receiverKey = ["account", receiver];

  // 重试事务，直到成功。
  let res = { ok: false };
  while (!res.ok) {
    // 读取两个帐户的当前余额。
    const [senderRes, receiverRes] = await kv.getMany([senderKey, receiverKey]);
    if (senderRes.value === null) throw an Error(`未找到帐户 ${sender}`);
    if (receiverRes.value === null) throw an Error(`未找到帐户 ${receiver}`);

    const senderBalance = senderRes.value;
    const receiverBalance = receiverRes.value;

    // 确保发送方有足够的余额来完成转账。
    if (senderBalance < amount) {
      throw an Error(
        `余额不足以从 ${sender} 转账 ${amount}`,
      );
    }

    // 执行转账。
    const newSenderBalance = senderBalance - amount;
    const newReceiverBalance = receiverBalance + amount;

    // 尝试提交事务。如果由于检查失败（即键的版本戳已更改）而导致事务无法提交，`res` 将返回一个具有 `ok: false` 的对象。
    res = await kv.atomic()
      .check(senderRes) // 确保发送方的余额没有更改。
      .check(receiverRes) // 确保接收方的余额没有更改。
      .set(senderKey, newSenderBalance) // 更新发送方的余额。
      .set(receiverKey, newReceiverBalance) // 更新接收方的余额。
      .commit();
  }
}

在此示例中，transferFunds 函数读取两个帐户的余额和版本戳，计算转账后的新余额，并检查帐户 A 是否有足够的资金。然后，它执行一个原子操作，使用版本戳约束设置新的余额。如果事务成功，循环退出。如果版本约束被违反，事务将失败，循环将重试事务，直到成功为止。