脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 数据库 → Mysql → 并发环境下mysql插入检查方案

并发环境下mysql插入检查方案

 更新时间：2016年03月04日 17:06:10   投稿：lijiao  
这篇文章主要介绍了并发环境下mysql插入检查方案的相关资料,需要的朋友可以参考下

业务背景：
基本业务场景是这样的，请求数据（车辆vin信息）进入到接口中，需要先判断其在数据库中的状态，如果库中不存在该vin，或者该vin状态位为“1（已完成）”，则执行一些检查操作后，将数据插入到数据库中，此时新增vin状态为0，调用人工处理接口，十分钟后返回结果，将状态置为1。如果其状态位为“0（正在处理）”则驳回操作，返回提示信息。
在单线程环境下，这样的业务没有问题，然而当并发访问接口时，会出现同时进入两条vin相同的请求AB，正常情况应该插入一条A，驳回一条B。然而并发环境下，B执行检查状态时A还没有插入，因此AB都进入到了数据库中，数据就错误了。

解决方案一：
首先想到的是使用sql处理，对数据库对应字段加唯一索引，保证一致性。如果插入重复的数据，则catch该异常，做出提示。

ALTER tableName ADD UNIQUE [indexName] ON (tableColumns(length))

但是由于业务限制，vin在库中是可以重复的，多条重复数据查询最新，所以不能再vin上添加唯一索引。

解决方案二：
使用mysql事务操作，将检查是否存在和插入作为一个事务进行处理，当检查失败的时候，不进行插入。从网上搜索了一下，大致思路如下：

public static void StartTransaction(Connection con, String[] sqls) throws Exception { 
    try { 
      // 事务开始 
      con.setAutoCommit(false);  // 设置连接不自动提交，即用该连接进行的操作都不更新到数据库 
      sm = con.createStatement(); // 创建Statement对象 

      //依次执行传入的SQL语句 
      for (int i = 0; i < sqls.length; i++) { 
        sm.execute(sqls[i]);// 执行添加事物的语句 
      } 
      con.commit();  // 提交给数据库处理 
      // 事务结束 

    //捕获执行SQL语句组中的异常   
    } catch (SQLException e) { 
      try { 
        System.out.println("事务执行失败，进行回滚！\n"); 
        con.rollback(); // 若前面某条语句出现异常时，进行回滚，取消前面执行的所有操作 
      } catch (SQLException e1) { 
        e1.printStackTrace(); 
      } 
    } finally { 
      sm.close(); 
    } 
  }

但是这样实际上还是没有解决并发的问题，这样只是把两个操作变成了一个原子的sql操作，可以用于同时插入两条数据一致性的情况，但并不适合需求。

既然sql层面没有解决问题，就考虑从java的并发编程方向解决。
解决方案三：
java解决并发问题，首先想到的是使用内置锁或者可重入锁，基本语法如下：
·内置锁：
由于是在Servlet中进行的处理，因此使用synchronized(this)直接处理业务代码，使得并发情况下，只能有一个线程访问到该段业务代码：

synchronized(this){
  //todo1:检查vin是否存在
  //todo2:如果不存在插入vin
}

·可重入锁：
相当于更灵活的内置锁，在这里与内置锁基本相同

public class DashengCallBack extends HttpServlet {
  private static ReentrantLock lock= new ReentrantLock();
  protected void doGet(HttpServletRequest request, HttpServletResponse response){
    lock.lock();
    try{
      //todo1:检查vin是否存在
      //todo2:如果不存在插入vin
    }finally{
      lock.unlock();
    }
  }
}

经过测试，这个方案是可行的，最终没有采用的原因是因为直接使用这种方式加锁，加锁的代码太多，影响效率。

解决方案四：
设置一个查询Map，插入前存储数据，插入后删除数据，代码如下：

    ConcurrentHashMap<String, String> vinMap=new ConcurrentHashMap<String,String>();
    if(vinMap.containsKey(vin)){
      // todo1: vin 请求完毕后, 从vinInRequestMap里删掉这个vinNo
      // todo2: 返回正在查询
    }
    vinMap.put(vin, "");
    //todo3:插入vin到数据库
    vinMap.remove(vin);
  }

这个方案基本满足了业务需求，唯一的问题是要求接口的更新时间要与业务时间错开，否则更新接口会清空vinMap，导致库中数据混乱，出现错误。

以上就是本文的全部内容，希望对大家的学习有所帮助。

您可能感兴趣的文章:

相关文章

  • MySQL系列数据库设计三范式教程示例

    MySQL系列数据库设计三范式教程示例

    这篇文章主要为大家介绍了MySQL系列之数据库设计三范式的教程示例讲解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步
    2021-10-10
  • mysql之关于CST和GMT时区时间转换方式

    mysql之关于CST和GMT时区时间转换方式

    这篇文章主要介绍了mysql之关于CST和GMT时区时间转换方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-10-10
  • phpmyadmin中为站点设置mysql权限的图文方法

    phpmyadmin中为站点设置mysql权限的图文方法

    在一个服务器上一般来讲都不止一个站点，更不止一个MySQL(和PHP搭配之最佳组合)数据库。
    2011-03-03
  • 关于mysql中innodb的count优化问题分享

    关于mysql中innodb的count优化问题分享

    关于mysql中innodb的count优化问题，有需要的朋友可以参考下
    2013-02-02
  • mysql中字符串截取与拆分的实现示例

    mysql中字符串截取与拆分的实现示例

    mysql 字符串截取与拆分在很多地方都可以用得到,本文主要介绍了mysql中字符串截取与拆分的实现示例,具有一定的参考价值,感兴趣的可以了解一下
    2023-12-12
  • 详解mysql表数据压缩

    详解mysql表数据压缩

    mysql进行压缩是借助于zlib库，采用L777压缩算法，这种算法在减少数据大小、CPU利用方面是成熟的、健壮的、高效的，这篇文章主要介绍了mysql表数据压缩,需要的朋友可以参考下
    2022-01-01
  • 详解mysql跨库查询解决方案

    详解mysql跨库查询解决方案

    本文主要介绍了mysql跨库查询解决方案，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2022-08-08
  • 初学者从源码理解MySQL死锁问题

    初学者从源码理解MySQL死锁问题

    这篇文章主要讲的是如何通过调试 MySQL 源码，知道一条 SQL 真正会拿哪些锁，不再抓虾，瞎猜或者何登成大神没写过的场景就不知道如何处理了，下面小编来和大家一起学习学习
    2019-05-05
  • SQL实战演练之网上商城数据库用户信息数据操作

    SQL实战演练之网上商城数据库用户信息数据操作

    一直认为，扎实的SQL功底是一名数据分析师的安身立命之本，甚至可以称得上是所有数据从业者的基本功。当然，这里的SQL绝不单单是写几条查询语句那么简单，接下来请跟着小编通过案例项目进一步提高SQL的能力吧
    2021-10-10
  • Mysql数据库中子查询的使用

    Mysql数据库中子查询的使用

    本文给大家分享mysql数据库中子查询的使用，非常不错具有参考借鉴价值，感兴趣的朋友一起看看吧
    2016-10-10

最新评论