公司的项目因为业务的原因采用了多数据源的配置，之前没有用过，现在学习一下。
由于SpringBoot框架会读取application.properties文件的spring.datasource.*属性并自动配置单数据源，所以我们需要在启动类上面加上@EnableAutoConfiguration(exclude={DataSourceAutoConfiguration.class}）禁止。
package com.example; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.EnableAutoConfiguration; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration; import org.springframework.boot.autoconfigure.jdbc.DataSourceTransactionManagerAutoConfiguration; @SpringBootApplication(scanBasePackages = { "com.example"}) // 需要在启动类上面加DataSourceAutoConfiguration禁止springboot自动寻找spring.datasource.*作为数据源 @EnableAutoConfiguration(exclude = { DataSourceAutoConfiguration.class, DataSourceTransactionManagerAutoConfiguration.class }) public class Application { public static void main(String[] args) { SpringApplication.run(Application.class, args); } } 然后在properties配置文件中加入数据源的配置 spring.datasource.test1.driverClassName = com.mysql.jdbc.Driver spring.datasource.test1.url = jdbc:mysql://127.0.0.1:3306/person spring.datasource.test1.username = root spring.datasource.test1.password = *** spring.datasource.test2.driverClassName = com.mysql.jdbc.Driver spring.datasource.test2.url = jdbc:mysql://*.*.*.*:3306/ord?useUnicode=true&characterEncoding=UTF-8 spring.datasource.test2.username = sldev spring.datasource.test2.password = *** server.port=8081 然后写每个数据源的实现 package com.example.util; import java.io.IOException; import javax.sql.DataSource; import org.apache.ibatis.session.SqlSessionFactory; import org.mybatis.spring.SqlSessionFactoryBean; import org.mybatis.spring.SqlSessionTemplate; import org.mybatis.spring.annotation.MapperScan; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.boot.autoconfigure.jdbc.DataSourceBuilder; import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Primary; import org.springframework.core.io.support.PathMatchingResourcePatternResolver; import org.springframework.jdbc.datasource.DataSourceTransactionManager; import org.springframework.transaction.annotation.EnableTransactionManagement; @EnableTransactionManagement @Configuration //当使用com.example.test1.dao的方法时采用test1SqlSessionTemplate的数据源 @MapperScan(basePackages = "com.example.test1.dao", sqlSessionTemplateRef = "test1SqlSessionTemplate") public class Test1DataSource { @Bean(name="DataSource1") //从配置文件中读取地址 @ConfigurationProperties(prefix="spring.datasource.test1") @Primary public DataSource dataSource1(){ return DataSourceBuilder.create().build(); } @Bean(name="test1SqlSessionFactory") //默认数据源，不加这个注解会报错 @Primary public SqlSessionFactory creatSqlSessionFactory(@Qualifier("DataSource1") DataSource dataSource) throws Exception{ SqlSessionFactoryBean sql=new SqlSessionFactoryBean(); //将地址注入到SqlSessionFactory sql.setDataSource(dataSource); //这里xml的地址 sql.setMapperLocations( new PathMatchingResourcePatternResolver().getResources("classpath:mapper/*.xml")); return sql.getObject(); } @Bean(name = "test1SqlSessionTemplate") @Primary public SqlSessionTemplate testSqlSessionTemplate( @Qualifier("test1SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception { return new SqlSessionTemplate(sqlSessionFactory); } //配置事务 @Bean(name = "test1TransactionManager") @Primary public DataSourceTransactionManager testTransactionManager(@Qualifier("DataSource1") DataSource dataSource) { return new DataSourceTransactionManager(dataSource); } } package com.example.util; import java.io.IOException; import javax.sql.DataSource; import org.apache.ibatis.session.SqlSessionFactory; import org.mybatis.spring.SqlSessionFactoryBean; import org.mybatis.spring.SqlSessionTemplate; import org.mybatis.spring.annotation.MapperScan; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.boot.autoconfigure.jdbc.DataSourceBuilder; import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.core.io.support.PathMatchingResourcePatternResolver; import org.springframework.jdbc.datasource.DataSourceTransactionManager; import org.springframework.transaction.annotation.EnableTransactionManagement; @EnableTransactionManagement @Configuration @MapperScan(basePackages = "com.example.test2.dao", sqlSessionTemplateRef = "test2SqlSessionTemplate") public class Test2DataSource { @Bean(name="DataSource2") //从配置文件中读取地址 @ConfigurationProperties(prefix="spring.datasource.test2") public DataSource dataSource2(){ return DataSourceBuilder.create().build(); } @Bean(name="test2SqlSessionFactory") public SqlSessionFactory creatSqlSessionFactory(@Qualifier("DataSource2") DataSource dataSource) throws Exception{ SqlSessionFactoryBean sql=new SqlSessionFactoryBean(); //将地址注入到SqlSessionFactory sql.setDataSource(dataSource); //这里可以配置xml的地址 sql.setMapperLocations( new PathMatchingResourcePatternResolver().getResources("classpath:mapper/*.xml")); return sql.getObject(); } @Bean(name = "test2SqlSessionTemplate") public SqlSessionTemplate testSqlSessionTemplate( @Qualifier("test2SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception { return new SqlSessionTemplate(sqlSessionFactory); } //配置事务 @Bean(name = "test2TransactionManager") public DataSourceTransactionManager testTransactionManager(@Qualifier("DataSource2") DataSource dataSource) { return new DataSourceTransactionManager(dataSource); }
然后把对应的dao放到对应的包中就可以了
