mysql中insert并发问题(on DUPLICATE KEY UPDATE)

 更新时间:2023年01月09日 10:59:39   作者:方才兄  
本文主要介绍了mysql中insert并发问题(on DUPLICATE KEY UPDATE),文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

小编最近在项目中,遇到了一个问题,因为并发insert造成了脏数据,主要场景是:

  • 根据查询数据库的结果:存在,则进行更新;不存在,则进行新增;
  • 还有一个场景需求:若已存在,则仅查询;不存在,则进行新增;

百度发现,mysql已经为我们提供了相应的sql语句去实现这些场景。

一、insert,存在则更新,不存在则新增

语法:on DUPLICATE KEY UPDATE

1、表结构如下:

CREATE TABLE `testMfc` (                                   
           `id` int(11) NOT NULL AUTO_INCREMENT,                    
           `age` int(11) DEFAULT NULL,                              
           `name` varchar(20) DEFAULT NULL,                         
           `num` int(11) DEFAULT NULL,                              
           PRIMARY KEY (`id`),                                      
           UNIQUE KEY `uk_01` (`age`,`name`)                        
         ) ENGINE=InnoDB AUTO_INCREMENT=12 DEFAULT CHARSET=utf8mb4  

注意:想要使用该语法,必须利用“唯一索引”或者“主键索引”,只有产生“索引冲突”,该语法才能正常生效。

此处建立唯一索引:age列和name列

插入初始数据:

insert into testMfc values (null, 1,'1',30),(null,2,'2',40)

2、sql语句 

已存在,则更新:(影响行数为:2,如果使用mybatis,返回值 int =2,同时该语句可返回当前 主键)

 insert into testMfc values (null, 1,'1',30) on duplicate key update num = 1;

 不存在,则新增:(影响行数为:1,如果使用mybatis,返回值 int =1,同时该语句可返回当前 主键)

insert into testMfc values (null, 3,'3',50) on duplicate key update num = 1;

 

3、批量插入,某一条记录存在,则更新;其余进行新增

insert into testMfc values 
(null, 3,'3',300), 
(null, 4,'4',400),
(null, 5,'5',500),
(null, 2,'2',200)
on duplicate key update num = values(num);

更新:age = 2 和 age =3 的num属性,新增age = 4 和 5 的数据

注意: num = values(num) ,此处的格式,必须是 values(列名),才能更新到对应的行。

mybatis语法:(与该表无关,则用作语法参考)

@Insert({
        "<script>",
        "insert into weekly_item (weekly_id, weekly_task_name," +
                "task_id, plan, project_id,duty_user_key, status, copy_status," +
                "create_at, update_at, comment_id,complete)" +
                "<foreach collection='insertList' item='item' open='values '  separator=','> " +
                "(#{item.weeklyId,jdbcType=INTEGER}," +
                "#{item.weeklyTaskName,jdbcType=VARCHAR}," +
                "#{item.taskId,jdbcType=INTEGER}," +
                "#{item.plan,jdbcType=VARCHAR}," +
                "#{item.projectId,jdbcType=INTEGER}," +
                "#{item.dutyUserKey,jdbcType=VARCHAR}," +
                "#{item.status,jdbcType=TINYINT}," +
                "#{item.copyStatus,jdbcType=TINYINT}," +
                "now()," +
                "now()," +
                "#{item.commentId,jdbcType=INTEGER}," +
                "#{item.complete,jdbcType=VARCHAR})" +
                "</foreach>"+
                "ON DUPLICATE KEY UPDATE " +
                "complete = VALUES(complete)",
        "</script>"
})
void insertBatchOrUpdate(@Param("insertList") List<WeeklyItem> copyItemList);

二、insert,存在则不进行任何操作;不存在则新增

语法:insert ignore into 表名

1、sql语句

注意:

  • 已存在:(影响行数为:0,如果使用mybatis,返回值 int =0,该语句不能 返回当前 主键)
  • 不存在则新增:(影响行数为:1,如果使用mybatis,返回值 int =1,该语句 可以 返回当前 主键)
 insert ignore into testMfc values (null,1,'1',123);

三、总结

mysql还提供了其他原子性操作,比如说:insert,若已存在,则先删除再新增,个人觉得可以使用存在则更新操作代替,所以此处就不做介绍,希望对你们有用。

备注: 网上有人提问,on DUPLICATE KEY UPDATE 在mysql客户端可以正常使用,但是在mybatis就没有效果,既不更新也不新增,同时语句还不报错。小编刚也遇到了“类似情况”,后来发现是参数传错了,粗心了呀。还有一个是sql语句insert的时候,将id也赋值了,这个时候就是主键冲突了。可能不是我们想要的自定义“唯一索引”

 到此这篇关于mysql中insert并发问题(on DUPLICATE KEY UPDATE)的文章就介绍到这了,更多相关mysql insert并发内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Navicat如何远程连接云服务器数据库

    Navicat如何远程连接云服务器数据库

    这篇文章主要介绍了Navicat如何远程连接云服务器数据库,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-11-11
  • MySql实现跨表查询的方法详解

    MySql实现跨表查询的方法详解

    本篇文章是对MySql实现跨表查询的方法进行了详细的分析介绍,需要的朋友参考下
    2013-06-06
  • MySQL之存储引擎使用及说明

    MySQL之存储引擎使用及说明

    这篇文章主要介绍了MySQL之存储引擎使用及说明,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2023-02-02
  • mysql Innodb表空间卸载、迁移、装载的使用方法

    mysql Innodb表空间卸载、迁移、装载的使用方法

    从MySQL的Innodb特性中我们知道,Inndob的表空间有共享和独享的特点,如果是共享的。则默认会把表空间存放在一个文件中(ibdata1),当开启独享表空间参数Innodb_file_per_table时,会为每个Innodb表创建一个.ibd的文件。文章讨论在独享表空间卸载、装载、迁移Innodb表的情况
    2013-11-11
  • Linux下修改MySQL编码的方法

    Linux下修改MySQL编码的方法

    有时候因为编码需要修改mysql的编码,windows下修改有图文界面简单一些,linux大家就可以参考下面的方法
    2012-04-04
  • SQL语句中SUM与COUNT的区别深入分析

    SQL语句中SUM与COUNT的区别深入分析

    本篇文章是对SQL语句中SUM与COUNT的区别进行了详细的分析介绍,需要的朋友参考下
    2013-06-06
  • Windows11下MySQL 8.0.29 安装配置方法图文教程

    Windows11下MySQL 8.0.29 安装配置方法图文教程

    这篇文章主要为大家详细介绍了Windows11下MySQL 8.0.29 安装配置方法图文教程,文中安装步骤介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2022-07-07
  • MYSQL中SWITCH语句和循环语句举例详解

    MYSQL中SWITCH语句和循环语句举例详解

    MySQL提供了多种循环语句来实现循环操作,其中包括while循环、loop循环、repeat循环和非标准的goto循环,下面这篇文章主要给大家介绍了关于MYSQL中SWITCH语句和循环语句的相关资料,需要的朋友可以参考下
    2024-06-06
  • 解决修改mysql的data_dir所引发的错误问题

    解决修改mysql的data_dir所引发的错误问题

    本文给大家分享解决修改mysql的data_dir所引发的错误问题,非常不错具有参考借鉴价值,需要的朋友参考下吧
    2017-04-04
  • mysql 8.0.15 winx64安装配置方法图文教程

    mysql 8.0.15 winx64安装配置方法图文教程

    这篇文章主要为大家详细介绍了mysql 8.0.15 安装配置方法图文教程,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2019-03-03

最新评论