mybatis批量更新数据两种方法效率对比

纯粹的果子

2018-06-22

关注关注

实现方式有两种，

一种用for循环通过循环传过来的参数集合，循环出N条sql，

另一种用mysql的case when 条件判断变相的进行批量更新

下面进行实现。

注意第一种方法要想成功，需要在db链接url后面带一个参数 &allowMultiQueries=true

即： jdbc:mysql://localhost:3306/mysqlTest?characterEncoding=utf-8&allowMultiQueries=true

其实这种东西写过来写过去就是差不多一样的代码，不做重复的赘述，直接上代码。

List<Customer> findByName(String name);  
  
int batchUpdate(Map<String,Object> param);  
  
int batchUpdateCaseWhen(Map<String,Object> param);

实现类

/** 
 * 用于更新时，获取更新数据 
 * @param name 
 * @return 
 */  
public List<Customer> findByName(String name) {  
    SqlSession sqlSession = null;  
    try {  
        sqlSession = SqlsessionUtil.getSqlSession();  
        return sqlSession.selectList("customer.findByName", name);  
    } catch (Exception e) {  
        e.printStackTrace();  
    } finally {  
        SqlsessionUtil.closeSession(sqlSession);  
    }  
    return new ArrayList<Customer>();  
}  
  
  
/** 
 * 批量更新第一种方式 
 * @param param 
 * @return 
 */  
public int batchUpdate(Map<String,Object> param) {  
    return bathUpdate("customer.batchUpdate",param);  
}  
  
/** 
 * 批量更新第二种方式 
 * @param param 
 * @return 
 */  
public int batchUpdateCaseWhen(Map<String,Object> param) {  
    return bathUpdate("customer.batchUpdateCaseWhen",param);  
}  
  
/** 
 * 公共部分提出 
 * @param statementId 
 * @param param 
 * @return 
 */  
private int bathUpdate(String statementId,Map param){  
    SqlSession sqlSession = null;  
    try {  
        sqlSession = SqlsessionUtil.getSqlSession();  
        int key =  sqlSession.update(statementId, param);  
        // commit  
        sqlSession.commit();  
        return key;  
    } catch (Exception e) {  
        sqlSession.rollback();  
        e.printStackTrace();  
    } finally {  
        SqlsessionUtil.closeSession(sqlSession);  
    }  
    return 0;  
}

测试前准备首先用上节的 mybatis学习之路----批量更新数据批量插入，插入10000条数据以备下面的批量更新用。

@Test  
public void batchInsert() throws Exception {  
    Map<String,Object> param = new HashMap<String,Object>();  
    List<Customer> list = new ArrayList<Customer>();  
    for(int i=0;i<10000;i++){  
        Customer customer = new Customer();  
        customer.setName("准备数据" + i);  
        customer.setAge(15);  
        customer.setCeroNo("111111111111"+i);  
        customer.setCeroType(2);  
        customer.setSex(1);  
        list.add(customer);  
    }  
    param.put("list",list);  
    Long start = System.currentTimeMillis();  
    int result = customerDao.batchInsert(param);  
    System.out.println("耗时 ： "+(System.currentTimeMillis() - start));  
}

开始进行测试效率问题。

首先进行的是测试十条数据。调整查询数据为查询十条

@Test  
public void batchudpate() throws Exception {  
    Map<String,Object> param = new HashMap<String,Object>();  
  
    param.put("list",getFindByName("准备数据","批量更新01"));  
    Long start = System.currentTimeMillis();  
    customerDao.batchUpdate(param);  
    System.out.println("耗时 ： "+(System.currentTimeMillis() - start));  
}  
  
@Test  
public void batchudpateCaseWhen() throws Exception {  
    Map<String,Object> param = new HashMap<String,Object>();  
    param.put("list",getFindByName("批量更新01","准备数据"));  
    Long start = System.currentTimeMillis();  
    customerDao.batchUpdateCaseWhen(param);  
    System.out.println("耗时 ： "+(System.currentTimeMillis() - start));  
}  
  
private List<Customer> getFindByName(String name, String change){  
    List<Customer> list = customerDao.findByName(name);  
    System.out.println("查询出来的条数 ： " + list.size());  
    if(null != change && !"".equals(change)){  
        for(Customer customer : list){  
            customer.setName(change);  
        }  
    }  
  
    return list;  
}

第一种拼完整sql的方式耗时：

mybatis批量更新数据两种方法效率对比