文档章节

python django事务transaction源码分析

张豪飞
 张豪飞
发布于 2016/07/26 16:49
字数 724
阅读 291
收藏 2

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可以正常回滚(就是因为没有注意到这个问题,导致尝试了好几天都没成功,切记)

© 著作权归作者所有

张豪飞
粉丝 30
博文 42
码字总数 21538
作品 0
郑州
程序员
私信 提问
一个 Pythoner的 Awesome List

从大三接触 Python 到现在几乎已经有两年的接触经验了,除去中间有一年左右接私活写写 Android 和 Lamp 之外,有 Python 实际项目开发经验也算是 9 个多月,也稍微算得上是一个入门级别的 Py...

无与童比
2016/12/10
0
0
【Python Web学习路线】干货整理,不谈虚的,让你短时间高效学好它!

无论是大数据、人工智能还是机器学习,Python都是最热门的首选语言。 学好Python,可以从事Python Web工程师、Python数据分析、人工智能专家等岗位。本期专题,分享的主题是“如何成为一枚优...

Eddie_yang
2018/12/24
0
0
使用 Django 1.6 实现事务交易管理

如果你花费了很多的时间去进行Django数据库事务处理的话,你将会了解到这是让人晕头转向的。 在过去,只是提供了简单的基础文档,要想清楚知道它是怎么使用的,还必须要通过创建和执行Djang...

renwofei423
2014/01/08
4K
1
CentOS 6.4下安装Django

Django是一个基于python的网站开发框架,笔者学过了python的基本知识,对用python进行网站开发颇有兴趣。于是想安装一个在本地研究一下。 笔者本地操作系统是:CentOS 6.4,Linux内核:2.6.3...

临峰不畏
2014/06/08
0
0
python中配置mysql

Traceback (most recent call last): File "E:\python\lib\site-packages\django\utils\autoreload.py", line 225, in wrapper fn(*args, **kwargs) File "E:\python\lib\site-packages\djan......

littleh
2018/04/08
192
0

没有更多内容

加载失败,请刷新页面

加载更多

mac环境编译facets

facets是Google开源的数据可视化工具。首页:https://pair-code.github.io/facets/。 体验:https://colab.research.google.com/github/PAIR-code/facets/blob/master/colab_facets.ipynb#sc......

孟飞阳
28分钟前
2
0
代码保护软件VMProtect用户手册控制面板“项目”部分都有哪些功能?

VMProtect是一种很可靠的工具,可以保护应用程序代码免受分析和破解,但只有在应用程序内保护机制正确构建且没有可能破坏整个保护的严重错误的情况下,才能实现最好的效果。 【下载VMProtect...

mnrssj
33分钟前
1
0
房子在买入两年后出手要涨幅多少才能保证不亏(粗略计算)

7日年化收益率12% 属于高利贷么 首先,将年化转换为日化的1w的日收益 0.12*10000/365 = 3.19 我们看一下余额宝7日年化2.485%1w的日收益 0.02485*10000/365 = 0.68 借贷双方约定年利率 年利率...

小小明童鞋
34分钟前
101
1
rapidjson之原位解析(Insitu parse)

什么是原位解析 一种空间复杂度为O(1)的解析方式。正常解析方式需要将JSON字符串复制到其他缓冲区进行解析,这样将会消耗时间和空间复杂度。而原位解析则在JSON字符串所在的原空间进行操作,...

SibylY
35分钟前
1
0
使用gradle打包

安装包到https://gradle.org/下载 然后 将文件解压到自定文件夹,配置环境变量 新建环境变量 GRADLE_HOME,即 D:\usr\local\gradle-2.4; 修改环境变量 Path,即追加 %GRADLE_HOME%\BIN; 打包...

青峰Jun19er
38分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部