springBoot整合多数据源

springBoot整合相关

1：springBoot整合多数据源：

 应用场景：     项目需要同时连接两个不同的数据库A, B，并且它们都为主从架构，一台写库，多台读库。

工具/版本：

    jdk1.8、idea2018.1.4、springBoot2.0.1

注意：一定要统一版本，特别是springBoot不然或出问题。

创建项目：

    我这里的项目与上一篇的springBoot整合mybatis、jsp是一样的就不重新建了。

下面我们看一下项目结构：

红框表示整合多数据源用到的模块：

下面我们开始整合：

 1：首先：我们在application.properties配置文件中配置两个数据源：

application.properties   ：

#test01 datasource
spring.datasource.hikari.test1.driver-class-name = com.mysql.jdbc.Driver
spring.datasource.hikari.test1.jdbc-url = jdbc:mysql://localhost:3306/test01?useUnicode=true&characterEncoding=utf-8
spring.datasource.hikari.test1.username = root
spring.datasource.hikari.test1.password = admin

####test02 datasource
spring.datasource.hikari.test2.driver-class-name = com.mysql.jdbc.Driver
spring.datasource.hikari.test2.jdbc-url = jdbc:mysql://localhost:3306/test02?useUnicode=true&characterEncoding=utf-8
spring.datasource.hikari.test2.username = root
spring.datasource.hikari.test2.password = admin

2： 然后新建dataSource包 ：参考上面的项目结构

新建类：Datasource1Config :

注：该数据源只针对下面的test1包下面的所有方法

package com.dengwei.springdemo.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.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;

import javax.sql.DataSource;
/*
 *  @Configuration :// 注册到springBoot容器中
 *  @MapperScan(basePackages = "com.dengwei.springdemo.test1", sqlSessionFactoryRef = "sqlSessionFactory1")
 *  当前扫描包：com.dengwei.springdemo.test1下使用此数据源；sqlSessionFactoryRef：对应下面的sql回话工厂
 *  @Bean(name = "DataSource1")  ：给当前注入的bean对象取的名字
 *  @ConfigurationProperties(prefix = "spring.datasource.hikari.test1")   application.properteis中对应属性的前缀
 *  @Primary  : 设置默认数据源，当多个数据源时，不加会报错
 */
@Configuration
@MapperScan(basePackages = "com.dengwei.springdemo.test1", sqlSessionFactoryRef = "sqlSessionFactory1")
public class DataSource1Config {

    /**
     *
     * @methodDesc: 功能描述:(配置test1数据库)
     */
    @Bean(name = "DataSource1")
    @ConfigurationProperties(prefix = "spring.datasource.hikari.test1")
    @Primary
    public DataSource testDataSource() {
        return DataSourceBuilder.create().build();
    }

    /**
     *
     * @methodDesc: 功能描述:(test1 sql会话工厂)
     * @returnType:@param dataSource
     * @returnType:@throws Exception SqlSessionFactory

     */
    @Bean(name = "sqlSessionFactory1")
    @Primary
    public SqlSessionFactory testSqlSessionFactory(@Qualifier("DataSource1") DataSource dataSource)
            throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dataSource);
        //mybatis写配置文件（sql映射）需要加下面的代码
//         bean.setMapperLocations(
//                 new PathMatchingResourcePatternResolver().getResources("classpath:mybatis/mapper/test1/*.xml"));
        return bean.getObject();
    }

    /**
     *
     * @methodDesc: 功能描述:(test1 事物管理)
     */
    @Bean(name = "test1TransactionManager")
    @Primary
    public DataSourceTransactionManager testTransactionManager(@Qualifier("DataSource1") DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }

    @Bean(name = "test1SqlSessionTemplate")
    @Primary
    public SqlSessionTemplate testSqlSessionTemplate(
            @Qualifier("sqlSessionFactory1") SqlSessionFactory sqlSessionFactory) throws Exception {
        return new SqlSessionTemplate(sqlSessionFactory);
    }

}

2:再建类  DataSource2Config  : （基本上和DataSource1Config一样只是数据源名字不一样）

该数据源针对下面的test2包下面的方法：

package com.dengwei.springdemo.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.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;

import javax.sql.DataSource;

