-- 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)
)