springboot - mybatis 实现多数据源连接(静态)

ゞ浴缸里的玫瑰 2022-05-17 02:08 303阅读 0赞

## 前言 ##

###    在实际开发中我们往往要实现多个数据源的信息操作，比如查询一个数据源的名称时，还要将该数据的其他信息从另一个数据源中提取，这里我使用的是静态的方法，也就是把各个不同的数据源配置在各自的配置文件config中，让每个Mapper都有对应的config文件配置。 ###

### 这里感谢其他博主的分享，参考文章：[springBoot 动态数据源以及Mybatis多数据源][springBoot _Mybatis] ###

废话不多说，先把整个项目的结构说一下：

![70][]

### 这个项目的名称是doubleidea,包使用默认的com.example ###

### 下面来解释一下各个包的内容 ###

###   config包中 DatasourceConfig文件是将我们在application.properties中配置的多数据源读取并使用@Bean标签声明;MybatisDbAConfig和MybatisDbBConfig分别实现了两个数据源的sqlSessionFactory和SqlSessionTemplate两个方法，其实就是在读取之前的@Bean下的数据库中操作的实体类和放在xml中的sql语句。 ###

###   Controller包中的文件就是映射和适配对应的方法，这里我仅实现了数据查看 ###

###   one/mapper和two/mapper两个包的接口内容大体一致，都是声明对应的xml文件中的id里的方法，进行数据操作 ###

###   Person包中的两个实体类就是对应的两个数据库中的表名 ###

在简单了解了项目的结构后，我们就可以开始我们的项目了，

### 第一步、先将我们的pom.xml文件配置依赖，导入jar包 ###

<dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-jdbc</artifactId>
            </dependency>
            <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>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-tomcat</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-autoconfigure</artifactId>
            </dependency>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-aop</artifactId>
            </dependency>
            <dependency>
                <groupId>org.mybatis</groupId>
                <artifactId>mybatis-spring</artifactId>
                <version>1.2.3</version>
            </dependency>
            <dependency>
                <groupId>org.mybatis</groupId>
                <artifactId>mybatis</artifactId>
                <version>3.3.0</version>
            </dependency>
            <dependency>
                <groupId>org.aspectj</groupId>
                <artifactId>aspectjweaver</artifactId>
                <version>1.8.13</version>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid</artifactId>
                <version>1.0.26</version>
            </dependency>
        </dependencies>

### 第二步、在默认配置文件application.perproties中将我们的两个数据源配置写进去 ###

![70 1][]

### 第三步、我们要在运行类DoubleideaApplication中写入 ###

### (exclude = \{DataSourceAutoConfiguration.class\})，关闭默认数据源配置 ###

![70 2][]

### 第四步、配置实体类 ###

![70 3][]

![70 4][]

### 第五步、就是将我们的数据源从之前的配置文件中读取出来了 ###

### 首先是配置DataSourceConfig这个类 ###

@Configuration
    public class DataSourceConfig {
    
        @Autowired
        Environment env;
    
        @Bean(name = "one")
        public DataSource dataSource1(){
            DruidDataSource dataSource = new DruidDataSource();
    
            dataSource.setUrl(env.getProperty("spring.datasource.one.url"));
            dataSource.setUsername(env.getProperty("spring.datasource.one.username"));
            dataSource.setPassword(env.getProperty("spring.datasource.one.password"));
            dataSource.setDriverClassName(env.getProperty("spring.datasource.one.driver-class-name"));
    
            return dataSource;
        }
    
    
        @Bean(name = "two")
        public DataSource dataSource2(){
            DruidDataSource dataSource = new DruidDataSource();
    
            dataSource.setUrl(env.getProperty("spring.datasource.two.url"));
            dataSource.setUsername(env.getProperty("spring.datasource.two.username"));
            dataSource.setPassword(env.getProperty("spring.datasource.two.password"));
            dataSource.setDriverClassName(env.getProperty("spring.datasource.two.driver-class-name"));
            return dataSource;
        }
    }

### 第七步、MybatisDbAConfig 和MybatisDbBConfig配置 ###

将两个数据源从配置信息中读取后，我们就要分别配置数据源的实体类和xml文件了

