SpringBoot之MyBatis多数据源配置实现

缺乏、安全感 2022-06-03 04:28 243阅读 0赞

1.新建SpringBootDemo\_mutilDatasource项目  
![这里写图片描述][SouthEast]

2，配置pom.xml

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
      <modelVersion>4.0.0</modelVersion>
    
      <groupId>com.spb</groupId>
      <artifactId>SpringBootDemo_mutilDatasource</artifactId>
      <version>0.0.1-SNAPSHOT</version>
      <packaging>jar</packaging>
    
      <name>SpringBootDemo</name>
      <url>http://maven.apache.org</url>
    
      <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <mybatis-spring-boot>1.2.0</mybatis-spring-boot>
        <mysql-connector>5.1.39</mysql-connector>
        <druid>1.0.18</druid>
      </properties>
    
       
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>1.4.0.BUILD-SNAPSHOT</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>
                <scope>test</scope>
            </dependency>
    
            
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
                <version>${mybatis-spring-boot}</version>
            </dependency>
    
            
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>${mysql-connector}</version>
            </dependency>
    
            
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid</artifactId>
                <version>${druid}</version>
            </dependency>
    
            <dependency>
              <groupId>junit</groupId>
              <artifactId>junit</artifactId>
              <version>3.8.1</version>
               <scope>test</scope>
            </dependency>
        </dependencies>
    
        
        <build>
            <plugins>
               
                <plugin>
                    <groupId>org.apache.maven.plugins</groupId>
                    <artifactId>maven-assembly-plugin</artifactId>
                    <version>2.4.1</version>
                    <configuration>
                        
                        <descriptorRefs>
                            <descriptorRef>jar-with-dependencies</descriptorRef>
                        </descriptorRefs>
                        
                        <archive>
                          <manifest>
                            <mainClass>com.spb.SpringBootDemo.App</mainClass>
                          </manifest>
                        </archive>
    
                    </configuration>
                    <executions>
                      <execution>
                        <id>make-assembly</id>
                         
                        <phase>package</phase> 
                        <goals>
                            <goal>single</goal>
                        </goals>
                      </execution>
                    </executions>
                </plugin>
    
            </plugins>
        </build>
    </project>

3, 创建application.propertises文件

## master \u6570\u636E\u6E90\u914D\u7F6E
    master.datasource.url=jdbc:mysql://localhost:3306/springbootdb?useUnicode=true&characterEncoding=utf8
    master.datasource.username=root
    master.datasource.password=123456
    master.datasource.driverClassName=com.mysql.jdbc.Driver
    
    ## cluster \u6570\u636E\u6E90\u914D\u7F6E
    cluster.datasource.url=jdbc:mysql://localhost:3306/springbootdb2?useUnicode=true&characterEncoding=utf8
    cluster.datasource.username=root
    cluster.datasource.password=123456
    cluster.datasource.driverClassName=com.mysql.jdbc.Driver

4.,编写扫描 Mapper 接口并容器管理

package com.spb.SpringBootDemo.config;
    
    import javax.sql.DataSource;
    
    import org.apache.ibatis.session.SqlSessionFactory;
    import org.mybatis.spring.SqlSessionFactoryBean;
    import org.mybatis.spring.annotation.MapperScan;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.beans.factory.annotation.Value;
    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 com.alibaba.druid.pool.DruidDataSource;
    
    @Configuration
    //扫描 Mapper 接口并容器管理
    @MapperScan(basePackages = MasterDataSourceConfig.PACKAGE, sqlSessionFactoryRef = "masterSqlSessionFactory")
    public class MasterDataSourceConfig {
    
         // 精确到 master 目录，以便跟其他数据源隔离
         static final String PACKAGE = "com.spb.SpringBootDemo.dao.master";
         static final String MAPPER_LOCATION = "classpath:mapper/master/*.xml";
    
         @Value("${master.datasource.url}")
         private String url;
    
         @Value("${master.datasource.username}")
         private String user;
    
         @Value("${master.datasource.password}")
         private String password;
    
         @Value("${master.datasource.driverClassName}")
         private String driverClass;
    
         @Bean(name = "masterDataSource")
         @Primary
         public DataSource masterDataSource() {
             DruidDataSource dataSource = new DruidDataSource();
             dataSource.setDriverClassName(driverClass);
             dataSource.setUrl(url);
             dataSource.setUsername(user);
             dataSource.setPassword(password);
             return dataSource;
         }
    
         @Bean(name = "masterTransactionManager")
         @Primary
         public DataSourceTransactionManager masterTransactionManager() {
             return new DataSourceTransactionManager(masterDataSource());
         }
    
         @Bean(name = "masterSqlSessionFactory")
         @Primary
         public SqlSessionFactory masterSqlSessionFactory(@Qualifier("masterDataSource") DataSource masterDataSource)
                 throws Exception {
             final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
             sessionFactory.setDataSource(masterDataSource);
             sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
                     .getResources(MasterDataSourceConfig.MAPPER_LOCATION));
             return sessionFactory.getObject();
         }
    }

