在 Google Cloud Spanner 中插入或读取如果记录已存在的最高效方式

如何解决在 Google Cloud Spanner 中插入或读取如果记录已存在的最高效方式

假设我有一个 cars 表，其中 vin 是主键。 我想插入一条记录（在事务中）或读取记录（如果已经存在具有相同 PK 的记录）。

如果已经存在具有相同 PK 的记录，那么插入或读取记录的最佳方法是什么？

这是我目前的方法：

情况 A：记录不存在

1. 插入记录
2. 退货记录

情况 B：记录已存在

1. 插入记录
2. 检查错误是否是由于记录已经存在
3. 阅读记录
4. 退货记录

const car = { vin: '123',make: 'honda',model: 'accord' };

spannerDatabase.runTransactionAsync(async (databaseTransaction) => {
    try {
        // Try to insert car
        await databaseTransaction.insert('cars',car);
        await databaseTransaction.commit();
        return car;
    } catch (error) {
        await databaseTransaction.end();
        // Spanner "row already exists" error. Insert failed because there is already a record with the same vin(PK)
        if (error.code === 6) {
            // Since the record already exists,I want to read it and return it. Whats the most performant way to do this?
            const existingRecord = await carsTable.read({
                columns: ['vin','make','model'],keys: [car.vin],json: true,});
            return existingRecord;
        }
    }
})

解决方法

正如@skuruppu 在上面的评论中提到的，您当前的示例对于您所描述的内容基本没问题。然而，它确实隐含地假设了几件事，因为您没有在同一个事务中执行读取和插入。这意味着这两个操作一起不是原子的，其他事务可能会更新或删除您的两个操作之间的记录。

此外，您的方法假设场景 A（记录不存在）是最有可能的。如果情况并非如此，并且记录很可能确实存在，那么您应该在写入之前在事务中执行读取。

如果有其他可能删除记录的进程，您也应该这样做。否则，另一个进程可能会在您尝试插入记录之后删除该记录，但之前您尝试读取它（在事务之外）。

上述问题仅在存在其他可能删除或更改记录的进程时才真正成为问题。如果不是这样，将来也不会，这只是一个理论问题。

总结一下：

1. 您的示例很好如果场景 A 最有可能并且没有其他进程会删除 cars 表中的任何记录。
2. 如果 1 中的任何条件不成立，您应该在写入之前对两个操作使用相同的读/写事务执行读取。

您在示例中使用的 read 操作是从表中读取单行的最有效方法。