Fluent Mybatis 批量更新的使用
更新時間：2021年08月05日 10:06:47 作者：稻草江南
本文主要介紹了Fluent Mybatis 批量更新的使用，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
批量更新同一張表的數據
更新多條數據,每條數據都不一樣
背景描述
通常需要一次更新多條數據有兩個方式
在業(yè)務代碼中循環(huán)遍歷，逐條更新
一次性更新所有數據, 采用批量sql方式，一次執(zhí)行。
更準確的說是一條sql語句來更新所有數據，逐條更新的操作放到數據庫端，在業(yè)務代碼端展現的就是一次性更新所有數據。
這兩種方式各有利弊，程序中for循環(huán)實現就不說了，這里主要介紹第二種方式在fluent mybatis中的實現，以及和mybatis實現的對比。
java中for循環(huán)實現方式
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提供的循環(huán)標簽，一次構造多條update的sql，一次提交服務器進行執(zhí)行。
<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
public interface StudentBatchMapper {
void updateStudentBatch(List list);
}
執(zhí)行測試驗證
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數組即可
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屬性
例如：
jdbc:mysql://localhost:3306/testdb?characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true
使用mysql的Case When then方式更新
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文件
<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
public interface StudentBatchMapper {
int updateBatchByIds(List<StudentEntity> list);
}
驗證
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)
));
/** 驗證執(zhí)行的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實現方式
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);
/** 驗證執(zhí)行的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語句中的預編譯占位符'?')
如果業(yè)務入口傳入的是Entity List或者Map List，可以使用java8的stream功能處理成數組，示例如下：
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文件就夠了）。在業(yè)務邏輯上不至于因為有額外的xml文件，而產生割裂感。
批量更新不同的表數據
上面的例子使用mybatis和fluent mybatis演示的如果通過不同方法批量更新同一張表的數據，在fluent mybatis的更新其實不限定于同一張表，
在#updateBy(IUpdate... updates)函數可以傳入任意表更新.
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();
/** 執(zhí)行不同表的批量更新 **/
mapper.updateBy(update1, update2);
/** 驗證實際執(zhí)行的預編譯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")
);
/** 驗證實際執(zhí)行預編譯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 批量更新內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
本文主要介紹了SpringBoot兩種方式接入DeepSeek的實現,包括HttpClient方式和基于spring-ai-openai的方式,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2025-03-03
SpringBoot內置tomcat參數調優(yōu)的實現
springboot內置了tomcat, 并給我們設置了默認參數, 我們怎么樣修改springboot內置的tomcat參數,本文就詳細的來介紹一下,感興趣的可以了解一下2023-09-09
這篇文章主要介紹了lambda表達式內出現異常無法throw拋出的解決，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-09-09
Spring框架中ImportBeanDefinitionRegistrar的應用詳解
這篇文章主要介紹了Spring框架中ImportBeanDefinitionRegistrar的應用詳解,如果實現了ImportSelector接口,在配置類中被@Import加入到Spring容器中以后,Spring容器就會把ImportSelector接口方法返回的字符串數組中的類new出來對象然后放到工廠中去,需要的朋友可以參考下2024-01-01
這篇文章主要介紹了java如何刪除以逗號隔開的字符串中某一個值，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-06-06
這篇文章主要介紹了詳解jvm中的標量替換，幫助大家更好的理解和使用Java虛擬機，感興趣的朋友可以了解下2020-09-09
在Web開發(fā)中,有時我們需要將文件以流的形式返回給前端,下面這篇文章主要給大家介紹了關于Java調用SSE流式接口并流式返回給前端實現打字輸出效果的相關資料,需要的朋友可以參考下2024-08-08
這篇文章主要介紹了Java數據類型的規(guī)則的相關資料,非常不錯，具有參考借鑒價值，需要的朋友可以參考下2016-12-12
這篇文章主要介紹了Springboot消除switch-case過程解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-10-10
我最近在開發(fā)時遇到了文件另存為時文件名出現亂碼，在火狐上正常的文件名，在IE中又出現亂碼問題，然后好不容易在IE下調試好了文件名亂碼問題，在火狐下又出現亂碼，最后終于感覺這樣是能解決了。具體如下：2013-04-04