SpringBoot配置多数据源多数据库

Springboot支持配置多数据源。默认情况，在yml文件中只会配置一个数据库。如果涉及到操作多个数据库的情况，在同实例中（即同一个ip地址下的不同数据库），可以采用数据库名点数据库表的方式，实现跨库表的操作。（database.table）但这种方式属于硬编码，如果数据库名变化意味着代码也要变化，不易维护。

下面是在springboot项目中，配置多数据源。需要添加几个配置类，和相关注解的方式，实现在某个特定方法层面下切换数据源。

1、目录结构

2、具体代码

1）DataSource

@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Inherited
public @interface DataSource {String name() default "";
}

2）DataSourceAspect

/*** 多数据源，切面处理类**/
@Aspect
@Component
@Order(Ordered.HIGHEST_PRECEDENCE)
public class DataSourceAspect implements Ordered {protected Logger logger = LoggerFactory.getLogger(getClass());@Pointcut("@annotation(io.installer.commons.dynamic.datasource.annotation.DataSource)")public void dataSourcePointCut() {}@Around("dataSourcePointCut()")public Object around(ProceedingJoinPoint point) throws Throwable {MethodSignature signature = (MethodSignature) point.getSignature();Method method = signature.getMethod();DataSource ds = method.getAnnotation(DataSource.class);if (ds == null) {DynamicDataSource.setDataSource(DataSourceNames.FIRST);logger.debug("set datasource is " + DataSourceNames.FIRST);} else {DynamicDataSource.setDataSource(ds.name());logger.debug("set datasource is " + ds.name());}try {return point.proceed();} finally {DynamicDataSource.clearDataSource();logger.debug("clean datasource");}}@Overridepublic int getOrder() {return 1;}
}

3）DataSourceNames

public interface DataSourceNames {String FIRST = "first";String SECOND = "second";
}

4）DynamicContextHolder

/*** 多数据源上下文**/
public class DynamicContextHolder {private static final ThreadLocal<Deque<String>> CONTEXT_HOLDER = ThreadLocal.withInitial(ArrayDeque::new);/*** 获得当前线程数据源** @return 数据源名称*/public static String peek() {return CONTEXT_HOLDER.get().peek();}/*** 设置当前线程数据源** @param dataSource 数据源名称*/public static void push(String dataSource) {CONTEXT_HOLDER.get().push(dataSource);}/*** 清空当前线程数据源*/public static void poll() {Deque<String> deque = CONTEXT_HOLDER.get();deque.poll();if (deque.isEmpty()) {CONTEXT_HOLDER.remove();}}}

5）DynamicDataSource

