#connection import MySQLdb conn = MySQLdb.Connect( host = '127.0.0.1', port = 3306, user = 'root', passwd = '', db = 'innodb', charset = 'utf8' ) cursor = conn.cursor() sql_insert = 'insert into stu (name) values("ddd")' sql_update = "update stu set name='小明dddd' where id=14" sql_delete = 'delete from stu where id=1111' # try: # #cursor.execute(sql_insert) # #print cursor.rowcount # #cursor.execute(sql_update) # #print cursor.rowcount # cursor.execute(sql_delete) # print cursor.rowcount # conn.commit() # except Exception as e: # print e # conn.rollbake() try: cursor.execute(sql_insert) print(cursor.rowcount) cursor.execute(sql_update) print(cursor.rowcount) cursor.execute(sql_delete) print(cursor.rowcount) conn.commit() #以上三条操作作为整体单元事务,提交数据 except Exception as e: print(e) conn.rollback() #事务出现异常回滚数据 cursor.close() conn.close()
HansonQ