mybatis 批量更新(batchUpdate)分析

无情 阅读:245 2021-03-31 21:33:37 评论:0

第一:修改数据库的连接方式 &&allowMultiQueries=true

比如:jdbc\:mysql\://rdshme0env6yf2n829ympublic.mysql.rds.aliyuncs.com/wlsq_dev_test?useUnicode\=true&characterEncoding\=utf8&allowMultiQueries=true


mybatis 配置文件:

   <!--批量修改密码  --> 
   <update id="updateBatch" parameterType="java.util.List">     
          <foreach collection="list" item="item" index="index" open="" close="" separator=";"> 
				update account set `password` = #{item.password} where acct_id = #{item.acctId}				 
	       </foreach> 
   </update>  


dao 层

  public void updateBatch(List<Account> list);

service 层

  public void updateBatch(List<Account> list);

service 实现层

	public void updateBatch(List<Account> list) { 
		// TODO Auto-generated method stub 
		this.accountMapper.updateBatch(list); 
	}

controller 层

 @RequestMapping({"/batchupdate"}) 
  @ResponseBody 
  public String batchUpdate(){ 
	  String result = ""; 
	  try{ 
	  List<Account> list = accountService.batchUpdate(); 
	  List<Account> batch = new ArrayList<Account>(); 
	   
	  
	  //密码修改 
	  if(list !=null && list.size()>0){ 
		  for(int i=0;i<list.size();i++){ 
			  Account account =list.get(i); 
			  String oldpassword = account.getPassword(); 
			  account.setPassword(EncryptUtils.encodeBase64String(oldpassword)); 
			  batch.add(account); 
		  } 
	  } 
	  //一次处理数据量 
	  int  init = 1000;// 每隔1000条循环一次  =1000; 
	  //总数 
	  int nums = batch.size(); 
	  //批次数 
	  int batchnum = nums / init;   
	  if (nums % init != 0) {   
		  batchnum += 1;   
          if (nums < init) {   
              init = list.size();   
          }   
      }  
	   
	   for (int i = 0; i < batchnum; i++) {   
           System.out.println("------" + i + "保存"+init+"条数据到数据库....");   
           List<Account> a = new ArrayList<Account>(); 
           if (i == batchnum - 1) {   
               int size = (i + 1) * init;   
               for (int j = size - init; j < nums; j++) {   
            	   if (batch.get(j) == null) {   
                       break;   
                   }  
            	   a.add(batch.get(j));   
               }   
               
           } else {   
               int size = (i + 1) * init;   
               for (int j = size - init; j < size; j++) {  
            	   if (batch.get(j) == null) {   
                       break;   
                   }   
            	   a.add(batch.get(j));   
               }   
              
           }   
           accountService.updateBatch(a); 
           
       }   
	   
	  
	 
	   
	  }catch(Exception e){ 
		  System.out.println(e.getMessage()); 
		  return "false"; 
	  } 
	  result = "true"; 
	  return result; 
	   
  }

结果展示:


声明

1.本站遵循行业规范,任何转载的稿件都会明确标注作者和来源;2.本站的原创文章,请转载时务必注明文章作者和来源,不尊重原创的行为我们将追究责任;3.作者投稿可能会经我们编辑修改或补充。

发表评论
搜索
KIKK导航

KIKK导航

排行榜
关注我们

一个IT知识分享的公众号