Spring-Boot + Mybatis 多数据源配置

折腾了一天，终于完成了多数据源的配置，记录在这里！

1，先上SpringBoot 基础配置

        ①,系统引入了Security的包，但是没有配置Security相关信息，在启动时会打印警告log，故这里排除SecurityAutoConfiguration这个类

2，配置两个数据源

@Configuration
public class DataBaseConfig implements EnvironmentAware {

	private RelaxedPropertyResolver dbPropertyResolver;

	private static final Logger logger = LoggerFactory.getLogger(EnvironmentAware.class);

	@Override
	public void setEnvironment(Environment environment) {
		dbPropertyResolver = new RelaxedPropertyResolver(environment,"jdbc.");
	}


	/**
	 * 写库
	 * @return
	 */
	@Bean(name="writeDataSource", destroyMethod = "close", initMethod="init")
	@Primary
	public DataSource writeDataSource() {
		DruidDataSource datasource = new DruidDataSource();
		datasource.setUrl(dbPropertyResolver.getProperty("url"));
		datasource.setDriverClassName(dbPropertyResolver.getProperty("driverClass"));
		datasource.setUsername(dbPropertyResolver.getProperty("username"));
		datasource.setPassword(dbPropertyResolver.getProperty("password"));
		return datasource;
	}

	/**
	 * 读库
	 * @return
	 */
	@Bean(name="readDataSource", destroyMethod = "close", initMethod="init")
	public DataSource readOneDataSource() {
		DruidDataSource datasource = new DruidDataSource();
		datasource.setUrl(dbPropertyResolver.getProperty("url"));
		datasource.setDriverClassName(dbPropertyResolver.getProperty("driverClassName"));
		datasource.setUsername(dbPropertyResolver.getProperty("username"));
		datasource.setPassword(dbPropertyResolver.getProperty("password"));
		return datasource;
	}
}

3，配置只读数据源与Mybatis的配置信息

@Configuration
@EnableTransactionManagement
@AutoConfigureAfter(WriteMybatisConfig.class)
public class ReadMybatisConfig implements EnvironmentAware {

	/**
	 * 日志记录器
	 */
	private static final Logger LOGGER = LoggerFactory.getLogger(ReadMybatisConfig.class);

	private RelaxedPropertyResolver mybatisPropertyResolver;

	/**
	 * 获取配置信息
	 * @param environment
	 */
	@Override
	public void setEnvironment(Environment environment) {
		mybatisPropertyResolver = new RelaxedPropertyResolver(environment,"mybatis.");
	}

	//从库数据源
	@Resource(name = "readDataSource")
	private DataSource readDataSource;

	/**
	 * 只读sqlSessionFactory
	 * @return
	 */
	@Bean(name = "readSqlSessionFactory")
	public SqlSessionFactory readSqlSessionFactory() {
		SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
		bean.setDataSource(readDataSource);
		bean.setTypeAliasesPackage(mybatisPropertyResolver.getProperty("typeAliasesPackage"));

		//分页插件
		PageHelper pageHelper = new PageHelper();
		Properties properties = new Properties();
		properties.setProperty("reasonable", "true");
		properties.setProperty("supportMethodsArguments", "true");
		properties.setProperty("returnPageInfo", "check");
		properties.setProperty("params", "count=countSql");
		pageHelper.setProperties(properties);
		bean.setPlugins(new Interceptor[]{pageHelper});

		//添加mybatis配置文件
		PathMatchingResourcePatternResolver resourceResolver = new PathMatchingResourcePatternResolver();
		bean.setConfigLocation(resourceResolver.getResource(mybatisPropertyResolver.getProperty("configLocation")));
		try {
			bean.setMapperLocations(resourceResolver.getResources(mybatisPropertyResolver.getProperty("mapperLocations")));
			return bean.getObject();
		} catch (IOException e) {
			LOGGER.error("获取mapper资源出现异常",e);
			throw new RuntimeException("获取mapper资源出现异常",e);
		} catch (Exception e){
			LOGGER.error("初始化sqlSessionFactory时出现异常",e);
			throw new RuntimeException("初始化sqlSessionFactory时出现异常",e);
		}
	}

}

