springboot使用MyBatis配置多个数据源,代码事例展示,展示完整
时间: 2024-01-31 13:02:41 浏览: 181
Mybatis plus 配置多数据源的实现示例
好的,以下是使用 Spring Boot 配置多个 MyBatis 数据源的完整示例代码:
首先,我们需要在 `application.properties` 文件中配置多个数据源的相关信息:
```properties
# 配置第一个数据源
spring.datasource.primary.url=jdbc:mysql://localhost:3306/db1
spring.datasource.primary.username=username1
spring.datasource.primary.password=password1
spring.datasource.primary.driver-class-name=com.mysql.jdbc.Driver
# 配置第二个数据源
spring.datasource.secondary.url=jdbc:mysql://localhost:3306/db2
spring.datasource.secondary.username=username2
spring.datasource.secondary.password=password2
spring.datasource.secondary.driver-class-name=com.mysql.jdbc.Driver
```
接下来,我们需要创建多个数据源的 `DataSource` 对象,并将其注入到 `SqlSessionFactory` 中:
```java
@Configuration
@MapperScan(basePackages = "com.example.mapper", sqlSessionTemplateRef = "primarySqlSessionTemplate")
public class PrimaryDataSourceConfig {
@Bean
@Primary
@ConfigurationProperties(prefix = "spring.datasource.primary")
public DataSource primaryDataSource() {
return DataSourceBuilder.create().build();
}
@Bean
@Primary
public SqlSessionFactory primarySqlSessionFactory() throws Exception {
SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
factoryBean.setDataSource(primaryDataSource());
Resource[] resources = new PathMatchingResourcePatternResolver()
.getResources("classpath*:mapper/primary/*Mapper.xml");
factoryBean.setMapperLocations(resources);
return factoryBean.getObject();
}
@Bean
@Primary
public SqlSessionTemplate primarySqlSessionTemplate() throws Exception {
return new SqlSessionTemplate(primarySqlSessionFactory());
}
}
@Configuration
@MapperScan(basePackages = "com.example.mapper", sqlSessionTemplateRef = "secondarySqlSessionTemplate")
public class SecondaryDataSourceConfig {
@Bean
@ConfigurationProperties(prefix = "spring.datasource.secondary")
public DataSource secondaryDataSource() {
return DataSourceBuilder.create().build();
}
@Bean
public SqlSessionFactory secondarySqlSessionFactory() throws Exception {
SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
factoryBean.setDataSource(secondaryDataSource());
Resource[] resources = new PathMatchingResourcePatternResolver()
.getResources("classpath*:mapper/secondary/*Mapper.xml");
factoryBean.setMapperLocations(resources);
return factoryBean.getObject();
}
@Bean
public SqlSessionTemplate secondarySqlSessionTemplate() throws Exception {
return new SqlSessionTemplate(secondarySqlSessionFactory());
}
}
```
这里我们创建了 `PrimaryDataSourceConfig` 和 `SecondaryDataSourceConfig` 两个配置类,分别用于配置第一个数据源和第二个数据源。其中,我们使用了 `@MapperScan` 注解扫描 `com.example.mapper` 包下的所有 Mapper 接口,并使用 `sqlSessionTemplateRef` 属性指定使用哪个 `SqlSessionTemplate`。
在配置类中,我们使用了 `@Bean` 注解创建了 `DataSource`、`SqlSessionFactory` 和 `SqlSessionTemplate` 对象,并将其注入到 Spring 容器中。同时,我们还使用了 `@Primary` 注解标记第一个数据源和 `SqlSessionTemplate` 为主数据源和主会话模板。
在创建 `SqlSessionFactory` 对象时,我们使用了 `SqlSessionFactoryBean` 类,并设置了 `DataSource` 对象和 Mapper 接口对应的 XML 文件路径,以便 MyBatis 能够正确解析 Mapper 接口中的 SQL 语句。
最后,在 Mapper 接口中使用 `@Qualifier` 注解指定使用哪个数据源:
```java
@Mapper
@Qualifier("primarySqlSessionTemplate")
public interface PrimaryMapper {
// ...
}
@Mapper
@Qualifier("secondarySqlSessionTemplate")
public interface SecondaryMapper {
// ...
}
```
这样,我们就完成了使用 Spring Boot 配置多个 MyBatis 数据源的示例代码。希望能对你有所帮助。
阅读全文