1、引入依赖

<parent>

        <groupId>org.springframework.boot</groupId>

        <artifactId>spring-boot-parent</artifactId>

        <version>2.0.6.RELEASE</version>

    </parent>

    <dependencies>

        <dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-web</artifactId>

        </dependency>

        <dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-test</artifactId>

        </dependency>

        <!--mybatis起步依赖-->

        <dependency>

            <groupId>org.mybatis.spring.boot</groupId>

            <artifactId>mybatis-spring-boot-starter</artifactId>

            <version>1.1.1</version>

        </dependency>

        <!--mysql依赖-->

        <dependency>

            <groupId>mysql</groupId>

            <artifactId>mysql-connector-java</artifactId>

            <scope>runtime</scope>

        </dependency>

    </dependencies>

2、配置application.properties中配置多个数据源

#slave dataSource数据源

spring.datasource.slave.driver-class-name =com.mysql.jdbc.Driver

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

spring.datasource.slave.username =root

spring.datasource.slave.password =root

#master  dataSource数据源

spring.datasource.master.driver-class-name =com.mysql.jdbc.Driver

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

spring.datasource.master.username =root

spring.datasource.master.password =root

3、创建多个配置类

数据源1；

@Configuration

@MapperScan(basePackages =DataSourceMaterConfig.PACKAGE,sqlSessionFactoryRef = "masterSqlSessionFactory")

public class DataSourceMaterConfig {

    // master dao所在的包

    public static final String PACKAGE = "com.yehui.mapper.master";

    //配置文件所在目录

    //private static final String MAPPER_LOCATION = "classpath:mapper/master/*.xml";

    @Bean(name = "mapper/master")

    @Primary //默认访问

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

    public DataSource msaterDataSource() {

        return DataSourceBuilder.create().build();

    }

    // 创建Session

    @Bean(name = "masterSqlSessionFactory")

    @Primary //默认访问

    public SqlSessionFactory sqlSessionFactory() throws Exception {

        final SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();

        sqlSessionFactoryBean.setDataSource(msaterDataSource());

       /* 使用配置文件是加入

       Resource[] mapperLocations = new PathMatchingResourcePatternResolver()

                .getResources(DataSourceMaterConfig.MAPPER_LOCATION);

        sqlSessionFactoryBean.setMapperLocations(mapperLocations);*/

        return sqlSessionFactoryBean.getObject();

    }

    // 数据源事务管理器

    @Bean(name = "masterDataSourceTransactionManager")

    @Primary //默认访问

    public DataSourceTransactionManager masterDataSourceTransactionManager() {

        return new DataSourceTransactionManager(msaterDataSource());

    }

}

数据源2:

@Configuration

@MapperScan(basePackages =DataSourceSalveConfig.PACKAGE,sqlSessionFactoryRef = "slaveSqlSessionFactory")

public class DataSourceSalveConfig {

    // slave dao所在的包

    public static final String PACKAGE = "com.yehui.mapper.slave";

    //配置文件所在目录

    private static final String MAPPER_LOCATION = "classpath:mapper/slave/*.xml";

    @Bean(name = "mapper/slave")

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

    public DataSource slaveDataSource() {

        return DataSourceBuilder.create().build();

    }

    // 创建Session

    @Bean(name = "slaveSqlSessionFactory")

    public SqlSessionFactory sqlSessionFactory() throws Exception {

        final SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();

        sqlSessionFactoryBean.setDataSource(slaveDataSource());

        /*使用配置文件时加入

        Resource[] mapperLocations = new PathMatchingResourcePatternResolver()

                .getResources(DataSourceSalveConfig.MAPPER_LOCATION);

        sqlSessionFactoryBean.setMapperLocations(mapperLocations);*/

        return sqlSessionFactoryBean.getObject();

    }

    // 数据源事务管理器

    @Bean(name = "slaveDataSourceTransactionManager")

    public DataSourceTransactionManager slaveDataSourceTransactionManager() {

        return new DataSourceTransactionManager(slaveDataSource());

    }

}

4、创建多个包mapper

数据源1：

package com.yehui.mapper.master;

import org.apache.ibatis.annotations.Select;

import java.util.List;

import java.util.Map;

public interface MasterMapper {

    @Select("SELECT * FROM tb_user")

    public List<Map<String,Object>> selectList();

}

数据源2：

package com.yehui.mapper.slave;

import org.apache.ibatis.annotations.Select;

import java.util.List;

import java.util.Map;

public interface SlaveMapper {

    @Select("SELECT * FROM tb_user")

    public List<Map<String,Object>> selectList();

}

5、创建service类

@Service

public class UserService {

    @Autowired

    private MasterMapper masterMapper;

    @Autowired

    private SlaveMapper savlesMapper;

    public List<Map<String,Object>> selectList1(){

        return masterMapper.selectList();

    }

    public List<Map<String,Object>> selectList2(){

        return savlesMapper.selectList();

    }

}

6、测试类

@RunWith(SpringRunner.class)

@SpringBootTest

public class DataSourceTest {

    @Autowired

    private UserService userService;

    @Test

    public void  test1(){

        List<Map<String, Object>> mapList = userService.selectList1();

        System.out.println(mapList);

    }

    @Test

    public void  test2(){

        List<Map<String, Object>> mapList = userService.selectList2();

        System.out.println(mapList);

    }

}

注意配置过程中如果报此错误

No qualifying bean of type 'javax.sql.DataSource' available: more than one 'primary' bean found amon

导致原因@Primary这个注解只能在一个包下存在，不能在其他存在

巴特西

SpringBoot 分包方式多数据源

1、引入依赖

2、配置application.properties中配置多个数据源

3、创建多个配置类

4、创建多个包mapper

5、创建service类

6、测试类

最新文章

热门文章