@Configuration
@EnableTransactionManagement
@AutoConfigureAfter
public class WriteMybatisConfig implements EnvironmentAware {
    public static final Logger LOGGER = LoggerFactory.getLogger(WriteMybatisConfig.class);

	private RelaxedPropertyResolver mybatisPropertyResolver;

	@Override
	public void setEnvironment(Environment environment) {
		mybatisPropertyResolver = new RelaxedPropertyResolver(environment,"mybatis.");
	}

	//写库
	@Resource(name = "writeDataSource")
    private DataSource writeDataSource;

	/**
	 * 可读可写sqlSessionFactory
	 * @return
	 */
    @Bean(name = "writeSqlSessionFactory")
    public SqlSessionFactory writeSqlSessionFactory() {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(writeDataSource);
        bean.setTypeAliasesPackage(mybatisPropertyResolver.getProperty("typeAliasesPackage"));

        //分页插件
        PageHelper pageHelper = new PageHelper();
        Properties properties = new Properties();
        properties.setProperty("reasonable", "true");
        properties.setProperty("supportMethodsArguments", "true");
        properties.setProperty("returnPageInfo", "check");
        properties.setProperty("params", "count=countSql");
        pageHelper.setProperties(properties);
        bean.setPlugins(new Interceptor[]{pageHelper});

        //添加mybatis配置文件
		PathMatchingResourcePatternResolver resourceResolver = new PathMatchingResourcePatternResolver();
		bean.setConfigLocation(resourceResolver.getResource(mybatisPropertyResolver.getProperty("configLocation")));
        try {
			bean.setMapperLocations(resourceResolver.getResources(mybatisPropertyResolver.getProperty("mapperLocations")));
			return bean.getObject();
        } catch (IOException e) {
			LOGGER.error("获取mapper资源出现异常",e);
            throw new RuntimeException("获取mapper资源出现异常",e);
        } catch (Exception e){
			LOGGER.error("初始化sqlSessionFactory时出现异常",e);
			throw new RuntimeException("初始化sqlSessionFactory时出现异常",e);
		}
    }

	/**
	 * 因为当前项目中有
	 * @return
	 */
	@Bean(name = "writeTransactionManager")
	public DataSourceTransactionManager writeTransactionManager() {
		DataSourceTransactionManager manager = new DataSourceTransactionManager(writeDataSource);
		return manager;
	}


}

5，配置Mybatis的Mapper扫描器

@Configuration
public class MybatisMapperScannerConfig {

	/**
	 * 扫描读写模式-mapper,只有在basePackage包下且继承自BaseWriterMapper的mapper才会被扫描到
	 * @return
	 */
	@Bean(name = "writeMapperScanner")
	public MapperScannerConfigurer writeMapperScanner(){
		MapperScannerConfigurer configurer = new MapperScannerConfigurer();
		configurer.setBasePackage("com.llktop.dao");
		configurer.setMarkerInterface(BaseWriteMapper.class);
		configurer.setSqlSessionFactoryBeanName("writeSqlSessionFactory");
		return configurer;
	}

	/**
	 * 扫描只读模式-mapper,只有在basePackage包下且继承自BaseReadMapper的mapper才会被扫描到
	 * @return
	 */
	@Bean(name = "readMapperScanner")
	public MapperScannerConfigurer readMapperScanner(){
		MapperScannerConfigurer configurer = new MapperScannerConfigurer();
		configurer.setBasePackage("com.llktop.dao");
		configurer.setMarkerInterface(BaseReadMapper.class);
		configurer.setSqlSessionFactoryBeanName("readSqlSessionFactory");
		return configurer;
	}
}

这样，就做到了多套数据源，可以配合Mysql读写分离进行使用！