zoukankan      html  css  js  c++  java
  • mysqlclicent批量更新或创建数据(mysql)

    背景:

      在开发过程中肯定会遇到一堆数据需要向数据库存储,但是写入前需要验证是否主键重复或联合唯一值是否存在,如果存在则,更新,否则创建的写入要求条件。如果采用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"。

  • 相关阅读:
    hadoop yarn
    java 删除文件夹及其里面的文件
    scrapy 429 处理
    java 获取当前时间(年月日时分秒)
    Java测试类
    eclipse环境问题-java版本不兼容
    Java内功修炼系列一工厂模式
    Java内功修炼系列一观察者模式
    Java内功修炼系列一责任链模式
    Java内功修炼系列一拦截器
  • 原文地址:https://www.cnblogs.com/xshan/p/12841973.html
Copyright © 2011-2022 走看看