springboot整合mybatis配置多数据源（mysql/oracle）

前言

springboot整合mybatis配置多数据源，可以都是mysql数据源，也可以都是oracle数据源，也可以mysql/oracle数据源都有，下面是配置多数据源的步骤（不局限与某一类数据库），之前配过都是oracle数据源的配置，下面是验证这个想法的实现，实现效果后，好像也可以同时配MongoDB、Redis等其他的数据源配置，但是好像也没碰到有人在一个项目里面这么干过…要么都是mysql数据源要么都是oracle数据源。

导入依赖坐标

<dependencies><!--springboot起步依赖--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId><version>${spring-boot.version}</version></dependency><!-- spring-boot-starter-web  --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!--单元测试 包含junit-jupiter--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><!--springboot整合mybatis --><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>${mybatis.version}</version></dependency><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter-test</artifactId><version>${mybatis.version}</version><scope>test</scope></dependency><!--添加tk.mybatis用于对单表进行处理--><dependency><groupId>tk.mybatis</groupId><artifactId>mapper-spring-boot-starter</artifactId><version>${tk.mybatis.version}</version></dependency><!-- oracle驱动 --><dependency><groupId>com.oracle.database.jdbc</groupId><artifactId>ojdbc8</artifactId><version>${oracle.version}</version></dependency><!-- mysql驱动 --><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>${mysql.version}</version></dependency><!-- alibaba/druid --><dependency><groupId>com.alibaba</groupId><artifactId>druid</artifactId><version>${druid.version}</version></dependency><!--c3p0连接池--><dependency><groupId>com.mchange</groupId><artifactId>c3p0</artifactId><version>${c3p0.version}</version></dependency>
</dependencies>

创建mysql/oracle数据源配置类

MySQLDataSourceConfig

@Configuration
@MapperScan(basePackages = "com.example.dao.mysql", sqlSessionFactoryRef = "mysqlSessionFactory")
public class MySQLDataSourceConfig {@Primary // 表示这个数据源是默认数据源, 这个注解必须要加，因为不加的话spring将分不清楚那个为主数据源（默认数据源）@Bean("mysqlDataSource")//方式一：@ConfigurationProperties(prefix = "spring.datasource.mysql")@ConfigurationProperties(prefix = "spring.datasource.mysql") //读取application.yml中的配置参数映射成为一个对象public DataSource getMysqlDataSource() {return DataSourceBuilder.create().build();}//方式二：@Value注解方法 set方法注入yml数据源属性/*@Value("${spring.datasource.mysql.driver-class-name}")String driverClass;@Value("${spring.datasource.mysql.jdbc-url}")String url;@Value("${spring.datasource.mysql.username}")String userName;@Value("${spring.datasource.mysql.password}")String passWord;@Bean(name = "mysqlDataSource")@ConfigurationProperties("spring.datasource.mysql")public DataSource masterDataSource(){DriverManagerDataSource dataSource = new DriverManagerDataSource();dataSource.setDriverClass(driverClass);dataSource.setJdbcUrl(url);dataSource.setUser(userName);dataSource.setPassword(passWord);return dataSource;}*/@Primary@Bean("mysqlSessionFactory")public SqlSessionFactory mysqlSessionFactory(@Qualifier("mysqlDataSource") DataSource dataSource) throws Exception {SqlSessionFactoryBean bean = new SqlSessionFactoryBean();bean.setDataSource(dataSource);// mapper的xml形式文件位置必须要配置，不然将报错：no statement （这种错误也可能是mapper的xml中，namespace与项目的路径不一致导致）bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath*:mapper/mysql/*.xml")); // 持久化.xml文件的地址return bean.getObject();}@Primary@Bean("mysqlSessionTemplate")public SqlSessionTemplate mysqlSessionTemplate(@Qualifier("mysqlSessionFactory") SqlSessionFactory sqlSessionFactory) {return new SqlSessionTemplate(sqlSessionFactory);}
}

OracleDataSourceConfig

@Configuration
@MapperScan(basePackages = "com.example.dao.oracle", sqlSessionFactoryRef = "oracleSessionFactory")
public class OracleDataSourceConfig {@Bean("oracleDataSource")@ConfigurationProperties(prefix = "spring.datasource.oracle") //读取application.yml中的配置参数映射成为一个对象public DataSource getOracleDataSource() {return DataSourceBuilder.create().build();}@Bean("oracleSessionFactory")public SqlSessionFactory oracleSessionFactory(@Qualifier("oracleDataSource") DataSource dataSource) throws Exception {SqlSessionFactoryBean bean = new SqlSessionFactoryBean();bean.setDataSource(dataSource);// mapper的xml形式文件位置必须要配置，不然将报错：no statement （这种错误也可能是mapper的xml中，namespace与项目的路径不一致导致）bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath*:mapper/oracle/*.xml")); // 持久化.xml文件的地址return bean.getObject();}@Bean("oracleSessionTemplate")public SqlSessionTemplate oracleSessionTemplate(@Qualifier("oracleSessionFactory") SqlSessionFactory sqlSessionFactory) {return new SqlSessionTemplate(sqlSessionFactory);}

application.yml配置文件配置mysql/oracle数据源

spring:# 配置数据源datasource:#单一数据源配置driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://rhel:3306/note_bootusername: rootpassword: Redhat1#多数据源配置mysql:driver-class-name: com.mysql.cj.jdbc.Driverjdbc-url: jdbc:mysql://rhel:3306/note_bootusername: rootpassword: Redhat1oracle:driver-class-name: oracle.jdbc.OracleDriverjdbc-url: jdbc:oracle:thin:@//rhel:1521/orclusername: testdbpassword: oraclepasshikari:connection-timeout: 3000idle-timeout: 60000maximum-pool-size: 50minimum-idle: 5connection-test-query: select 1 from dualvalidation-timeout: 2000

编写Mapper接口

//BookDao里面都是两个简单查询测试方法，注解实现...
//mysql数据库测试
public Book getById(Integer id);
//oracle数据库测试
public Book findById(Integer id);

编写Book实体类

public class Book {private Integer id;private String name;private String type;private String description;//get/set方法省略...
}

编写测试类

public class MybatisDemo {@Autowiredprivate BookDao bookDao;@Autowiredprivate BookDao1 bookDao1;@Autowiredprivate BookDao2 bookDao2;@Testvoid test() {//原始配置，单一数据库查询Book book = bookDao.getById(1);System.out.println(book);//多数据源配置 mysql查询Book book1 = bookDao1.getById(1);System.out.println(book1);//多数据源配置 oracle查询Book book2 = bookDao2.findById(1);System.out.println(book2);}
}

效果图：