#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()
添加回答
举报
0/150
提交
取消