使用SpringBoot配置多數(shù)據(jù)源的經(jīng)驗(yàn)分享
1. 引入jar包
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>
2. properties配置
分別準(zhǔn)備兩個數(shù)據(jù)源
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
3. 分別配置兩個數(shù)據(jù)源
第一個數(shù)據(jù)源
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();
}
}
第二個數(shù)據(jù)源
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();
}
}
4. Dao目錄
為了區(qū)分兩個數(shù)據(jù)源,分別設(shè)置了不同的目錄
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();
}
5. Entity
package com.multi.datasource.entity;
import lombok.Data;
@Data
public class UserEntity {
private String userName;
}
6. Mapper文件
從my1數(shù)據(jù)源查詢
<?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數(shù)據(jù)源查詢
<?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>
7. Controller測試
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);
}
}
兩個數(shù)據(jù)源,對應(yīng)的user_name分別是zhangsan和lisi


8. 結(jié)果驗(yàn)證
訪問 http://localhost:18888/query,結(jié)果如下

到此這篇關(guān)于使用SpringBoot配置多數(shù)據(jù)源的經(jīng)驗(yàn)分享的文章就介紹到這了,更多相關(guān)SpringBoot配置多數(shù)據(jù)源內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
- SpringBoot多數(shù)據(jù)源配置并通過注解實(shí)現(xiàn)動態(tài)切換數(shù)據(jù)源
- SpringBoot多數(shù)據(jù)源讀寫分離的自定義配置問題及解決方法
- spring注解 @PropertySource配置數(shù)據(jù)源全流程
- springboot配置多個數(shù)據(jù)源兩種方式實(shí)現(xiàn)
- Spring配置數(shù)據(jù)源的三種方式(小結(jié))
- 解決springboot項(xiàng)目不配置數(shù)據(jù)源啟動報錯問題
- springboot整合多數(shù)據(jù)源配置方式
- Spring配置數(shù)據(jù)源流程與作用詳解
相關(guān)文章
Java把數(shù)字格式化為貨幣字符串實(shí)例代碼
這篇文章主要介紹了Java把數(shù)字格式化為貨幣字符串實(shí)例代碼,需要的朋友可以參考下2014-02-02
spring boot actuator監(jiān)控超詳細(xì)教程
Spring Boot Actuator就是一款可以幫助你監(jiān)控系統(tǒng)數(shù)據(jù)的框架,其可以監(jiān)控很多很多的系統(tǒng)數(shù)據(jù),接下來通過本文給大家介紹spring boot actuator監(jiān)控超詳細(xì)教程,感興趣的朋友一起看看吧2021-10-10
SpringBoot自定義FailureAnalyzer詳解
這篇文章主要介紹了SpringBoot自定義FailureAnalyzer詳解,FailureAnalyzer是一種在啟動時攔截?exception?并將其轉(zhuǎn)換為?human-readable?消息的好方法,包含在故障分析中,需要的朋友可以參考下2023-11-11
詳解SpringBoot注冊Windows服務(wù)和啟動報錯的原因
這篇文章主要介紹了詳解SpringBoot注冊Windows服務(wù)和啟動報錯的原因,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧2019-03-03

