多数据源配置springboot+Mybatis

忘是亡心i 2023-07-06 09:51 13阅读 0赞

多数据源用到的场景很多，所以就写了本篇文章进行演示如何配置多数据源。[项目源码地址点击此处查看][Link 1]

项目依赖springboot2+mybatis+mysql

首先在mysql中创建数据库db1和db2，然后分别在两个数据库中创建表test1和test2并插入演示数据

create DATABASE test1;
    use test1;
    create table test1(
    	id int not null,
        name varchar(50)
    );
    insert into test1(id,name) values(2,'李四');
    
    create DATABASE test2;
    use test2;
    create table test2(
    	id int not null,
        name varchar(50)
    );
    insert into test2(id,name) values(1,'张三');

创建springboot项目并导入mybatis和mysql依赖

<dependency>
        <groupId>org.mybatis.spring.boot</groupId>
        <artifactId>mybatis-spring-boot-starter</artifactId>
        <version>2.1.1</version>
    </dependency>
    
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <scope>runtime</scope>
    </dependency>

项目结构  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNTQ4NzQx_size_16_color_FFFFFF_t_70]  
application.properties配置数据源

spring.datasource.test1.jdbc-url=jdbc:mysql://localhost:3306/test1?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8&useSSL=true
    spring.datasource.test1.username=root
    spring.datasource.test1.password=root
    spring.datasource.test1.driver-class-name=com.mysql.cj.jdbc.Driver
    
    spring.datasource.test2.jdbc-url=jdbc:mysql://localhost:3306/test2?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8&useSSL=true
    spring.datasource.test2.username=root
    spring.datasource.test2.password=root
    spring.datasource.test2.driver-class-name=com.mysql.cj.jdbc.Driver

MybatisTest1Config.java主数据源

package com.example.mybatis.config;
    
    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.core.io.support.PathMatchingResourcePatternResolver;
    import org.springframework.jdbc.datasource.DataSourceTransactionManager;
    
    import javax.sql.DataSource;
    
    @Configuration
    @MapperScan(basePackages = "com.example.mybatis.mapper.test1", sqlSessionTemplateRef = "test1SessionTemplate")
    public class MybatisTest1Config { 
        @Bean(name = "test1")
        @Primary
        @ConfigurationProperties(prefix = "spring.datasource.test1")
        public DataSource test1() { 
            return DataSourceBuilder.create().build();
        }
    
        @Bean
        @Primary
        public SqlSessionFactory test1SessionFactory(@Qualifier("test1") DataSource dataSource) throws Exception { 
            SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
            bean.setDataSource(dataSource);
            //添加XML目录
            bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath*:/mapper/test1/**/*Mapper.xml"));
            return bean.getObject();
        }
    
        @Bean
        @Primary
        public DataSourceTransactionManager test1TransactionManager(@Qualifier("test1") DataSource dataSource) { 
            return new DataSourceTransactionManager(dataSource);
        }
    
        @Bean
        @Primary
        public SqlSessionTemplate test1SessionTemplate(@Qualifier("test1SessionFactory") SqlSessionFactory sqlSessionFactory) { 
            return new SqlSessionTemplate(sqlSessionFactory);
        }
    }

MybatisTest2Config.java

package com.example.mybatis.config;
    
    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.core.io.support.PathMatchingResourcePatternResolver;
    import org.springframework.jdbc.datasource.DataSourceTransactionManager;
    
    import javax.sql.DataSource;
    
    @Configuration
    @MapperScan(basePackages = "com.example.mybatis.mapper.test2", sqlSessionTemplateRef = "test2SessionTemplate")
    public class MybatisTest2Config { 
        @Bean(name = "test2")
        @ConfigurationProperties(prefix = "spring.datasource.test2")
        public DataSource test2() { 
            return DataSourceBuilder.create().build();
        }
    
        @Bean
        public SqlSessionFactory test2SessionFactory(@Qualifier("test2") DataSource dataSource) throws Exception { 
            SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
            bean.setDataSource(dataSource);
            bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath*:/mapper/test2/**/*Mapper.xml"));
            return bean.getObject();
        }
    
        @Bean
        public DataSourceTransactionManager test2TransactionManager(@Qualifier("test2") DataSource dataSource) { 
            return new DataSourceTransactionManager(dataSource);
        }
    
        @Bean
        public SqlSessionTemplate test2SessionTemplate(@Qualifier("test2SessionFactory") SqlSessionFactory sqlSessionFactory) { 
            return new SqlSessionTemplate(sqlSessionFactory);
        }
    }

这里用了两个数据库进行演示，如果还要其它的可以继续按上面示例增加类和application.properties数据库配置，@Primary只需指定其中一个数据库就行

Test1.java

package com.example.mybatis.entity;
    
    public class Test1 { 
        private int id;
        private String name;
    
        @Override
        public String toString() { 
            return "Test1{" +
                    "id=" + id +
                    ", name='" + name + '\'' +
                    '}';
        }
    
        public int getId() { 
            return id;
        }
    
        public void setId(int id) { 
            this.id = id;
        }
    
        public String getName() { 
            return name;
        }
    
        public void setName(String name) { 
            this.name = name;
        }
    }

Test2.java

package com.example.mybatis.entity;
    
    public class Test2 {
        private int id;
        private String name;
    
        @Override
        public String toString() {
            return "Test2{" +
                    "id=" + id +
                    ", name='" + name + '\'' +
                    '}';
        }
    
        public int getId() {
            return id;
        }
    
        public void setId(int id) {
            this.id = id;
        }
    
        public String getName() {
            return name;
        }
    
        public void setName(String name) {
            this.name = name;
        }
    }

Test1Mapper.java

package com.example.mybatis.mapper.test1;
    
    import com.example.mybatis.entity.Test1;
    import org.apache.ibatis.annotations.Select;
    
    import java.util.List;
    
    public interface Test1Mapper { 
        @Select("select * from test1")
        List<Test1> getAll();
    }

Test2Mapper.java

package com.example.mybatis.mapper.test2;
    
    import com.example.mybatis.entity.Test2;
    import org.apache.ibatis.annotations.Select;
    
    import java.util.List;
    
    public interface Test2Mapper { 
        @Select("select * from test2")
        List<Test2> getAll();
    }

TestService.java

package com.example.mybatis.service;
    
    import com.example.mybatis.entity.Test1;
    import com.example.mybatis.entity.Test2;
    import com.example.mybatis.mapper.test1.Test1Mapper;
    import com.example.mybatis.mapper.test2.Test2Mapper;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    
    import java.util.List;
    
    @Service
    public class TestService { 
        @Autowired
        private Test1Mapper test1Mapper;
    
        @Autowired
        private Test2Mapper test2Mapper;
    
        public void getStudents() { 
            List<Test1> test1 = test1Mapper.getAll();
            List<Test2> test2 = test2Mapper.getAll();
    
            System.out.println("数据源DB1:" + test1);
            System.out.println("数据源DB2:" + test2);
        }
    }

TestController.java

package com.example.mybatis.controller;
    
    import com.example.mybatis.service.TestService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    public class TestController { 
        @Autowired
        private TestService testService;
    
        @RequestMapping("/test")
        public void getStudents() { 
            testService.getStudents();
        }
    }

最后启动项目，浏览器访问http://localhost:8080/test看控制台打印结果  
![在这里插入图片描述][20200223123226883.png]

[Link 1]: https://gitee.com/hehedabiao/springboot-series.git
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNTQ4NzQx_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200412190928980.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNTQ4NzQx,size_16,color_FFFFFF,t_70
[20200223123226883.png]: https://img-blog.csdnimg.cn/20200223123226883.png