首页 > 解决方案 > 在原子块内调用的“select_for_update”仍然是 TransactionManagementError

问题描述

代码爆炸

@transaction.atomic
def cancel_one(o_id):
    order= Order.objects.select_for_update().get(id=o_id)

提高

TransactionManagementError('select_for_update 不能在事务之外使用。')

django.db.transaction.TransactionManagementError: select_for_update 不能在事务之外使用。

我检查了我的代码是否在交易中transaction.get_connection().in_atomic_block.

它出现在交易中,但仍然提高

错误:django.db.transaction.TransactionManagementError:select_for_update 不能在事务之外使用。

我的代码:

# Step1
def cancel_one(o_id):
   print("DO")
   cxn = transaction.get_connection()
   if cxn.in_atomic_block:
       print("We're inside a transaction!")
   order= Order.objects.select_for_update().get(id=o_id)

# Step2
@transaction.atomic
def cancel_one(o_id):
   print("DO")
   cxn = transaction.get_connection()
   if cxn.in_atomic_block:
       print("We're inside a transaction!")
   order= Order.objects.select_for_update().get(id=o_id)

代码结果

# Step1
-----------------------
DO
-----------------------

# Step2
-----------------------
DO
"We're inside a transaction!"
-----------------------

标签: djangodjango-orm

解决方案


您是否有机会使用 DBRouters?我遇到了麻烦-技巧是在事务和 select_for_update 上定义数据库

with transaction.atomic(using='db_x'):
    order = Order.objects.using('db_x').select_for_update().get(id=o_id)

推荐阅读