-- encoding: utf-8 --
'''
db_test.py
Created on 2019/6/25 11:14
Copyright (c) 2019/6/25, 海牛学院版权所有.
@author: 潘牛
'''
from commons.until.db_util  import DBUtil
from configs.config import _HAINIU_DB
db_util = DBUtil(_HAINIU_DB)
设置字符集是utf8mb4
db_util.execute_no_commit("set NAMES utf8mb4;")
插入两次,两次在同一个事务里
import time, traceback
sql = """
insert into hainiu_queue (type,action,params) values (%s, %s, %s);      #一个sql
"""
try:
params = [1, 'www.hainiubl.com', "ff"]                              #执行一次
db_util.execute_no_commit(sql, params)
# 1/0
time.sleep(5)                                                       #执行以后  休眠5秒
params = [1, 'www.hainiubl.com', "gg"]                              # 执行第二次
db_util.execute_no_commit(sql, params)                              #不提交       在同一事物里
time.sleep(5)                                                       #再过5秒
db_util.commit()                                                    # 一共10秒以后 提交
except Exception, e:
db_util.rollback()
traceback.print_exc(e)
finally:
db_util.close()
sql = """
insert into hainiu_queue (type,action,params) values (%s, %s, %s);
"""
params = []
在表中 循环插入的   数量
for i in range(1,11):
params.append((1,'www.hainiubl.com%d' % i, "aa%d" % i))
db_util.executemany(sql, params)