1.4、springboot整合多数据源

你们在项目中有使用到多数据源吗？

4.4.1配置文件中新增两个数据源

spring.datasource.test1.driverClassName = com.mysql.jdbc.Driver

spring.datasource.test1.url = jdbc:mysql://localhost:3306/test01?useUnicode=true&characterEncoding=utf-8

spring.datasource.test1.username = root

spring.datasource.test1.password = root

spring.datasource.test2.driverClassName = com.mysql.jdbc.Driver

spring.datasource.test2.url = jdbc:mysql://localhost:3306/test02?useUnicode=true&characterEncoding=utf-8

spring.datasource.test2.username = root

spring.datasource.test2.password = root

4.4.2配置文件中新增两个数据源

@Configuration // 注册到springboot容器中

@MapperScan(basePackages = "com.cs.user1", sqlSessionFactoryRef = "test1SqlSessionFactory")

public class DataSource1Config {

/**

*

* @methodDesc: 功能描述:(配置test1数据库)

*/

@Bean(name = "test1DataSource")

@Primary

@ConfigurationProperties(prefix = "spring.datasource.test1")

public DataSource testDataSource() {

return DataSourceBuilder.create().build();

}

/**

*

* @methodDesc: 功能描述:(test1 sql会话工厂)

* Exception

*/

@Bean(name = "test1SqlSessionFactory")

@Primary

public SqlSessionFactory testSqlSessionFactory(@Qualifier("test1DataSource") DataSource dataSource)

throws Exception {

SqlSessionFactoryBean bean = new SqlSessionFactoryBean();

bean.setDataSource(dataSource);

// bean.setMapperLocations(

// new PathMatchingResourcePatternResolver().getResources("classpath:mybatis/mapper/test1/*.xml"));

return bean.getObject();

}

/**

*

* @methodDesc: 功能描述:(test1 事物管理)

*/

@Bean(name = "test1TransactionManager")

@Primary

public DataSourceTransactionManager testTransactionManager(@Qualifier("test1DataSource") DataSource dataSource) {

return new DataSourceTransactionManager(dataSource);

}

@Bean(name = "test1SqlSessionTemplate")

public SqlSessionTemplate testSqlSessionTemplate(

@Qualifier("test1SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {

return new SqlSessionTemplate(sqlSessionFactory);

}

}

4.4.2创建分包Mapper

public interface User1Mapper {

@Insert("insert into users values(null,#{name},#{age});")

public int addUser(@Param("name") String name, @Param("age") Integer age);

}

4.4.3启动项目

@ComponentScan(basePackages = "com.cs")

@EnableAutoConfiguration

public class App {

public static void main(String[] args) {

SpringApplication.run(App.class, args);

}

}

欢迎关注本人微信公众号，继续交流更多技术问题，还有架构师视频领取哦

http://weixin.qq.com/r/KSgWDg3EuFDHrUlt9307 (二维码自动识别)