zoukankan      html  css  js  c++  java
  • 【mysql】MySQLdb中的事务处理

    MySQL数据库有一个自动提交事务的概念,autocommit。含义是,如果开启autocommit, 则每一个语句执行后会自动提交。即一个语句视为一个事务。

    在python使用的MySQLdb中,默认是不开启autocommit的。所以,只有在显示commit后,数据库操作才会真正提交。或者在rollback()后,回滚到上一次commit的状态。

    例:

    #!/bin/env python
    #coding=utf-8
    
    import MySQLdb
    
    class MYSQL(object):
        def __init__(self):
            self.db = MySQLdb.connect("localhost","root","12345678","TESTTABLE",charset='utf8')
            self.cursor = self.db.cursor()
            
        def test(self):
            try:
                sql = "insert into test_distinct(name, type) values('t3','1')"
                self.cursor.execute(sql)
                sql = "update test_distinct set type='2' where name='t3'"
                #raise   #打开用于测试异常
                self.cursor.execute(sql)
            except:
                self.db.rollback()   #出现异常,不会提交任何数据变化
            else:
                self.db.commit()   #正常处理,提交数据变化(如果没有这一句,也是不会提交任何变化的)
                
    if __name__ == "__main__":
        obj = MYSQL()
        obj.test()

    场景:在两次插入语句直接有一个查询语句

    #!/bin/env python
    #coding=utf-8
    
    import MySQLdb
    
    class MYSQL(object):
        def __init__(self):
            self.db = MySQLdb.connect("localhost","root","12345678","TESTTABLE",charset='utf8')
            self.cursor = self.db.cursor()
            
        def test(self):
            try:
                name = 't5'
                #insert
                sql = "insert into test_distinct(name, type) values('%s','1')" % name
                self.cursor.execute(sql)
                #search
                sql = "select * from test_distinct where name = '%s'" % name   #查询新插入的数据
                self.cursor.execute(sql)
                res = self.cursor.fetchone()
                print res
                #insert
                sql = "update test_distinct set type='2' where name='%s'" % name
                raise   #引起异常
                self.cursor.execute(sql)
            except:
                self.db.rollback()
            else:
                self.db.commit()
                
    if __name__ == "__main__":
        obj = MYSQL()
        obj.test()

    结果:

    可以正确查询到新插入的数据,并且数据成功回滚,没有写入数据。

    结论:虽然没有commit时,数据库不会真正变化,但是会有一个临时变化的版本,供我们查询还未真正加入的数据。

    注意:上面的结果是建立在mysql使用的存储引擎支持事务的基础上的。如果用MyISAM,则即使像上面一样写代码,也会默认一句话就提交一次的,因为MyISAM不支持事务。

  • 相关阅读:
    c# 4.0新功能--隐式类型
    常用的sql语句记录
    算法学习-回文数判断
    算法学习-两数之和
    RSA加密(前端js)和MD5加密(后台)同时使用实例
    layer父页获取弹出层输入框里面的值
    关于checkbox的全选和反选实例
    jQuery实用小技巧-获取选中的的下拉框和返回头部滑动动画
    jQuery实用小技巧--输入框文字获取和失去焦点
    得到网站下的文件虚拟路径的方法
  • 原文地址:https://www.cnblogs.com/dplearning/p/6388059.html
Copyright © 2011-2022 走看看