使用SpringBoot配置多数据源的经验分享

<?xml version= "1.0" encoding= "UTF-8" ?>

<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 https://maven.apache.org/xsd/maven-4.0.0.xsd" >

     <modelVersion> 4.0 . 0 </modelVersion>

     <parent>

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

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

         <version> 2.5 . 6 </version>

         <relativePath/> <!-- lookup parent from repository -->

     </parent>

     <groupId>com.multi.datasource</groupId>

     <artifactId>demo</artifactId>

     <version> 0.0 . 1 -SNAPSHOT</version>

     <name>demo</name>

     <description>Demo project for Spring Boot</description>

     <properties>

         <java.version> 1.8 </java.version>

     </properties>

     <dependencies>

         <dependency>

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

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

         </dependency>

         <dependency>

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

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

         </dependency>

         <dependency>

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

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

             <version> 1.3 . 2 </version>

         </dependency>

         <dependency>

             <groupId>com.alibaba</groupId>

             <artifactId>druid</artifactId>

             <version> 1.1 . 8 </version>

         </dependency>

         <dependency>

             <groupId>mysql</groupId>

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

         </dependency>

         <dependency>

             <groupId>org.projectlombok</groupId>

             <artifactId>lombok</artifactId>

             <version> 1.16 . 22 </version>

         </dependency>

         <dependency>

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

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

             <scope>test</scope>

         </dependency>

     </dependencies>

     <build>

         <plugins>

             <plugin>

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

                 <artifactId>spring-boot-maven-plugin</artifactId>

                 <configuration>

                     <excludes>

                         <exclude>

                             <groupId>org.projectlombok</groupId>

                             <artifactId>lombok</artifactId>

                         </exclude>

                     </excludes>

                 </configuration>

             </plugin>

         </plugins>

     </build>

</project>

server.port= 18888

