个人中心
gpt4 book ai didi

Fluent Mybatis 批量更新的使用

转载 作者：qq735679552 更新时间：2022-09-27 22:32:09 26 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章Fluent Mybatis 批量更新的使用由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

批量更新同一张表的数据

更新多条数据,每条数据都不一样

背景描述 。

通常需要一次更新多条数据有两个方式 。

在业务代码中循环遍历，逐条更新 一次性更新所有数据, 采用批量sql方式，一次执行.

更准确的说是一条sql语句来更新所有数据，逐条更新的操作放到数据库端，在业务代码端展现的就是一次性更新所有数据.

这两种方式各有利弊，程序中for循环实现就不说了，这里主要介绍第二种方式在fluent mybatis中的实现，以及和mybatis实现的对比.

java中for循环实现方式

?
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
public class UpdateBatchTest extends BaseTest {
     @Autowired
     private StudentMapper mapper;
 
     @Test
     public void testBatchJavaEach() {
         /** 构造多个更新 **/
         List<IUpdate> updates = this .newListUpdater();
         for (IUpdate update : updates) {
             mapper.updateBy(update);
         }
     }
    
     /**
      * 构造多个更新操作
      */
     private List<IUpdate> newListUpdater() {
         StudentUpdate update1 = new StudentUpdate()
             .update.userName().is( "user name23" ).end()
             .where.id().eq(23L).end();
         StudentUpdate update2 = new StudentUpdate()
             .update.userName().is( "user name24" ).end()
             .where.id().eq(24L).end();
         return Arrays.asList(update1, update2);
     }
}

这种方式在大批量更新时, 最大的问题就是效率，逐条更新，每次都会连接数据库，然后更新，再释放连接资源.

一条SQL，服务端逐条更新

mybatis实现方式

通过mybatis提供的循环标签，一次构造多条update的sql，一次提交服务器进行执行.

?
1
2
3
4
5
6
7
8
9
10
11
< update id = "updateStudentBatch"  parameterType = "java.util.List" > 
     < update id = "updateStudentBatch"  parameterType = "java.util.List" >
         < foreach collection = "list" item = "item" index = "index" open = "" close = "" separator = ";" >
             update student
             < set >
                 user_name=#{item.userName}
             </ set >
             where id = #{item.id}
         </ foreach >
     </ update >  
</ update >

定义Mapper 。

?
1
2
3
public interface StudentBatchMapper {
     void updateStudentBatch(List list);
}

执行测试验证 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
public class UpdateBatchTest extends BaseTest {
     @Autowired
     private StudentBatchMapper batchMapper;
 
     @Test
     public void updateStudentBatch() {
         List<StudentEntity> students = Arrays.asList(
             new StudentEntity().setId(23L).setUserName( "user name23" ),
             new StudentEntity().setId(24L).setUserName( "user name24" ));
         batchMapper.updateStudentBatch(students);
         /** 验证SQL参数 **/
         db.table(ATM.table.student).query().eqDataMap(ATM.dataMap.student.table( 2 )
             .id.values(23L, 24L)
             .userName.values( "user name23" , "user name24" )
         );
     }
}

使用FluentMybatis实现方式

使用fluent mybatis进行批量更新很简单，只需要在#updateBy方法中传入 IUpdate数组即可 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
public class UpdateBatchTest extends BaseTest {
     @Autowired
     private StudentMapper mapper;
 
     @DisplayName ( "批量更新同一张表" )
     @Test
     public void testUpdateBatch_same() {
         IUpdate[] updates = this .newListUpdater().toArray( new IUpdate[ 0 ]);
         mapper.updateBy(updates);
         /** 验证SQL语句 **/
         db.sqlList().wantFirstSql().eq( "" +
                 "UPDATE student SET gmt_modified = now(), user_name = ? WHERE id = ?; " +
                 "UPDATE student SET gmt_modified = now(), user_name = ? WHERE id = ?"
             , StringMode.SameAsSpace);
         /** 验证SQL参数 **/
         db.table(ATM.table.student).query().eqDataMap(ATM.dataMap.student.table( 2 )
             .id.values(23L, 24L)
             .userName.values( "user name23" , "user name24" )
         );
     }
}