/*
 *  @Configuration :// 注册到springBoot容器中
 *  @MapperScan(basePackages = "com.dengwei.springdemo.test2", sqlSessionFactoryRef = "SqlSessionFactory2")
 *  当前扫描包：com.dengwei.springdemo.test2 下使用此数据源；sqlSessionFactoryRef：对应下面的sql回话工厂
 *  @Bean(name = "DataSource2")  ：给当前注入的bean对象取的名字
 *  @ConfigurationProperties(prefix = "spring.datasource.hikari.test2")   application.properteis中对应属性的前缀
 *
 */
@Configuration
@MapperScan(basePackages = "com.dengwei.springdemo.test2", sqlSessionFactoryRef = "sqlSessionFactory2")
public class DataSource2Config {

    /**
     *
     * @methodDesc: 功能描述:(配置test２数据库)
     */
    @Bean(name = "DataSource2")
    @ConfigurationProperties(prefix = "spring.datasource.hikari.test2")
    public DataSource testDataSource() {
        return DataSourceBuilder.create().build();
    }

    /**
     *
     * @methodDesc: 功能描述:(test２ sql会话工厂)
     * @returnType:@param dataSource
     * @returnType:@throws Exception SqlSessionFactory

     */
    @Bean(name = "sqlSessionFactory2")
    public SqlSessionFactory testSqlSessionFactory(@Qualifier("DataSource2") DataSource dataSource)
            throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dataSource);
        //mybatis写配置文件（sql映射）需要加下面的代码
//         bean.setMapperLocations(
//                 new PathMatchingResourcePatternResolver().getResources("classpath:mybatis/mapper/test1/*.xml"));
        return bean.getObject();
    }

    /**
     *
     * @methodDesc: 功能描述:(test2 事物管理)
     */
    @Bean(name = "test2TransactionManager")
    public DataSourceTransactionManager testTransactionManager(@Qualifier("DataSource2") DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }

    @Bean(name = "test2SqlSessionTemplate")
    public SqlSessionTemplate testSqlSessionTemplate(
            @Qualifier("sqlSessionFactory2") SqlSessionFactory sqlSessionFactory) throws Exception {
        return new SqlSessionTemplate(sqlSessionFactory);
    }

}

3 ：建两个数据的映射 接口 test1、test2：

这里sql我用的是注解的方式：

test1 -----  IUserMapper1:

package com.dengwei.springdemo.test1;


import com.dengwei.springdemo.model.User;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;


public interface IUserMapper1 {

    @Select("SELECT id,user_name userName, pass_word password FROM user WHERE id = #{id}")
    User queryById(@Param("id") Integer id);

    @Insert("INSERT INTO `user` (user_name, password) VALUES (#{userName},#{password})")
    void saveUser(@Param("userName") String userName, @Param("password") String password);
}

 test2 ---IUserMapper2 :

 与 IuserMapper1  中的方法一样，只是操作不同的数据库

package com.dengwei.springdemo.test2;


import com.dengwei.springdemo.model.User;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;


public interface IUserMapper2 {

    @Select("SELECT id,user_name userName, pass_word password FROM user WHERE id = #{id}")
    User queryById(@Param("id") Integer id);

    @Insert("INSERT INTO `user` (user_name, password) VALUES (#{userName},#{password})")
    void saveUser(@Param("userName") String userName, @Param("password") String password);
}

 4：建一个UserController2类 ：

测试两个包下面针对不同数据源的操作

package com.dengwei.springdemo.controller;

import com.dengwei.springdemo.model.User;
import com.dengwei.springdemo.test1.IUserMapper1;
import com.dengwei.springdemo.test2.IUserMapper2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

@Controller
@RequestMapping("/user2")
public class UserController2 {
    @Autowired
    private IUserMapper1 userMapper1;
    @Autowired
    private IUserMapper2 userMapper2;

    @RequestMapping("/userMapper1")
    @ResponseBody
    public String testUserMapper1(String name,String password){
        userMapper1.saveUser(name,password);
        return "success";
    }
    @RequestMapping("/userMapper2")
    @ResponseBody
    public String testUserMapper2(String name,String password){
         userMapper2.saveUser(name, password);
        return "success";
    }
}

 下面我们看一下springBoot的启动类：

 启动项目：

---

 数据库新增数据成功：

---