如何在数据库中保持应用程序级并发的同时将逻辑与数据访问分离

Question

我正在尝试为某件商品预订订单。但要做到这一点，我需要能够获取项目并锁定它们，以便在我更新或释放锁之前阻止其他并发读取和写入。保证调用 release 的方式是使用 try-finally 块。

如何在保持逻辑和数据访问关注点分离的同时阻止对表或某些行的读取和写入？

用例大致如下：

def use_case(input, repository):
    validate_input(input)
    try:
        data = repository.get_data()

        if condition1 and condition2:
            update_data()
    finally:
        repository.unlock()

我实现存储库的方式是：

class Repository:
    def get_data():
         conn = adapter.connect()
         cur = conn.cursor()

         cur.execute('select * from table where condition')

         cur.close()
         conn.close()

    def update():
         conn = adapter.connect()
         cur = conn.cursor()

         cur.execute('update table set field = value where condition')

         cur.close()
         conn.close()
    
    def unlock():
         pass

我尝试过选择更新、显式锁定和咨询锁，但它们都在连接关闭时释放，这是正确的。

我本可以使用乐观锁定，但问题是我一次更新多个列。即使一次列的值发生变化，我也需要重新运行我的逻辑。

我创建单独连接的原因是通过仅在需要时创建它们来避免空闲连接。我不知道这是否是标准的做事方式。

Answer 1

基本上有两种选择：乐观锁和悲观锁：

• 使用悲观锁定，所有事情都发生在单个数据库事务中。你SELECT ... FOR UPDATE，你通过提交事务来释放锁。

  如果整个动作很短（没有用户交互！），悲观锁定是好的，特别是如果冲突的可能性很高。

• 乐观锁定不绑定到数据库事务（尽管您可以使用REPEATABLE READ 事务来实现它）。您记住所有列的原始值并使用UPDATE 和WHERE 条件来检查所有值是否仍然相同（没有人修改该行）。如果并发事务修改了行（没有更新行），则重复整个操作。

  如果操作需要很长时间或发生冲突的可能性很低，那么乐观锁定是很好的。