zoukankan      html  css  js  c++  java
  • python中单个和批量增加更新的mysql(没有则插入,有则更新)

    建表语句:

    DROP TABLE IF EXISTS `stock_discover`;
    CREATE TABLE `stock_discover` (
      `code` char(6) NOT NULL,
      `index` int(11) unsigned NOT NULL DEFAULT '0',
      `name` varchar(20) NOT NULL,
      `exchange` varchar(10) NOT NULL DEFAULT '',
      `date` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
      `yesterday` double unsigned NOT NULL,
      PRIMARY KEY (`code`,`index`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8 ROW_FORMAT=DYNAMIC;

    单个添加更新

    如果记录在表中不存在则进行插入,如果存在则进行更新:

    sql = "INSERT INTO stock_discover VALUES ('%s', 2, '%s', 'HZ', '%s', '%s')" 
           " ON DUPLICATE KEY UPDATE `date` = '%s' , yesterday = '%s''"
    #数据格式
    data = ['000005', u'合肥', '2018-09-19 14:55:21', u'2520.64']
    sql = sql % (data[0], data[1], data[2], data[3], data[2], data[3])
    
    cursor.execute(sql)

    批量添加更新
    在更新大量数据时可能同时遇到两个问题:
    ① 如果每条更新执行一次sql性能很低,也容易造成阻塞;
    ② 批量更新时又有可能遇到主键重复的问题
    使用 ON DUPLICATE KEY UPDATE 一条sql解决批量更新和主键重复问题(id为主键),使用executemany进行批量插入

    # 记录在表中不存在则进行插入,如果存在则进行更新
    sql = "INSERT INTO `stock_discover` VALUES (%s, %s, %s, %s, %s, %s) " 
              "ON DUPLICATE KEY UPDATE `date` = VALUES(`date`) , yesterday = VALUES(yesterday)"
    
    #数据格式如下:
    data_info = [('000005', 2, u'合肥', 'HZ', '2018-09-19 14:55:21', u'2520.64'),
                 ('000006', 2, u'北京', 'HZ', '2018-09-19 14:55:21', u'2694.92'),
                 ('000007', 2, u'上海', 'HZ', '2018-09-19 14:55:21', u'2745.38')]
    
    #批量插入使用executement
    cursor.executemany(sql, data_info)

    注意: ON DUPLICATE KEY UPDATE是mysql特有的语法,对于其他sql并不一定适用

    也可以使用如下方法:

    Mysql插入数据的SQL语句主要有:

    1、insert into表示插入数据,数据库会检查主键,如果出现重复会报错;

    2、replace into表示插入替换数据,需求表中有PrimaryKey,或者unique索引,如果数据库已经存在数据,则用新数据替换,如果没有数据效果则和insert into一样;

    3、insert ignore表示,如果表中如果已经存在相同的记录,则忽略当前新数据;

    create table testtb(  
    id int not null primary key,  
    name varchar(50),  
    age int 
    );  
    insert into testtb(id,name,age)values(1,'bb',13);  
    select * from testtb;  
    insert ignore into testtb(id,name,age)values(1,'aa',13);  
    select * from testtb;  
    replace into testtb(id,name,age)values(1,"aa",12);  
    select * from testtb;
  • 相关阅读:
    EMQ X v4.3 正式发布:性能大幅提升,更好用的多语言扩展
    全新 EMQ X Cloud 物联网云平台重磅发布
    MQTT 和 CoAP 在 EMQ X 世界的一次「约会」
    Python MQTT 异步框架 —— HBMQTT
    EMQ X 团队:连接数亿关键 IoT 设备|EMQ 2021 全球招聘季
    让每一个来自社区的声音被听见、有回响:EMQ X 开源项目正式采用 RFC 流程
    Kuiper 1.1.2 正式发布
    Xamarin.Forms iOS打包上传AppStore,奇妙的崩溃 EXC_CRASH (SIGABRT)
    大数据系列修炼-Scala课程01
    文本摘要简述
  • 原文地址:https://www.cnblogs.com/skgoo/p/10821110.html
Copyright © 2011-2022 走看看