/*** 多数据源** @author Mark sunlightcs@gmail.com* @since 1.0.0*/
public class DynamicDataSource extends AbstractRoutingDataSource {private static final ThreadLocal<String> contextHolder = new ThreadLocal<>();public DynamicDataSource(DataSource defaultTargetDataSource, Map<Object, Object> targetDataSources) {//设置默认数据源super.setDefaultTargetDataSource(defaultTargetDataSource);super.setTargetDataSources(targetDataSources);super.afterPropertiesSet();}@Overrideprotected Object determineCurrentLookupKey() {//获取数据源，没有指定，则为默认数据源return getDataSource();}public static void setDataSource(String dataSource) {contextHolder.set(dataSource);}public static String getDataSource() {return contextHolder.get();}public static void clearDataSource() {contextHolder.remove();}}

6）DynamicDataSourceConfig

@Configuration
@EnableConfigurationProperties(DynamicDataSourceProperties.class)
public class DynamicDataSourceConfig {//数据源1，读取spring.datasource.druid.first下的配置信息@Bean@ConfigurationProperties("spring.datasource.druid.first")public DataSource firstDataSource() {return DruidDataSourceBuilder.create().build();}//数据源2，读取spring.datasource.druid.second下的配置信息@Bean@ConfigurationProperties("spring.datasource.druid.second")public DataSource secondDataSource() {return DruidDataSourceBuilder.create().build();}//加了@Primary注解，表示指定DynamicDataSource为Spring的数据源//因为DynamicDataSource是继承与AbstractRoutingDataSource，而AbstractR//outingDataSource又是继承于AbstractDataSource，AbstractDataSource实现了统一//的DataSource接口，所以DynamicDataSource也可以当做DataSource使用@Bean@Primarypublic DynamicDataSource dataSource(DataSource firstDataSource, DataSource secondDataSource) {Map<Object, Object> targetDataSources = new HashMap<>();targetDataSources.put(DataSourceNames.FIRST, firstDataSource);targetDataSources.put(DataSourceNames.SECOND, secondDataSource);return new DynamicDataSource(firstDataSource, targetDataSources);}
}

7）DynamicDataSourceFactory

public class DynamicDataSourceFactory {public static DruidDataSource buildDruidDataSource(DataSourceProperties properties) {DruidDataSource druidDataSource = new DruidDataSource();druidDataSource.setDriverClassName(properties.getDriverClassName());druidDataSource.setUrl(properties.getUrl());druidDataSource.setUsername(properties.getUsername());druidDataSource.setPassword(properties.getPassword());druidDataSource.setInitialSize(properties.getInitialSize());druidDataSource.setMaxActive(properties.getMaxActive());druidDataSource.setMinIdle(properties.getMinIdle());druidDataSource.setMaxWait(properties.getMaxWait());druidDataSource.setTimeBetweenEvictionRunsMillis(properties.getTimeBetweenEvictionRunsMillis());druidDataSource.setMinEvictableIdleTimeMillis(properties.getMinEvictableIdleTimeMillis());druidDataSource.setMaxEvictableIdleTimeMillis(properties.getMaxEvictableIdleTimeMillis());druidDataSource.setValidationQuery(properties.getValidationQuery());druidDataSource.setValidationQueryTimeout(properties.getValidationQueryTimeout());druidDataSource.setTestOnBorrow(properties.isTestOnBorrow());druidDataSource.setTestOnReturn(properties.isTestOnReturn());druidDataSource.setPoolPreparedStatements(properties.isPoolPreparedStatements());druidDataSource.setMaxOpenPreparedStatements(properties.getMaxOpenPreparedStatements());druidDataSource.setSharePreparedStatements(properties.isSharePreparedStatements());try {// druidDataSource.setFilters(properties.getFilters());druidDataSource.init();} catch (SQLException e) {e.printStackTrace();}return druidDataSource;}
}

8）DataSourceProperties

public class DataSourceProperties {private String driverClassName;private String url;private String username;private String password;/*** Druid默认参数*/private int initialSize = 2;private int maxActive = 10;private int minIdle = -1;private long maxWait = 60 * 1000L;private long timeBetweenEvictionRunsMillis = 60 * 1000L;private long minEvictableIdleTimeMillis = 1000L * 60L * 30L;private long maxEvictableIdleTimeMillis = 1000L * 60L * 60L * 7;private String validationQuery = "select 1";private int validationQueryTimeout = -1;private boolean testOnBorrow = false;private boolean testOnReturn = false;private boolean testWhileIdle = true;private boolean poolPreparedStatements = false;private int maxOpenPreparedStatements = -1;private boolean sharePreparedStatements = false;private String filters = "stat,wall";public String getDriverClassName() {return driverClassName;}public void setDriverClassName(String driverClassName) {this.driverClassName = driverClassName;}public String getUrl() {return url;}public void setUrl(String url) {this.url = url;}public String getUsername() {return username;}public void setUsername(String username) {this.username = username;}public String getPassword() {return password;}public void setPassword(String password) {this.password = password;}public int getInitialSize() {return initialSize;}public void setInitialSize(int initialSize) {this.initialSize = initialSize;}public int getMaxActive() {return maxActive;}public void setMaxActive(int maxActive) {this.maxActive = maxActive;}public int getMinIdle() {return minIdle;}public void setMinIdle(int minIdle) {this.minIdle = minIdle;}public long getMaxWait() {return maxWait;}public void setMaxWait(long maxWait) {this.maxWait = maxWait;}public long getTimeBetweenEvictionRunsMillis() {return timeBetweenEvictionRunsMillis;}public void setTimeBetweenEvictionRunsMillis(long timeBetweenEvictionRunsMillis) {this.timeBetweenEvictionRunsMillis = timeBetweenEvictionRunsMillis;}public long getMinEvictableIdleTimeMillis() {return minEvictableIdleTimeMillis;}public void setMinEvictableIdleTimeMillis(long minEvictableIdleTimeMillis) {this.minEvictableIdleTimeMillis = minEvictableIdleTimeMillis;}public long getMaxEvictableIdleTimeMillis() {return maxEvictableIdleTimeMillis;}public void setMaxEvictableIdleTimeMillis(long maxEvictableIdleTimeMillis) {this.maxEvictableIdleTimeMillis = maxEvictableIdleTimeMillis;}public String getValidationQuery() {return validationQuery;}public void setValidationQuery(String validationQuery) {this.validationQuery = validationQuery;}public int getValidationQueryTimeout() {return validationQueryTimeout;}public void setValidationQueryTimeout(int validationQueryTimeout) {this.validationQueryTimeout = validationQueryTimeout;}public boolean isTestOnBorrow() {return testOnBorrow;}public void setTestOnBorrow(boolean testOnBorrow) {this.testOnBorrow = testOnBorrow;}public boolean isTestOnReturn() {return testOnReturn;}public void setTestOnReturn(boolean testOnReturn) {this.testOnReturn = testOnReturn;}public boolean isTestWhileIdle() {return testWhileIdle;}public void setTestWhileIdle(boolean testWhileIdle) {this.testWhileIdle = testWhileIdle;}public boolean isPoolPreparedStatements() {return poolPreparedStatements;}public void setPoolPreparedStatements(boolean poolPreparedStatements) {this.poolPreparedStatements = poolPreparedStatements;}public int getMaxOpenPreparedStatements() {return maxOpenPreparedStatements;}public void setMaxOpenPreparedStatements(int maxOpenPreparedStatements) {this.maxOpenPreparedStatements = maxOpenPreparedStatements;}public boolean isSharePreparedStatements() {return sharePreparedStatements;}public void setSharePreparedStatements(boolean sharePreparedStatements) {this.sharePreparedStatements = sharePreparedStatements;}public String getFilters() {return filters;}public void setFilters(String filters) {this.filters = filters;}
}

9）DynamicDataSourceProperties

@ConfigurationProperties(prefix = "dynamic")
public class DynamicDataSourceProperties {private Map<String, DataSourceProperties> datasource = new LinkedHashMap<>();public Map<String, DataSourceProperties> getDatasource() {return datasource;}public void setDatasource(Map<String, DataSourceProperties> datasource) {this.datasource = datasource;}
}

10）yml配置

spring:datasource:type: com.alibaba.druid.pool.DruidDataSourcedruid:first:#MySQLurl: jdbc:mysql://localhost:3306/database1?useSSL=false&useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&transformedBitIsBoolean=true&serverTimezone=GMT%2B8username: rootpassword: rootsecond:#MySQLurl: jdbc:mysql://localhost:3306/database2?useSSL=false&useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&transformedBitIsBoolean=true&serverTimezone=GMT%2B8username: rootpassword: rootdriver-class-name: com.mysql.cj.jdbc.Driverinitial-size: 10max-active: 100min-idle: 10max-wait: 6000pool-prepared-statements: truemax-pool-prepared-statement-per-connection-size: 20time-between-eviction-runs-millis: 60000min-evictable-idle-time-millis: 300000#Oracle需要打开注释#      validation-query: SELECT 1 FROM DUALtest-while-idle: truetest-on-borrow: falsetest-on-return: falsestat-view-servlet:enabled: trueurl-pattern: /druid/*

3、测试代码

1）DynamicDataSourceTestService

/*** 测试多数据源** @author Mark sunlightcs@gmail.com*/
@Service
//@DataSource(name = DataSourceNames.FIRST)
public class DynamicDataSourceTestService {@Resourceprivate SysUserDao sysUserDao;//@Transactionalpublic void updateUser(Long id) {SysUserEntity user = new SysUserEntity();user.setId(id);user.setMobile("13500000000");//sysUserDao.updateById(user);System.out.println(sysUserDao.selectById(id));}@DataSource(name = DataSourceNames.SECOND)@Transactionalpublic void updateUserBySlave1(Long id) {SysUserEntity user = new SysUserEntity();user.setId(id);user.setMobile("13500000001");//sysUserDao.updateById(user);System.out.println(sysUserDao.selectById(id));}//    @DataSource(name = DataSourceNames.SECOND)
//    @Transactional
//    public void updateUserBySlave2(Long id){
//        SysUserEntity user = new SysUserEntity();
//        user.setId(id);
//        user.setMobile("13500000002");
//        sysUserDao.updateById(user);
//
//        //测试事物
//        int i = 1/0;
//    }
}

2）DynamicDataSourceTest

@RunWith(SpringRunner.class)
@SpringBootTest
public class DynamicDataSourceTest {@Resourceprivate DynamicDataSourceTestService dynamicDataSourceTestService;@Testpublic void test() {Long id = 1067246875800000001L;//        dynamicDataSourceTestService.updateUser(id);
//        dynamicDataSourceTestService.updateUserBySlave1(id);dynamicDataSourceTestService.updateUserBySlave2(id);}}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如若转载，请注明出处：http://www.pswp.cn/pingmian/90647.shtml
繁体地址，请注明出处：http://hk.pswp.cn/pingmian/90647.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Rocky9.4部署Zabbix7

Rocky9.4部署Zabbix7

一、配置安装源 rpm -Uvh https://repo.zabbix.com/zabbix/7.0/rocky/9/x86_64/zabbix-release-7.0-5.el9.noarch.rpm ​ yum clean all 二、安装Zabbix server&#xff0c;Web前端&#xff0c;agent yum install zabbix-server-mysql zabbix-web-mysql zabbix-nginx-conf z…
阅读更多...
【Java】对象类型转换(ClassCastException)异常：从底层原理到架构级防御，老司机的实战经验

【Java】对象类型转换(ClassCastException)异常：从底层原理到架构级防御，老司机的实战经验

在开发中&#xff0c;ClassCastException&#xff08;类转换异常&#xff09;就像一颗隐藏的定时炸弹&#xff0c;常常在代码运行到类型转换逻辑时突然爆发。线上排查问题时&#xff0c;这类异常往往因为类型关系复杂而难以定位。多数开发者习惯于在转换前加个instanceof判断就…
阅读更多...
探路者：用 AI 面试加速人才集结，为户外爱好者带来更专业的服务

探路者：用 AI 面试加速人才集结，为户外爱好者带来更专业的服务

作为深耕户外用品领域的知名品牌&#xff0c;探路者已构建起覆盖全国的销售服务网络&#xff0c;上千品种的产品矩阵更是为品牌在市场中站稳脚跟提供了有力支撑。对探路者来说&#xff0c;要持续为户外爱好者带来专业且贴心的体验&#xff0c;专业人才是核心支撑。然而&#xf…
阅读更多...
LeetCode——面试题 05.01 插入

LeetCode——面试题 05.01 插入

通过万岁&#xff01;&#xff01;&#xff01; 题目&#xff1a;一共会给四个数&#xff0c;分别是N、M、i、j&#xff0c;然后希望我们把N和M抓怒换为2进制以后&#xff0c;将M的二进制放在i到j之间的区域&#xff0c;如果M的二进制长度小于i-j1&#xff0c;则前面补0即可。最…
阅读更多...
前端设计中如何在鼠标悬浮时同步修改块内样式

前端设计中如何在鼠标悬浮时同步修改块内样式

虽然只是一个小问题&#xff0c;但这个解决问题的过程也深化了自己对盒子模型的理解问题缘起正在写一个登录注册的小窗口&#xff0c;想要在鼠标悬浮阶段让按钮和文字都变色&#xff0c;但是发现实操的时候按钮和文字没办法同时变色鼠标悬停前鼠标悬停后问题分析仔细分析了下该…
阅读更多...
航空发动机高速旋转件的非接触式信号传输系统

航空发动机高速旋转件的非接触式信号传输系统

航空发动机是飞机动力系统的核心&#xff0c;各种关键部件如涡轮、压气机等&#xff0c;经常处于极端高温、高速旋转的工作环境中。航空发动机内的传感器数据&#xff0c;如何能够稳定可靠的通过无线的方式传输到检测太&#xff0c;一直是业内的一个难点和痛点。在这个领域&…
阅读更多...
【postgresql按照逗号分割字段，并统计数量和求和】

【postgresql按照逗号分割字段，并统计数量和求和】

postgresql按照逗号分割字段&#xff0c;并统计数量和求和postgresql按照逗号分割字段&#xff0c;并统计数量和求和postgresql按照逗号分割字段&#xff0c;并统计数量和求和 SELECT ucd, p ,tm, step, unitcd, tm_end from resource_calc_scene_rain_bound_value_plus whe…
阅读更多...
「iOS」————继承链与对象的结构

「iOS」————继承链与对象的结构

iOS学习前言对象的底层结构isa的类型isa_tobjc_class & objc_object类信息的静态与动态存储&#xff08;ro、rw、rwe机制&#xff09;cachebits继承链isKindOfClass和isMemberOfClassisKindOfClass:isMemberofClass前言 对 对象底层结构的相关信息有点遗忘&#xff0c;简略…
阅读更多...
代码随想录day46dp13

代码随想录day46dp13

647. 回文子串 题目链接 文章讲解 回溯法 class Solution { public:int count 0;// 检查字符串是否是回文bool isPalindrome(string& s, int start, int end) {while (start < end) {if (s[start] ! s[end]) return false;start;end--;}return true;}// 回溯法&#…
阅读更多...
学习随笔录

学习随笔录

#61 学习随笔录 今日的思考 &#xff1a; 反思一下学习效率低下 不自律 或者 惰性思维 懒得思考 又或者 好高婺远 顶级自律从不靠任何意志力&#xff0c;而在于「平静如水的野心」_哔哩哔哩_bilibili 然后上面是心灵鸡汤合集 vlog #79&#xff5c;程序员远程办公的一天…
阅读更多...
python-函数进阶、容器通用方法、字符串比大小（笔记）

python-函数进阶、容器通用方法、字符串比大小（笔记）

python数据容器的通用方法#记住排序后容器类型会变成list容器列表 list[1,3,5,4,6,7] newListsorted(list,reverseTrue) print(newList) [7, 6, 5, 4, 3, 1]list[1,3,5,4,6,7] newListsorted(list,reverseFalse) print(newList) [1, 3, 4, 5, 6, 7]字典排序的是字典的key字符串…
阅读更多...
关闭chrome自带的跨域限制,简化本地开发

关闭chrome自带的跨域限制,简化本地开发

在开发时为了图方便,简化本地开发,懒得去后端配置允许跨域,那就可以用此方法1. 右键桌面上的Chrome浏览器图标&#xff0c;选择“创建快捷方式”到桌面。2. 在新创建的快捷方式的图标上右键&#xff0c;选择“属性”。3. 在弹出窗口中的“目标”栏中追加&#xff1a; --allow-r…
阅读更多...
C++___快速入门(上)

C++___快速入门(上)

第一个C程序#include<iostream> using namespace std; int main() {cout << "hello world !" << endl;return 0; }上边的代码就是用来打印字符串 “hello world !” 的&#xff0c;可见&#xff0c;与C语言还是有很大的差别的&#xff0c;接下来我…
阅读更多...
构建企业级Docker日志驱动：将容器日志无缝发送到腾讯云CLS

构建企业级Docker日志驱动：将容器日志无缝发送到腾讯云CLS

源码地址：https://github.com/k8scat/docker-log-driver-tencent-cls 在现代云原生架构中，容器化应用已经成为主流部署方式。随着容器数量的快速增长，如何高效地收集、存储和分析容器日志成为了一个关键挑战。传统的日志收集方式往往存在以下问题： 日志分散在各个容器中，难…
阅读更多...
Kafka——消费者组重平衡能避免吗？

Kafka——消费者组重平衡能避免吗？

引言 其实在消费者组到底是什么&#xff1f;中&#xff0c;我们讲过重平衡&#xff0c;也就是Rebalance&#xff0c;现在先来回顾一下这个概念的原理和用途。它是Kafka实现消费者组&#xff08;Consumer Group&#xff09;弹性伸缩和容错能力的核心机制&#xff0c;却也常常成…
阅读更多...
使用爬虫获取游戏的iframe地址

使用爬虫获取游戏的iframe地址

如何通过爬虫获取游戏的iframe地址要获取网页中嵌入的游戏的iframe地址&#xff08;即iframe元素的src属性&#xff09;&#xff0c;您可以使用网络爬虫技术。iframe是HTML元素&#xff0c;用于在当前页面中嵌入另一个文档&#xff08;如游戏页面&#xff09;&#xff0c;其地址…
阅读更多...
NTLite Ent Version

NTLite Ent Version

NTLite是一款专业的系统安装镜像制作工具&#xff0c;通过这款软件可以帮助用户快速生成镜像文件打好补丁&#xff0c;很多朋友在安装电脑系统的时候一般都安装了windows系统的所有Windows组件&#xff0c;其实有很多Windows组件你可能都用到不到&#xff0c;不如在安装系统时就…
阅读更多...
Maven之依赖管理

Maven之依赖管理

Maven之依赖管理一、Maven依赖管理的核心价值二、依赖的基本配置&#xff08;坐标与范围&#xff09;2.1 依赖坐标&#xff08;GAV&#xff09;2.2 依赖范围&#xff08;scope&#xff09;示例&#xff1a;常用依赖范围配置三、依赖传递与冲突解决3.1 依赖传递性示例&#xff1…
阅读更多...
【Unity实战100例】Unity资源下载系统开发流程详解（移动端、PC端 ，局域网控制台服务）

【Unity实战100例】Unity资源下载系统开发流程详解（移动端、PC端 ，局域网控制台服务）

目录 一、项目概述 二、服务器开发 1、配置文件设计 1、加载配置 2. 处理客户端请求 3. 文件下载处理 三、客户端开发 1、配置管理 1、配置加载与保存 2、下载任务管理 1、任务类设计 2、下载队列管理 3、核心下载流程 四、UI系统实现 五、部署与测试 1、服务…
阅读更多...
[Python] -进阶理解7- Python中的内存管理机制简析

[Python] -进阶理解7- Python中的内存管理机制简析

Python（尤其是 CPython）采用自动内存管理机制，核心包括引用计数（Reference Counting）与垃圾回收机制（Garbage Collection），并配合专门的内存池和分配器机制来提升效率与减少碎片。 这套机制隐藏在开发者视线之外，Python 开发者无需手动申请或释放内存。 二、Python 内…
阅读更多...
最新文章

Copyright @ 2022~2023