背景:
在开发过程中肯定会遇到一堆数据需要向数据库存储,但是写入前需要验证是否主键重复或联合唯一值是否存在,如果存在则,更新,否则创建的写入要求条件。如果采用sql先查询,再写入或更新的操作比较麻烦,所以我们采用mysql自带的“
on duplicate key update”方法实现。同时,由于是批量存入数据,为了提高我们采用mysqldb的“executemany”方式提交。
on duplicate key update:
在此,我们先看下这个sql语句:
insert into commodity_base (i_id, supplier_id, supplier_name, ) values(%s,%s,%s) on duplicate key update supplier_id=values(supplier_id), supplier_name=values(supplier_name)"
在执行这个sql语句时,会自动判断插入的数据的主键重复或联合唯一值是否存在,如果存在,则会更新“on duplicate key update”后面指定的字段。
mysqlclicent:
import MySQLdb
def create_commodity(sql,datas_list):
# 连接mysql数据库 conn = MySQLdb.connect( host='127.0.0.1', port=3306, user='root', passwd='root', db='test_database',
# 设置编码类型,否则存储中文会报错 charset='utf8' ) cur = conn.cursor() # 打印影响的行数,如果没有发生任何变更,则返回0 print(cur.executemany(sql, datas_list)) cur.close() conn.commit() conn.close() if __name__ == '__main__': datas_list = [(1, '531296', 'txt1',),(1, '53', 'txt2',)]
sql = "insert into commodity_base (i_id, supplier_id, supplier_name, ) values(%s,%s,%s) on duplicate key update supplier_id=values(supplier_id), supplier_name=values(supplier_name)"
create_commodity(sql, datas_list)
print("执行完成")
数据表设置i_id为主键,最终,supplier_id=53, supplier_name="txt2"。