上述的问题采用mybatis-plus的方法,并且在连接数据库是采用spring.datasource.dynamic.datasource.master.driver-class-name=oracle.jdbc.OracleDriver spring.datasource.dynamic.datasource.master.url=jdbc:oracle:thin:@10.178.8.137:1521:gsjzzdb 这种发放来区分数据库的主次
时间: 2023-12-06 17:05:48 浏览: 146
mybatis-plus-boot-starter-3.4.3.3.jar
如果采用Mybatis-Plus的方法连接多个数据库,可以采用Mybatis-Plus提供的动态数据源功能。
首先,在application.properties或application.yml中配置多个数据源,例如:
```
spring.datasource.dynamic.datasource.master.driver-class-name=oracle.jdbc.OracleDriver
spring.datasource.dynamic.datasource.master.url=jdbc:oracle:thin:@10.178.8.137:1521:gsjzzdb
spring.datasource.dynamic.datasource.master.username=root
spring.datasource.dynamic.datasource.master.password=root
spring.datasource.dynamic.datasource.slave.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.dynamic.datasource.slave.url=jdbc:mysql://localhost:3306/db2
spring.datasource.dynamic.datasource.slave.username=root
spring.datasource.dynamic.datasource.slave.password=root
```
然后,在我们的代码中,我们需要使用DynamicDataSourceContextHolder来切换不同的数据源。例如,我们可以使用以下代码来查询master数据源中的数据表:
```
DynamicDataSourceContextHolder.setDataSourceType(DataSourceEnum.MASTER);
List<User> userList = userMapper.selectList(null);
// do something with the userList
DynamicDataSourceContextHolder.clearDataSourceType();
```
同样的,我们也可以切换到slave数据源并执行SQL语句。例如,我们可以使用以下代码来查询slave数据源中的数据表:
```
DynamicDataSourceContextHolder.setDataSourceType(DataSourceEnum.SLAVE);
List<Order> orderList = orderMapper.selectList(null);
// do something with the orderList
DynamicDataSourceContextHolder.clearDataSourceType();
```
其中,DataSourceEnum是一个枚举类型,用于指定不同的数据源。例如:
```
public enum DataSourceEnum {
MASTER,
SLAVE
}
```
在我们的代码中,我们还需要为每个数据源创建对应的SqlSessionFactory和Mapper bean,并将其注入到我们的应用程序中。例如,我们可以使用以下代码创建master数据源的SqlSessionFactory和Mapper bean:
```
@Bean(name = "masterDataSource")
@ConfigurationProperties(prefix = "spring.datasource.dynamic.datasource.master")
public DataSource masterDataSource() {
return DruidDataSourceBuilder.create().build();
}
@Bean(name = "masterSqlSessionFactory")
public SqlSessionFactory masterSqlSessionFactory(@Qualifier("masterDataSource") DataSource dataSource) throws Exception {
MybatisSqlSessionFactoryBean factoryBean = new MybatisSqlSessionFactoryBean();
factoryBean.setDataSource(dataSource);
return factoryBean.getObject();
}
@Bean(name = "masterSqlSessionTemplate")
public SqlSessionTemplate masterSqlSessionTemplate(@Qualifier("masterSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
return new SqlSessionTemplate(sqlSessionFactory);
}
@Bean(name = "userMapper")
public UserMapper userMapper(@Qualifier("masterSqlSessionTemplate") SqlSessionTemplate sqlSessionTemplate) {
return sqlSessionTemplate.getMapper(UserMapper.class);
}
```
同样的,我们也需要为slave数据源创建对应的SqlSessionFactory和Mapper bean。例如,我们可以使用以下代码创建slave数据源的SqlSessionFactory和Mapper bean:
```
@Bean(name = "slaveDataSource")
@ConfigurationProperties(prefix = "spring.datasource.dynamic.datasource.slave")
public DataSource slaveDataSource() {
return DruidDataSourceBuilder.create().build();
}
@Bean(name = "slaveSqlSessionFactory")
public SqlSessionFactory slaveSqlSessionFactory(@Qualifier("slaveDataSource") DataSource dataSource) throws Exception {
MybatisSqlSessionFactoryBean factoryBean = new MybatisSqlSessionFactoryBean();
factoryBean.setDataSource(dataSource);
return factoryBean.getObject();
}
@Bean(name = "slaveSqlSessionTemplate")
public SqlSessionTemplate slaveSqlSessionTemplate(@Qualifier("slaveSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
return new SqlSessionTemplate(sqlSessionFactory);
}
@Bean(name = "orderMapper")
public OrderMapper orderMapper(@Qualifier("slaveSqlSessionTemplate") SqlSessionTemplate sqlSessionTemplate) {
return sqlSessionTemplate.getMapper(OrderMapper.class);
}
```
注意,在使用Mybatis-Plus的动态数据源功能之前,我们需要在pom.xml中引入mybatis-plus-boot-starter和druid-spring-boot-starter依赖。例如:
```
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.4.0</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.2.6</version>
</dependency>
```
如果你的代码中仍然无法连接到表,请确保你的SQL语句正确,并检查表名是否正确。
阅读全文