🎉Spring Boot集成MyBatis實現多數據源訪問的“秘密”

---

• ☆* o(≧▽≦)o *☆嗨~我是IT·陳寒🍹
• ?博客主頁：IT·陳寒的博客
• 🎈該系列文章專欄：架構設計
• 📜其他專欄：Java學習路線 Java面試技巧 Java實戰項目 AIGC人工智能 數據結構學習
• 🍹文章作者技術和水平有限，如果文中出現錯誤，希望大家能指正🙏
• 📜 歡迎大家關注！ ??

---

在企業級應用程序中，往往需要處理多個數據庫的數據。Spring Boot提供了強大的功能，使得集成多數據源變得相對容易。本文將揭示Spring Boot集成MyBatis實現對多數據源的訪問的“秘密”，并通過實例代碼來演示整個過程。

為什么需要多數據源？

在實際的應用中，有一些常見的場景需要使用多個數據源：

1. 業務數據和日志數據分離： 將業務數據和日志數據存儲在不同的數據庫中，方便業務數據的備份和維護。

2. 讀寫分離： 將讀操作和寫操作分別指向不同的數據庫，提高系統的讀取性能。

3. 多租戶系統： 在一個系統中為不同的租戶使用不同的數據庫，確保數據隔離和安全性。

4. 數據分片： 將數據按照某種規則分散到不同的數據庫中，提高查詢效率。

Spring Boot集成MyBatis的基礎配置

在開始之前，確保你已經創建了一個Spring Boot項目。接下來，我們將通過Maven添加MyBatis和連接池的依賴項。

<!-- MyBatis依賴 -->
<dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>2.2.0</version>
</dependency><!-- 數據庫連接池（以Druid為例） -->
<dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>1.2.6</version>
</dependency>

接著，配置application.properties或application.yml文件，指定數據庫連接信息：

# 主數據源
spring.datasource.primary.url=jdbc:mysql://localhost:3306/primarydb
spring.datasource.primary.username=root
spring.datasource.primary.password=root
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver# 第二個數據源
spring.datasource.secondary.url=jdbc:mysql://localhost:3306/secondarydb
spring.datasource.secondary.username=root
spring.datasource.secondary.password=root
spring.datasource.secondary.driver-class-name=com.mysql.cj.jdbc.Driver

這里配置了兩個數據源，分別是primary和secondary。接下來，我們需要創建對應的數據源、SqlSessionFactory和SqlSessionTemplate。

@Configuration
@MapperScan(basePackages = "com.example.mapper.primary", sqlSessionTemplateRef = "primarySqlSessionTemplate")
public class PrimaryDataSourceConfig {@Primary@Bean(name = "primaryDataSource")@ConfigurationProperties(prefix = "spring.datasource.primary")public DataSource dataSource() {return DataSourceBuilder.create().build();}@Primary@Bean(name = "primarySqlSessionFactory")public SqlSessionFactory sqlSessionFactory(@Qualifier("primaryDataSource") DataSource dataSource) throws Exception {SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();factoryBean.setDataSource(dataSource);return factoryBean.getObject();}@Primary@Bean(name = "primarySqlSessionTemplate")public SqlSessionTemplate sqlSessionTemplate(@Qualifier("primarySqlSessionFactory") SqlSessionFactory sqlSessionFactory) {return new SqlSessionTemplate(sqlSessionFactory);}
}

上述代碼中，@Primary注解表示這是主數據源的配置。同樣，我們也需要為第二個數據源進行配置：

@Configuration
@MapperScan(basePackages = "com.example.mapper.secondary", sqlSessionTemplateRef = "secondarySqlSessionTemplate")
public class SecondaryDataSourceConfig {@Bean(name = "secondaryDataSource")@ConfigurationProperties(prefix = "spring.datasource.secondary")public DataSource dataSource() {return DataSourceBuilder.create().build();}@Bean(name = "secondarySqlSessionFactory")public SqlSessionFactory sqlSessionFactory(@Qualifier("secondaryDataSource") DataSource dataSource) throws Exception {SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();factoryBean.setDataSource(dataSource);return factoryBean.getObject();}@Bean(name = "secondarySqlSessionTemplate")public SqlSessionTemplate sqlSessionTemplate(@Qualifier("secondarySqlSessionFactory") SqlSessionFactory sqlSessionFactory) {return new SqlSessionTemplate(sqlSessionFactory);}
}