### MybatisDbAConfig  ###

import javax.sql.DataSource;
    
    @Configuration
    @MapperScan(basePackages = "com.example.doubleidea.one.mapper",sqlSessionFactoryRef = "sqlSessionFactory1")
    public class MybatisDbAConfig {
    
        @Qualifier("one")
        @Autowired
        private DataSource person;
    
        @Bean(name = "sqlSessionFactory1")
        public SqlSessionFactory sqlSessionFactory1() throws Exception{
            SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
            factoryBean.setDataSource(person);
            PathMatchingResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
            factoryBean.setMapperLocations(resolver.getResources("classpath:mapper/PersonMapper.xml"));
            factoryBean.setTypeAliasesPackage("com.example.doubleidea.Person");
            return factoryBean.getObject();
        }
    
        @Bean
        public SqlSessionTemplate sqlSessionTemplate1() throws Exception{
            SqlSessionTemplate template = new SqlSessionTemplate(sqlSessionFactory1());
            return template;
        }
    }

### MybatisDbBConfig ###

import javax.sql.DataSource;
    
    import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
    
    @Configuration
    @MapperScan(basePackages = {"com.example.doubleidea.two.mapper"}, sqlSessionFactoryRef = "sqlSessionFactory2")
    public class MybatisDbBConfig {
    
        @Autowired
        @Qualifier("two")
        private DataSource users;
    
        @Bean(name = "sqlSessionFactory2")
        public SqlSessionFactory sqlSessionFactory2() throws Exception {
            SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
            factoryBean.setDataSource(users);
            PathMatchingResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
            factoryBean.setMapperLocations(resolver.getResources("classpath:mapper/UserMapper.xml"));
            factoryBean.setTypeAliasesPackage("com.example.doubleidea.Person");
            return factoryBean.getObject();
    
        }
    
        @Bean
        public SqlSessionTemplate sqlSessionTemplate2() throws Exception {
            SqlSessionTemplate template = new SqlSessionTemplate(sqlSessionFactory2());
            return template;
        }
    }

### 最后一个Controller类 ###

@Controller
    public class personcontroller {
        final static Logger logger = LoggerFactory.getLogger(personcontroller.class);
    
        @Autowired
        UserMapper userMapper;
    
        @Autowired
        PersonMapper personMapper;
    
        @ResponseBody
        @RequestMapping("/hello")
        public String hello(){
             Person person = personMapper.seleteperson(6);
             User user = userMapper.seleteperson(1);
    
             logger.info(person+"....."+user);
            System.out.println("person id:"+person.getId()+".... person name:"+person.getName());
            System.out.println("user id:"+user.getId()+".... user name:"+user.getUsername()+"...password:"+user.getPassword());
             return null;
             //return person.getId()+"..."+person.getName();
        }
    }

### 这里我仅仅实现了将数据输出到控制台上，当然也可以在页面中显示出来，这里就不写那么多了 ###

### 好了，让我们运行一下， ###

# 这里我需要重要的说一下，如果控制台报错一般有以下几种情况： #

1.  # xml的namespace没有和Mapper类对应到，主要是大小写的问题 #
2.  # 数据源不能连接，你需要看你的运行类有没有关自动配置，看第三步 #
3.  # Controller或者bean找不到，仔细看你的@标签有没有遗漏 #

## ![70 5][] ##

## ok,大功告成，相关的xml文件和源代码可以点击[这里][Link 1] 下载，欢迎大家留言交流 ##

[springBoot _Mybatis]: https://blog.csdn.net/tengxing007/article/details/78424645
[70]: /images/20220517/27b5a34e6f3c4a6b8620af20c657d61f.png
[70 1]: /images/20220517/9ee822d66ddf4a82ba8071f514dde51b.png
[70 2]: /images/20220517/e4c7dda40be84e94be9c86e69acd9f93.png
[70 3]: /images/20220517/9a581b617fc64d41b51c537bd854155a.png
[70 4]: /images/20220517/2784b9c23f1b47b097aa375252a91b62.png
[70 5]: /images/20220517/e97c1a9a44d6429aad42d122f0a9ee61.png
[Link 1]: https://github.com/sanfenzZ/doublemysqlconnect