python Django事务
网上关于django1.6的事务资料很多，但是1.8的却搜不到任何资料，自己要用的时候费了不少劲就是不行，现在记下要用的人少走弯路 version：Django 1.8 事务官方文档 事务中文文档 里面介绍很多方法，不一一赘述，按照文档即可，下面只分析下atomic方法的源码 按照官方文档 transaction.atomic 有两种用法装饰器和上下文管理器
# 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')
注意：如果有多个数据库有路由，则需要指定和路由返回一致的useing： math2下的model需要事务，即使ziyuan_new和default是同一个库,也必须使用useing=ziyuan_new
ziyuan_app = ['math2', 'ziyuan'] if model._meta.app_label in ziyuan_app: return "ziyuan_new" return 'default'
调用时候必须.()方法调用
atomic块中必须注意try的使用，如果手动捕获了程序错误会导致atomic包装器捕获不到异常，也就不会回滚。要么try内代码不影响事务操作，要么就捕获异常后raise出，让atomic可以正常回滚(就是因为没有注意到这个问题，导致尝试了好几天都没成功，切记)
感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！
免责声明：本站文章均来自网站采集或用户投稿，网站不提供任何软件下载或自行开发的软件！ 如有用户或公司发现本站内容信息存在侵权行为，请邮件告知！ 858582#qq.com
《魔兽世界》大逃杀！60人新游玩模式《强袭风暴》3月21日上线
暴雪近日发布了《魔兽世界》10.2.6 更新内容，新游玩模式《强袭风暴》即将于3月21 日在亚服上线，届时玩家将前往阿拉希高地展开一场 60 人大逃杀对战。
艾泽拉斯的冒险者已经征服了艾泽拉斯的大地及遥远的彼岸。他们在对抗世界上最致命的敌人时展现出过人的手腕，并且成功阻止终结宇宙等级的威胁。当他们在为即将于《魔兽世界》资料片《地心之战》中来袭的萨拉塔斯势力做战斗准备时，他们还需要在熟悉的阿拉希高地面对一个全新的敌人──那就是彼此。在《巨龙崛起》10.2.6 更新的《强袭风暴》中，玩家将会进入一个全新的海盗主题大逃杀式限时活动，其中包含极高的风险和史诗级的奖励。
《强袭风暴》不是普通的战场，作为一个独立于主游戏之外的活动，玩家可以用大逃杀的风格来体验《魔兽世界》，不分职业、不分装备（除了你在赛局中捡到的），光是技巧和战略的强弱之分就能决定出谁才是能坚持到最后的赢家。本次活动将会开放单人和双人模式，玩家在加入海盗主题的预赛大厅区域前，可以从强袭风暴角色画面新增好友。游玩游戏将可以累计名望轨迹，《巨龙崛起》和《魔兽世界：巫妖王之怒 经典版》的玩家都可以获得奖励。