Python Django 트랜잭션 소스 코드 분석 소개

본 글에서는 python django 트랜잭션 트랜잭션 소스코드 분석 관련 정보를 주로 소개합니다. 필요한 친구는

python Django 트랜잭션

Django 1.6에 대한 정보는 인터넷에 많이 있는데, 1.8에 대한 정보를 찾을 수가 없어요. 지금은 참고한 사람이 거의 없습니다. 우회 버전: Django 1.8 거래 공식 문서에는 거래 방법이 많이 있습니다. 아래에서는 하나씩 자세히 설명하지 않겠습니다. 공식 문서 transaction.atomic에 따르면 데코레이터와 컨텍스트 관리의 두 가지 용도만 분석합니다. Server

# atomic() 方法 
# from django.db import transaction
###################
# atomic()
###################
def atomic(using=None, savepoint=True): # 装饰器和上下文管理器必须.()调用方法，因为真正的处理是该方法返回的实例，不是该方法本身
 if callable(using):
  return Atomic(DEFAULT_DB_ALIAS, savepoint)(using)
 # Decorator: @atomic(...) or context manager: with atomic(...): ...
 else:
  return Atomic(using, savepoint)
##########################################
# Atomic类 省略了非核心内容
############################################
class Atomic(ContextDecorator):
 def init(self, using, savepoint):
 self.using = using
 self.savepoint = savepoint
 def enter(self):
 connection = get_connection(self.using)
 sid = connection.savepoint()   # 进入with创建一个保存点
 # .............do
 def exit(self, exc_type, exc_value, traceback):
 if connection.in_atomic_block:
 # do.............
 if sid is not None:
  try:
   connection.savepoint_commit(sid)  # 提交事务
  except DatabaseError:
   try:
    connection.savepoint_rollback(sid) # 捕获数据库异常回滚
    connection.savepoint_commit(sid)
   except Error:
    connection.needs_rollback = True
   raise
 ## 还有一段代码是exec_type收到其他程序异常时候 全局回滚，此处省略
 # do.................
###############################
# ContextDecorator
#################################
class ContextDecorator(object):
 def call(self, func):
  def inner(*args, **kwargs):
   with self:    # 把函数放进self的with上下文管理器，效果with相同，只是控制细粒度不同
    return func(*args, **kwargs)
  return inner

python MySQLdb

class Tran():
 def init(self, conn=None, close=True):
  if conn is None:     # 创建数据库链接
   print 'init'
   self.conn = conn_tbkt()
   self.cur = self.conn.cursor()
   self.sql = []
 def enter(self):       # 上下文管理器返回 sql语句列表 with Tran('tbkt_pxb') as sqls:
  print 'enter'
  return self.sql  # sql.append('select 1')
 def exit(self, exc_type, exc_val, exc_tb):
  print 'exit'
  try:
   print self.sql        # 执行sql
   for s in self.sql:
    self.cur.execute(s)
   self.conn.commit()
  except:            # 可以捕获所有异常(django事务如果中间出现程序异常终止无法回滚)
   try:     # 回滚本身也是sql执行，也有可能失败
    import traceback
    traceback.print_exc()
    print 'rollback'
    self.conn.rollback()
   except:
    print u'回滚失败'
  finally:
   self.cur.close()
   self.conn.close()

세분화된 롤백:

# 在事务块中@atomic() 或者 with atomic():
sid = transaction.savepoint('tbkt_pxb')
try:
 # do ..........
except:
 transaction.savepoint_rollback(sid, 'tbkt_pxb')

참고: 경로가 포함된 데이터베이스가 여러 개 있는 경우 경로가 반환하는 것과 동일한 사용법을 지정해야 합니다. math2의

model에 트랜잭션이 필요한 경우에도 마찬가지입니다. new와 default는 동일한 라이브러리이므로 호출 시에는 =ziyuan_new

  ziyuan_app = ['math2', 'ziyuan']
  if model._meta.app_label in ziyuan_app:
   return "ziyuan_new"
  return 'default'

를 사용해야 합니다.

원자 블록 호출 시에는 사용에 주의해야 합니다. 프로그램 오류가 수동으로 포착되면 원자 래퍼는 예외를 포착할 수 없으며 롤백이 발생하지 않습니다. try에 있는 코드가 트랜잭션 작업에 영향을 주지 않거나 예외가 catch되어 발생하여 Atomic이 정상적으로 롤백될 수 있도록 합니다. (저는 이 문제를 인지하지 못했기 때문에 며칠 동안 시도했지만 성공하지 못했습니다. 기억하세요)

읽어 주셔서 감사합니다. 이 내용이 모든 사람에게 도움이 되기를 바라며 이 사이트를 지원해 주셔서 감사합니다!

위 내용은 Python Django 트랜잭션 소스 코드 분석 소개의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!