使用SpringBoot配置多數(shù)據(jù)源的經驗分享
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配置
分別準備兩個數(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ù)源,分別設置了不同的目錄
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ù)源,對應的user_name
分別是zhangsan和lisi
8. 結果驗證
訪問 http://localhost:18888/query
,結果如下
到此這篇關于使用SpringBoot配置多數(shù)據(jù)源的經驗分享的文章就介紹到這了,更多相關SpringBoot配置多數(shù)據(jù)源內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
spring boot actuator監(jiān)控超詳細教程
Spring Boot Actuator就是一款可以幫助你監(jiān)控系統(tǒng)數(shù)據(jù)的框架,其可以監(jiān)控很多很多的系統(tǒng)數(shù)據(jù),接下來通過本文給大家介紹spring boot actuator監(jiān)控超詳細教程,感興趣的朋友一起看看吧2021-10-10SpringBoot自定義FailureAnalyzer詳解
這篇文章主要介紹了SpringBoot自定義FailureAnalyzer詳解,FailureAnalyzer是一種在啟動時攔截?exception?并將其轉換為?human-readable?消息的好方法,包含在故障分析中,需要的朋友可以參考下2023-11-11詳解SpringBoot注冊Windows服務和啟動報錯的原因
這篇文章主要介紹了詳解SpringBoot注冊Windows服務和啟動報錯的原因,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧2019-03-03