這樣，我們已經完成了多數據源的基礎配置。

使用多數據源

接下來，我們將演示如何在Service層中使用多數據源。首先，創建對應的Mapper接口和Mapper XML文件。

// PrimaryDataSource中的Mapper接口
@Mapper
public interface PrimaryUserMapper {User getUserById(@Param("userId") int userId);
}

<!-- PrimaryUserMapper.xml -->
<mapper namespace="com.example.mapper.primary.PrimaryUserMapper"><resultMap id="BaseResultMap" type="com.example.entity.User"><id column="id" property="id" jdbcType="INTEGER"/><result column="username" property="username" jdbcType="VARCHAR"/><result column="password" property="password" jdbcType="VARCHAR"/></resultMap><select id="getUserById" resultMap="BaseResultMap">SELECT * FROM user WHERE id = #{userId}</select>
</mapper>

// SecondaryDataSource中的Mapper接口
@Mapper
public interface SecondaryUserMapper {User getUserById(@Param("userId") int userId);
}

<!-- SecondaryUserMapper.xml -->
<mapper namespace="com.example.mapper.secondary.SecondaryUserMapper"><resultMap id="BaseResultMap" type="com.example.entity.User"><id column="id" property="id" jdbcType="INTEGER"/><result column="username" property="username" jdbcType="VARCHAR"/><result column="password" property="password" jdbcType="VARCHAR"/></resultMap><select id="getUserById" resultMap="BaseResultMap">SELECT * FROM user WHERE id = #{userId}</select>
</mapper>

然后，在Service層中分別注入兩個Mapper接口，并在方法中使用對應的數據源。

@Service
public class UserService {@Autowiredprivate PrimaryUserMapper primaryUserMapper;@Autowiredprivate SecondaryUserMapper secondaryUserMapper;@Transactional(transactionManager = "primaryTransactionManager")public User getPrimaryUserById(int userId) {return primaryUserMapper.getUserById(userId);}@Transactional(transactionManager = "secondaryTransactionManager")public User getSecondaryUserById(int userId) {return secondaryUserMapper.getUserById(userId);}
}

在上述代碼中，通過@Transactional(transactionManager = "primaryTransactionManager")注解指定了使用主數據源。同樣，@Transactional(transactionManager = "secondaryTransactionManager")注解指定了使用第二個數據源。

最后，我們需要在application.properties或application.yml中配置事務管理器的Bean。

# 主數據源事務管理器
spring.primary.datasource.transactionManager=primaryTransactionManager# 第二個數據源事務管理器
spring.secondary.datasource.transactionManager=secondaryTransactionManager

小結

通過以上步驟，我們成功地實現了Spring Boot集成MyBatis，并實現了對多數據源的訪問。使用多數據源可以滿足一些特定的業務需求，如讀寫分離、多租戶系統等。在實際應用中，根據項目的具體情況，可以進一步進行配置和優化。

希望本文能夠幫助讀者更好地理解Spring Boot如何集成MyBatis，以及如何配置和使用多數據源。同時，了解多數據源的使用場景和優勢，對于構建高性能、可擴展的應用系統有著重要的意義。

---

🧸結尾 ?? 感謝您的支持和鼓勵！ 😊🙏
📜您可能感興趣的內容：

• 【Java面試技巧】Java面試八股文 - 掌握面試必備知識（目錄篇）
• 【Java學習路線】2023年完整版Java學習路線圖
• 【AIGC人工智能】Chat GPT是什么，初學者怎么使用Chat GPT，需要注意些什么
• 【Java實戰項目】SpringBoot+SSM實戰：打造高效便捷的企業級Java外賣訂購系統
• 【數據結構學習】從零起步：學習數據結構的完整路徑