要实现批量更新，首先得设置mysql支持批量操作，在jdbc url链接中附加&allowMultiQueries=true属性 。

例如:

?
1
jdbc:mysql://localhost:3306/testdb?characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true

使用mysql的Case When then方式更新

?
1
2
3
4
UPDATE student
SET gmt_modified = now(),
address = case id when 1 then 'address 1' when 2 then 'address 2' when 3 then 'address 3' end
WHERE id in (1, 2, 3)

上面的sql语句使用mysql的case when then语法实现的批量更新3条记录，并且根据id的值不同，设置不同的address值.

mybatis原生实现方式

如果使用mybatis的xml语法来实现，xml文件就需要表达为下面方式

xml文件 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
< update id = "updateBatchByIds" parameterType = "list" >
     update student
     < trim prefix = "set" suffixOverrides = "," >
         < trim prefix = "address =case id" suffix = "end," >
             < foreach collection = "list" item = "item" index = "index" >
                 < if test = "item.id!=null" >
                     when #{item.id} then #{item.address}
                 </ if >
             </ foreach >
         </ trim >
     </ trim >
     < trim prefix = "age =case id" suffix = "end," >
         < foreach collection = "list" item = "item" index = "index" >
             < if test = "item.id!=null" >
                 when #{item.id} then #{item.age}
             </ if >
         </ foreach >
     </ trim >
     where id in
     < foreach collection = "list" item = "item" index = "index" separator = "," open = "(" close = ")" >
         #{item.id}
     </ foreach >
</ update >

定义Mapper 。

?
1
2
3
public interface StudentBatchMapper {
     int updateBatchByIds(List<StudentEntity> list);
}

验证 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
public class CaseFuncTest extends BaseTest {
     @Autowired
     private StudentBatchMapper batchMapper;
 
     @Test
     public void test_mybatis_batch() {
         batchMapper.updateBatchByIds(Arrays.asList(
             new StudentEntity().setId(1L).setAddress( "address 1" ).setAge( 23 ),
             new StudentEntity().setId(2L).setAddress( "address 2" ).setAge( 24 ),
             new StudentEntity().setId(3L).setAddress( "address 3" ).setAge( 25 )
         ));
         /** 验证执行的SQL语句 **/
         db.sqlList().wantFirstSql().eq( "" +
                 "update student " +
                 "set address =case id when ? then ? when ? then ? when ? then ? end, " +
                 "age =case id when ? then ? when ? then ? when ? then ? end " +
                 "where id in ( ? , ? , ? )"
             , StringMode.SameAsSpace);
     }
}

使用Fluent Mybatis实现方式 。

?
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
public class CaseFuncTest extends BaseTest {
     @Autowired
     private StudentMapper mapper;
 
     @Test
     public void test_fluentMybatisBatch() throws Exception {
         final String CaseWhen = "case id " +
             "when 1 then ? " +
             "when 2 then ? " +
             "else ? end" ;
         StudentUpdate update = new StudentUpdate()
             .update.address().applyFunc(CaseWhen, "address 1" , "address 2" , "address 3" )
             .set.age().applyFunc(CaseWhen, 23 , 24 , 25 )
             .end()
             .where.id().in( new int []{ 1 , 2 , 3 }).end();
         mapper.updateBy(update);
         /** 验证执行的SQL语句 **/
         db.sqlList().wantFirstSql()
             .eq( "UPDATE student " +
                     "SET gmt_modified = now(), " +
                     "address = case id when 1 then ? when 2 then ? else ? end, " +
                     "age = case id when 1 then ? when 2 then ? else ? end " +
                     "WHERE id IN (?, ?, ?)" ,
                 StringMode.SameAsSpace);
     }
}

只需要在applyFunc中传入case when语句，和对应的参数（对应case when语句中的预编译占位符'?') 。

如果业务入口传入的是Entity List或者Map List，可以使用java8的stream功能处理成数组，示例如下:

?
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
31
32
33
34
35
36
37
public class CaseFuncTest extends BaseTest {
     @Autowired
     private StudentMapper mapper;
 
