这篇文章主要介绍了怎么使用SpringBoot配置多数据源的相关知识，内容详细易懂，操作简单快捷，具有一定借鉴价值，相信大家阅读完这篇怎么使用SpringBoot配置多数据源文章都会有所收获，下面我们一起来看看吧。
pom.xml文件
<?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;
}从my1数据源查询
<?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>
从my2数据源查询
<?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);
}
}两个数据源，对应的user_name分别是zhangsan和lisi
访问 http://localhost:18888/query，结果如下
关于“怎么使用SpringBoot配置多数据源”这篇文章的内容就介绍到这里，感谢各位的阅读！相信大家对“怎么使用SpringBoot配置多数据源”知识都有一定的了解，大家如果还想学习更多知识，欢迎关注亿速云行业资讯频道。
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
