《Mysql实例并发环境下mysql插入检查方案》要点：
本文介绍了Mysql实例并发环境下mysql插入检查方案，希望对您有用。如果有疑问，可以联系我们。
业务背景：
基本业务场景是这样的,哀求数据(车辆vin信息)进入到接口中,需要先判断其在数据库中的状态,如果库中不存在该vin,或者该vin状态位为“1(已完成)”,则执行一些检查操作后,将数据插入到数据库中,此时新增vin状态为0,调用人工处理接口,十分钟后返回结果,将状态置为1.如果其状态位为“0(正在处理)”则驳回操作,返回提示信息.
在单线程环境下,这样的业务没有问题,然而当并发访问接口时,会出现同时进入两条vin相同的哀求AB,正常情况应该插入一条A,驳回一条B.然而并发环境下,B执行检查状态时A还没有插入,因此AB都进入到了数据库中,数据就错误了.MYSQL学习
办理方案一：
首先想到的是使用sql处理,对数据库对应字段加唯一索引,保证一致性.如果插入重复的数据,则catch该异常,做出提示.MYSQL学习
ALTER tableName ADD UNIQUE [indexName] ON (tableColumns(length))
但是由于业务限制,vin在库中是可以重复的,多条重复数据查询最新,所以不能再vin上添加唯一索引.MYSQL学习
办理方案二：
使用mysql事务操作,将检查是否存在和插入作为一个事务进行处理,当检查失败的时候,不进行插入.从网上搜索了一下,大致思路如下：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操作,可以用于同时插入两条数据一致性的情况,但并不适合需求.MYSQL学习
既然sql层面没有解决问题,就考虑从java的并发编程方向解决.
解决方案三：
java解决并发问题,首先想到的是使用内置锁或者可重入锁,基本语法如下：
・内置锁：
由于是在Servlet中进行的处理,因此使用synchronized(this)直接处理业务代码,使得并发情况下,只能有一个线程拜访到该段业务代码：MYSQL学习
synchronized(this){
//todo1:检查vin是否存在
//todo2:如果不存在插入vin
}
・可重入锁：
相当于更灵活的内置锁,在这里与内置锁基本相同MYSQL学习
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();
}
}
}
经过测试,这个方案是可行的,最终没有采用的原因是因为直接使用这种方式加锁,加锁的代码太多,影响效率.MYSQL学习
办理方案四：
设置一个查询Map,插入前存储数据,插入后删除数据,代码如下：MYSQL学习
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学习
维易PHP培训学院每天发布《Mysql实例并发环境下mysql插入检查方案》等实战技能，PHP、MYSQL、LINUX、APP、JS,CSS全面培养人才。