     @Test
     public void test_fluentMybatisBatch2() throws Exception {
         List<StudentEntity> students = Arrays.asList(
             new StudentEntity().setId(1L).setAddress( "address 1" ).setAge( 23 ),
             new StudentEntity().setId(2L).setAddress( "address 2" ).setAge( 24 ),
             new StudentEntity().setId(3L).setAddress( "address 3" ).setAge( 25 ));
         final String CaseWhen = "case id " +
             "when 1 then ? " +
             "when 2 then ? " +
             "else ? end" ;
         StudentUpdate update = new StudentUpdate()
             .update.address().applyFunc(CaseWhen, getFields(students, StudentEntity::getAddress))
             .set.age().applyFunc(CaseWhen, getFields(students, StudentEntity::getAge))
             .end()
             .where.id().in(getFields(students, StudentEntity::getId)).end();
         mapper.updateBy(update);
         // 验证SQL语句
         db.sqlList().wantFirstSql()
             .eq( "UPDATE student " +
                     "SET gmt_modified = now(), " +
                     "address = case id when 1 then ? when 2 then ? else ? end, " +
                     "age = case id when 1 then ? when 2 then ? else ? end " +
                     "WHERE id IN (?, ?, ?)" ,
                 StringMode.SameAsSpace);
         // 验证参数
         db.sqlList().wantFirstPara()
             .eqReflect( new Object[]{ "address 1" , "address 2" , "address 3" , 23 , 24 , 25 , 1L, 2L, 3L});
     }
 
     private Object[] getFields(List<StudentEntity> students, Function<StudentEntity, Object> getField) {
         return students.stream().map(getField).toArray(Object[]:: new );
     }
}

使用Fluent Mybatis无需额外编写xml文件和mapper（使用框架生成的Mapper文件就够了）。在业务逻辑上不至于因为有额外的xml文件，而产生割裂感.

批量更新不同的表数据

上面的例子使用mybatis和fluent mybatis演示的如果通过不同方法批量更新同一张表的数据，在fluent mybatis的更新其实不限定于同一张表， 。

在#updateBy(IUpdate... updates)函数可以传入任意表更新. 。

?
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
31
32
public class UpdateBatchTest extends BaseTest {
     @Autowired
     private StudentMapper mapper;
 
     @DisplayName ( "批量更新不同表" )
     @Test
     public void testUpdateBatch_different() {
         StudentUpdate update1 = new StudentUpdate()
             .update.userName().is( "user name23" ).end()
             .where.id().eq(23L).end();
         HomeAddressUpdate update2 = new HomeAddressUpdate()
             .update.address().is( "address 24" ).end()
             .where.id().eq(24L).end();
        
         /** 执行不同表的批量更新 **/
         mapper.updateBy(update1, update2);
    
         /** 验证实际执行的预编译SQL语句**/
         db.sqlList().wantFirstSql().eq( "" +
                 "UPDATE student SET gmt_modified = now(), user_name = ? WHERE id = ?; " +
                 "UPDATE home_address SET gmt_modified = now(), address = ? WHERE id = ?" , StringMode.SameAsSpace);
         db.table(ATM.table.student).query().eqDataMap(ATM.dataMap.student.table( 2 )
             .id.values(23L, 24L)
             .userName.values( "user name23" , "user" )
         );
         /** 验证实际执行预编译SQL入参值 **/
         db.table(ATM.table.homeAddress).query().eqDataMap(ATM.dataMap.homeAddress.table( 2 )
             .id.values( 23 , 24 )
             .address.values( "address" , "address 24" )
         );
     }
}

示例更新了2张表: student 和 home_address 。

参考

Fluent MyBatis地址 Fluent MyBatis文档 。

到此这篇关于Fluent Mybatis 批量更新的使用的文章就介绍到这了,更多相关Fluent Mybatis 批量更新内容请搜索我以前的文章或继续浏览下面的相关文章希望大家以后多多支持我！ 。

原文链接：https://juejin.cn/post/6923914096467410958 。

最后此篇关于Fluent Mybatis 批量更新的使用的文章就讲到这里了,如果你想了解更多关于Fluent Mybatis 批量更新的使用的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

26 4 0
文章推荐： 你真的理解Java中的ArrayList吗
文章推荐： vps云主机的基础认识
文章推荐： 一篇文章带你入门Java多线程(详细)
文章推荐： 一文带你回顾Java中的垃圾回收机制
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
全站热门文章
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com