方式一:
1
2
3
4
5
6
7
8
9
10
|
<update id= "updatebatch" parametertype= "java.util.list" > <foreach collection= "list" item= "item" index= "index" open= "" close= "" separator= ";" > update tablename <set> name=${item.name}, name2=${item.name2} </set> where id = ${item.id} </foreach> </update> |
但mybatis映射文件中的sql语句默认是不支持以" ; " 结尾的,也就是不支持多条sql语句的执行。所以需要在连接mysql的url上加 &allowmultiqueries=true 这个才可以执行。
方式二:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
|
<update id= "updatebatch" parametertype= "java.util.list" > update tablename <trim prefix= "set" suffixoverrides= "," > <trim prefix= "c_name =case" suffix= "end," > <foreach collection= "list" item= "cus" > < if test= "cus.name!=null" > when id=#{cus.id} then #{cus.name} </ if > </foreach> </trim> <trim prefix= "c_age =case" suffix= "end," > <foreach collection= "list" item= "cus" > < if test= "cus.age!=null" > when id=#{cus.id} then #{cus.age} </ if > </foreach> </trim> </trim> <where> <foreach collection= "list" separator= "or" item= "cus" > id = #{cus.id} </foreach> </where> </update> |
这种方式貌似效率不高,但是可以实现,而且不用改动mysql连接
效率参考文章:http://www.zzvips.com/article/176279.html
方式三:
临时改表sqlsessionfactory的属性,实现批量提交的java,但无法返回受影响数量。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
public int updatebatch(list<object> list){ if (list == null || list.size() <= 0 ){ return - 1 ; } sqlsessionfactory sqlsessionfactory = springcontextutil.getbean( "sqlsessionfactory" ); sqlsession sqlsession = null ; try { sqlsession = sqlsessionfactory.opensession(executortype.batch, false ); mapper mapper = sqlsession.getmapper(mapper. class ); int batchcount = 1000 ; //提交数量,到达这个数量就提交 for ( int index = 0 ; index < list.size(); index++) { object obj = list.get(index); mapper.updateinfo(obj); if (index != 0 && index%batchcount == 0 ){ sqlsession.commit(); } } sqlsession.commit(); return 0 ; } catch (exception e){ sqlsession.rollback(); return - 2 ; } finally { if (sqlsession != null ){ sqlsession.close(); } } } |
其中 springcontextutil 是自己定义的工具类 用来获取spring加载的bean对象,其中getbean() 获得的是想要得到的sqlsessionfactory。mapper 是自己的更具业务需求的mapper接口类,object是对象。
总结
- 方式一 需要修改mysql的连接url,让全局支持多sql执行,不太安全
- 方式二 当数据量大的时候 ,效率明显降低
- 方式三 需要自己控制,自己处理,一些隐藏的问题无法发现。
附件:springcontextutil.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
|
@component public class springcontextutil implements applicationcontextaware{ private static applicationcontext applicationcontext; @override public void setapplicationcontext(applicationcontext applicationcontext) throws beansexception { springcontextutil.applicationcontext = applicationcontext; } public static applicationcontext getapplicationcontext(){ return applicationcontext; } public static object getbean( class t){ try { return applicationcontext.getbean(t); } catch (beansexception e){ return null ; } } public static object getbean(string name){ try { return applicationcontext.getbean(name); } catch (beansexception e){ return null ; } } } |
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持服务器之家。
原文链接:https://segmentfault.com/a/1190000018084851