MyBatis 提供了 ExecutorType.BATCH 類型，允許將多個 SQL 語句進行組合，最后統一執行，從而減少數據庫的訪問頻率，提升性能。
以下是如何在 Spring Boot 項目中使用 MyBatis 進行批量操作的關鍵點：
1. 配置 MyBatis 使用 ExecutorType.BATCH
主要有兩種方式可以來配置 MyBatis 使用 BATCH 執行器類型：
a) 在 SqlSessionFactoryBean 中配置 (推薦在 Spring Boot 中使用):
在 Spring Boot 應用中，通常通過 SqlSessionFactoryBean 來配置 SqlSessionFactory。我們可以在 SqlSessionFactoryBean 中設置 defaultExecutorType 屬性為 BATCH。
import org.apache.ibatis.session.ExecutorType;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;import javax.sql.DataSource;@Configuration
public class MyBatisConfig {@Beanpublic SqlSessionFactoryBean sqlSessionFactory(DataSource dataSource) throws Exception {SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();factoryBean.setDataSource(dataSource);// 設置默認的 ExecutorType 為 BATCHorg.apache.ibatis.session.Configuration configuration = new org.apache.ibatis.session.Configuration();configuration.setDefaultExecutorType(ExecutorType.BATCH);factoryBean.setConfiguration(configuration);// ... 其他配置，例如 Mapper 掃描路徑等return factoryBean;}
}
b) 編程式的方式創建 SqlSession 時指定 ExecutorType.BATCH:
如果需要更細粒度的控制，或者只想在特定的操作中使用批量處理，可以在創建 SqlSession 時指定 ExecutorType.BATCH。
import org.apache.ibatis.session.ExecutorType;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;import java.util.List;@Service
public class UserService {@Autowiredprivate SqlSessionFactory sqlSessionFactory;@Autowiredprivate UserMapper userMapper;@Transactionalpublic void batchInsertUsers(List<User> users) {try (SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH)) {UserMapper batchMapper = sqlSession.getMapper(UserMapper.class);for (User user : users) {batchMapper.insertUser(user); // 執行插入操作}sqlSession.flushStatements(); // 刷新批處理語句，執行批量操作sqlSession.commit(); // 提交事務}}
}
2. 在 Mapper XML 文件中編寫批量操作 SQL
在 Mapper XML 文件中，需要編寫能夠處理集合參數的 SQL 語句，通常使用 <foreach> 標簽來循環遍歷集合并構建批量 SQL。
a) 批量 INSERT 示例:
假設有一個 User 實體類，你需要批量插入多個用戶。
<!-- UserMapper.xml -->
<mapper namespace="com.example.mapper.UserMapper"><insert id="batchInsertUsers" parameterType="java.util.List" useGeneratedKeys="true" keyProperty="id">insert into users (username, password, email) values<foreach collection="list" item="item" separator=",">(#{item.username}, #{item.password}, #{item.email})</foreach></insert><insert id="insertUser" parameterType="com.example.entity.User" useGeneratedKeys="true" keyProperty="id">insert into users (username, password, email) values (#{username}, #{password}, #{email})</insert><!-- ... 其他 Mapper 方法 --></mapper>
parameterType="java.util.List": 指定方法參數類型為List。<foreach collection="list" item="item" separator="," >: 循環遍歷傳入的List，item代表當前循環的元素，separator指定元素之間的分隔符為逗號,。(#{item.username}, #{item.password}, #{item.email}): 使用#{item.propertyName}獲取User對象的屬性值。useGeneratedKeys="true" keyProperty="id": 如果需要獲取自增主鍵，需要配置useGeneratedKeys和keyProperty。
b) 批量 UPDATE 示例:
批量更新多個用戶的郵箱地址。
<!-- UserMapper.xml -->
<mapper namespace="com.example.mapper.UserMapper"><update id="batchUpdateUsersEmail" parameterType="java.util.List"><foreach collection="list" item="item" separator=";" open="" close=";" index="index">update users set email = #{item.email} where id = #{item.id}</foreach></update><!-- ... 其他 Mapper 方法 --></mapper>
<foreach collection="list" item="item" separator=";" open="" close=";" index="index">: 循環遍歷List，separator=";"使用分號作為分隔符。注意： 這里使用了分號;分隔多個UPDATE語句。不同的數據庫對批量 UPDATE 的語法支持可能有所不同，有些數據庫可能不支持這種方式，或者有其他更高效的批量更新語法。例如 MySQL 可以使用INSERT ... ON DUPLICATE KEY UPDATE或REPLACE INTO等。
3. Spring Boot Service 層調用批量操作 Mapper 方法
在 Spring Boot Service 層，需要調用 Mapper 接口中定義的批量操作方法，并傳入包含數據的 List。務必使用 @Transactional 注解來管理事務，確保批量操作的原子性。
import com.example.entity.User;
import com.example.mapper.UserMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;import java.util.List;@Service
public class UserService {@Autowiredprivate UserMapper userMapper;@Transactionalpublic void batchInsertUsers(List<User> users) {userMapper.batchInsertUsers(users);}@Transactionalpublic void batchUpdateUsersEmail(List<User> users) {userMapper.batchUpdateUsersEmail(users);}
}
4. 性能優化的關注點
-
事務管理 (
@Transactional): 批量操作必須在事務中進行，以保證操作的原子性。如果批量操作過程中出現錯誤，可以回滾所有操作，保持數據一致性。Spring Boot 的@Transactional注解可以方便地管理事務。 -
批量大小 (Batch Size): 批量操作并非批量越大越好。過大的批量可能會導致：
- 數據庫壓力過大: 單次請求發送大量 SQL 可能導致數據庫服務器資源消耗過高。
- 內存占用過高: 如果批量操作涉及到大量數據，可能會占用大量內存。
- 事務時間過長: 過長的事務會增加鎖沖突的風險，影響并發性能。
最佳批量大小需要根據實際場景進行測試和調優。一般來說，可以嘗試從較小的批量大小開始（例如 100, 500, 1000），逐步增加并監控數據庫性能，找到最佳的平衡點。
-
數據庫連接池配置: 確保數據庫連接池配置合理，能夠支持高并發的批量操作。Spring Boot 默認使用 HikariCP 連接池，性能良好，但仍需根據應用負載調整連接池參數，例如
maximum-pool-size,minimum-idle等。 -
網絡延遲: 批量操作的主要優勢是減少網絡 round trips。如果網絡延遲較高，批量操作的性能提升會更加明顯。
-
數據庫服務器性能: 最終性能也受限于數據庫服務器的性能。確保數據庫服務器配置合理，性能良好，例如 CPU, 內存, 磁盤 IO 等。
-
批量操作的適用場景: 批量操作最適合一次性處理大量數據的場景，例如數據導入、數據遷移、批量更新狀態等。對于頻繁的小批量操作，可能提升效果不明顯，甚至可能因為額外的批處理開銷而降低性能。
-
Generated Keys 的處理: 如果批量 INSERT 需要獲取自增主鍵，MyBatis 提供了
useGeneratedKeys和keyProperty屬性。但需要注意，不同數據庫對批量獲取自增主鍵的支持程度可能有所不同。對于 MySQL，批量 INSERT 可以一次性獲取所有自增主鍵。 -
錯誤處理: 批量操作中如果某條 SQL 執行失敗，需要妥善處理錯誤。默認情況下，MyBatis 的
ExecutorType.BATCH在遇到錯誤時會停止執行后續的 SQL。我們需要根據業務需求，決定是忽略錯誤繼續執行，還是回滾整個批量操作。
總結:
在 Spring Boot 項目中使用 MyBatis 的 ExecutorType.BATCH 進行批量操作，可以顯著提升處理大量數據的性能。關鍵在于正確配置 ExecutorType.BATCH，編寫高效的批量 SQL 語句，合理設置批量大小，并結合事務管理和錯誤處理機制。 性能優化是一個迭代過程，需要根據實際應用場景和性能測試結果進行調整和完善。
)