mybatis.mapper-locations=classpath:mapper/*.xml

my1.datasource.url=jdbc:mysql: //10.0.0.125:3306/wyl?autoReconnect=true

my1.datasource.driverClassName=com.mysql.cj.jdbc.Driver

my1.datasource.username=root

my1.datasource.password= 123456

my2.datasource.url=jdbc:mysql: //10.0.0.160:3306/wyl?autoReconnect=true

my2.datasource.driverClassName=com.mysql.cj.jdbc.Driver

my2.datasource.username=root

my2.datasource.password= 123456

package com.multi.datasource.config;

import com.alibaba.druid.pool.DruidDataSource;

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 javax.sql.DataSource;

@Configuration

@MapperScan (basePackages = My1DataSourceConfig.PACKAGE, sqlSessionFactoryRef = "my1SqlSessionFactory" )

public class My1DataSourceConfig {

     static final String PACKAGE = "com.multi.datasource.dao.my1" ;

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

     @Value ( "${my1.datasource.url}" )

     private String url;

     @Value ( "${my1.datasource.username}" )

     private String user;

     @Value ( "${my1.datasource.password}" )

     private String password;

     @Value ( "${my1.datasource.driverClassName}" )

     private String driverClass;

     @Bean (name = "my1DataSource" )

     public DataSource my1DataSource() {

         DruidDataSource dataSource = new DruidDataSource();

         dataSource.setDriverClassName(driverClass);

         dataSource.setUrl(url);

         dataSource.setUsername(user);

         dataSource.setPassword(password);

         dataSource.setMaxWait(Integer.MAX_VALUE);

         dataSource.setTestOnBorrow( true );

         dataSource.setTestOnReturn( true );

         dataSource.setTestWhileIdle( true );

         return dataSource;

     }

     @Bean (name = "my1TransactionManager" )

     public DataSourceTransactionManager my1TransactionManager() {

         return new DataSourceTransactionManager(my1DataSource());

     }

     @Bean (name = "my1SqlSessionFactory" )

     public SqlSessionFactory my1SqlSessionFactory( @Qualifier ( "my1DataSource" ) DataSource my1DataSource)

             throws Exception {

         final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();

         sessionFactory.setDataSource(my1DataSource);

         sessionFactory.setMapperLocations(

                 new PathMatchingResourcePatternResolver().getResources(My1DataSourceConfig.MAPPER_LOCATION));

         return sessionFactory.getObject();

     }

}

package com.multi.datasource.config;

import com.alibaba.druid.pool.DruidDataSource;

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 javax.sql.DataSource;

@Configuration

@MapperScan (basePackages = My1DataSourceConfig.PACKAGE, sqlSessionFactoryRef = "my1SqlSessionFactory" )

public class My1DataSourceConfig {

     static final String PACKAGE = "com.multi.datasource.dao.my1" ;

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

     @Value ( "${my1.datasource.url}" )

     private String url;

     @Value ( "${my1.datasource.username}" )

     private String user;

     @Value ( "${my1.datasource.password}" )

     private String password;

     @Value ( "${my1.datasource.driverClassName}" )

     private String driverClass;

     @Bean (name = "my1DataSource" )

     public DataSource my1DataSource() {

         DruidDataSource dataSource = new DruidDataSource();

         dataSource.setDriverClassName(driverClass);

         dataSource.setUrl(url);

         dataSource.setUsername(user);

         dataSource.setPassword(password);

         dataSource.setMaxWait(Integer.MAX_VALUE);

         dataSource.setTestOnBorrow( true );

         dataSource.setTestOnReturn( true );

         dataSource.setTestWhileIdle( true );

         return dataSource;

     }

     @Bean (name = "my1TransactionManager" )

     public DataSourceTransactionManager my1TransactionManager() {

         return new DataSourceTransactionManager(my1DataSource());

     }

     @Bean (name = "my1SqlSessionFactory" )

     public SqlSessionFactory my1SqlSessionFactory( @Qualifier ( "my1DataSource" ) DataSource my1DataSource)

             throws Exception {

         final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();

         sessionFactory.setDataSource(my1DataSource);

         sessionFactory.setMapperLocations(

                 new PathMatchingResourcePatternResolver().getResources(My1DataSourceConfig.MAPPER_LOCATION));

         return sessionFactory.getObject();

     }

}

package com.multi.datasource.dao.my1;

import com.multi.datasource.entity.UserEntity;

import org.apache.ibatis.annotations.Mapper;

@Mapper

public interface Test1Mapper {

     UserEntity query();

}

package com.multi.datasource.dao.my2;

import com.multi.datasource.entity.UserEntity;

import org.apache.ibatis.annotations.Mapper;

@Mapper

public interface Test2Mapper {

     UserEntity query();

}

package com.multi.datasource.entity;

import lombok.Data;

@Data

public class UserEntity {

     private String userName;

}

<? xml version = "1.0" encoding = "UTF-8" ?>

         <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">

< mapper namespace = "com.multi.datasource.dao.my1.Test1Mapper" >

< select id = "query" resultType = "com.multi.datasource.entity.UserEntity" >

         select user_name as userName from t_user

     </ select >

</ mapper >

<? xml version = "1.0" encoding = "UTF-8" ?>

<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">

< mapper namespace = "com.multi.datasource.dao.my2.Test2Mapper" >

     < select id = "query" resultType = "com.multi.datasource.entity.UserEntity" >

         select user_name as userName from t_user

     </ select >

</ mapper >

package com.multi.datasource.controller;

import com.multi.datasource.dao.my1.Test1Mapper;

import com.multi.datasource.dao.my2.Test2Mapper;

import com.multi.datasource.entity.UserEntity;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

@RestController

public class TestController {

     @Resource

     private Test1Mapper test1Mapper;

     @Resource

     private Test2Mapper test2Mapper;

     @RequestMapping ( "query" )

     public void query() {

         UserEntity user1 = test1Mapper.query();

         System.out.println( "my1 dataSource:" + user1);

         UserEntity user2 = test2Mapper.query();

         System.out.println( "my2 dataSource:" + user2);

     }

}