--------------------

package com.spb.SpringBootDemo.config;
    
    import javax.sql.DataSource;
    
    import org.apache.ibatis.session.SqlSessionFactory;
    import org.mybatis.spring.SqlSessionFactoryBean;
    import org.mybatis.spring.annotation.MapperScan;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.beans.factory.annotation.Value;
    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 com.alibaba.druid.pool.DruidDataSource;
    
    @Configuration
    //扫描 Mapper 接口并容器管理
    @MapperScan(basePackages = ClusterDataSourceConfig.PACKAGE, sqlSessionFactoryRef = "clusterSqlSessionFactory")
    public class ClusterDataSourceConfig {
    
         // 精确到 cluster 目录，以便跟其他数据源隔离
         static final String PACKAGE = "com.spb.SpringBootDemo.dao.cluster";
         static final String MAPPER_LOCATION = "classpath:mapper/cluster/*.xml";
    
         @Value("${cluster.datasource.url}")
         private String url;
    
         @Value("${cluster.datasource.username}")
         private String user;
    
         @Value("${cluster.datasource.password}")
         private String password;
    
         @Value("${cluster.datasource.driverClassName}")
         private String driverClass;
    
         @Bean(name = "clusterDataSource")
         public DataSource clusterDataSource() {
             DruidDataSource dataSource = new DruidDataSource();
             dataSource.setDriverClassName(driverClass);
             dataSource.setUrl(url);
             dataSource.setUsername(user);
             dataSource.setPassword(password);
             return dataSource;
         }
    
         @Bean(name = "clusterTransactionManager")
         public DataSourceTransactionManager clusterTransactionManager() {
             return new DataSourceTransactionManager(clusterDataSource());
         }
    
         @Bean(name = "clusterSqlSessionFactory")
         public SqlSessionFactory clusterSqlSessionFactory(@Qualifier("clusterDataSource") DataSource clusterDataSource)
                 throws Exception {
             final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
             sessionFactory.setDataSource(clusterDataSource);
             sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
                     .getResources(ClusterDataSourceConfig.MAPPER_LOCATION));
             return sessionFactory.getObject();
         }
    }

5.，其他mapper配置和dao编写省略。  
6.,测试：

*  向city表中插入数据，数据应该插入到springbootdb2中：

![这里写图片描述][SouthEast 1]

![这里写图片描述][SouthEast 2]

--------------------

*  查询userList应该能查出数据，因为springbootdb有user表  
    ![这里写图片描述][SouthEast 3]

测试成功。

源码：[http://download.csdn.net/download/u012343297/10163397][http_download.csdn.net_download_u012343297_10163397]

[SouthEast]: /images/20220603/b4988fade190416aa4bd93b5ba3adb5d.png
[SouthEast 1]: /images/20220603/3c8274e738d24820ad8c7ab939491047.png
[SouthEast 2]: /images/20220603/f2344c3e02314331a60e4ee5c8dcb201.png
[SouthEast 3]: /images/20220603/1ed4b0e0ef4e4d3fa6ed21a71ad35ca9.png
[http_download.csdn.net_download_u012343297_10163397]: http://download.csdn.net/download/u012343297/10163397