oracle读写分离多数据源

1、配置数据源

package com.netintech.core.config;import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder;
import com.alibaba.druid.spring.boot.autoconfigure.properties.DruidStatProperties;
import com.alibaba.druid.util.Utils;
import com.netintech.common.core.utils.SpringUtils;
import com.netintech.core.aspectj.lang.enums.DataSourceType;
import com.netintech.core.config.properties.DruidProperties;
import com.netintech.core.datasource.DynamicDataSource;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.web.servlet.FilterRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;import javax.servlet.*;
import javax.sql.DataSource;
import java.io.IOException;
import java.util.HashMap;
import java.util.Map;/*** druid 配置多数据源* * @author admin*/
@Configuration
public class DruidConfig
{@Bean@ConfigurationProperties("spring.datasource.druid.master")public DataSource masterDataSource(DruidProperties druidProperties){DruidDataSource dataSource = DruidDataSourceBuilder.create().build();return druidProperties.dataSource(dataSource);}@Bean@ConfigurationProperties("spring.datasource.druid.slave")@ConditionalOnProperty(prefix = "spring.datasource.druid.slave", name = "enabled", havingValue = "true")public DataSource slaveDataSource(DruidProperties druidProperties){DruidDataSource dataSource = DruidDataSourceBuilder.create().build();return druidProperties.dataSource(dataSource);}@Bean(name = "slave136DataSource")@ConfigurationProperties("spring.datasource.druid.slave136")@ConditionalOnProperty(prefix = "spring.datasource.druid.slave136", name = "enabled", havingValue = "true")public DataSource slave136DataSource(DruidProperties druidProperties){DruidDataSource dataSource = DruidDataSourceBuilder.create().build();return druidProperties.dataSource(dataSource);}@Bean(name = "slave110DataSource")@ConfigurationProperties("spring.datasource.druid.slave110")@ConditionalOnProperty(prefix = "spring.datasource.druid.slave110", name = "enabled", havingValue = "true")public DataSource slave110DataSource(DruidProperties druidProperties){DruidDataSource dataSource = DruidDataSourceBuilder.create().build();return druidProperties.dataSource(dataSource);}@Bean(name = "slaveGajDataSource")@ConfigurationProperties("spring.datasource.druid.slavegaj")@ConditionalOnProperty(prefix = "spring.datasource.druid.slavegaj", name = "enabled", havingValue = "true")public DataSource slaveGajDataSource(DruidProperties druidProperties) {DruidDataSource dataSource = DruidDataSourceBuilder.create().build();return druidProperties.dataSource(dataSource);}@Bean(name = "slaveZhzx36DataSource")@ConfigurationProperties("spring.datasource.druid.slavezhzx36")@ConditionalOnProperty(prefix = "spring.datasource.druid.slavezhzx36", name = "enabled", havingValue = "true")public DataSource slaveZhzx36DataSource(DruidProperties druidProperties) {DruidDataSource dataSource = DruidDataSourceBuilder.create().build();return druidProperties.dataSource(dataSource);}@Bean(name = "slaveQzdjDataSource")@ConfigurationProperties("spring.datasource.druid.slaveqzdj")@ConditionalOnProperty(prefix = "spring.datasource.druid.slaveqzdj", name = "enabled", havingValue = "true")public DataSource slaveQzdjDataSource(DruidProperties druidProperties) {DruidDataSource dataSource = DruidDataSourceBuilder.create().build();return druidProperties.dataSource(dataSource);}@Bean(name = "dynamicDataSource")@Primarypublic DynamicDataSource dataSource(DataSource masterDataSource){Map<Object, Object> targetDataSources = new HashMap<>();targetDataSources.put(DataSourceType.MASTER.name(), masterDataSource);setDataSource(targetDataSources, DataSourceType.SLAVE.name(), "slaveDataSource");setDataSource(targetDataSources, DataSourceType.SLAVE136.name(), "slave136DataSource");setDataSource(targetDataSources, DataSourceType.SLAVE110.name(), "slave110DataSource");setDataSource(targetDataSources, DataSourceType.SLAVEGAJ.name(), "slaveGajDataSource");setDataSource(targetDataSources, DataSourceType.SLAVEZHZX36.name(), "slaveZhzx36DataSource");setDataSource(targetDataSources, DataSourceType.SLAVEQZDJ.name(), "slaveQzdjDataSource");return new DynamicDataSource(masterDataSource, targetDataSources);}/*** 设置数据源* * @param targetDataSources 备选数据源集合* @param sourceName 数据源名称* @param beanName bean名称*/public void setDataSource(Map<Object, Object> targetDataSources, String sourceName, String beanName){try{DataSource dataSource = SpringUtils.getBean(beanName);targetDataSources.put(sourceName, dataSource);}catch (Exception e){}}/*** 去除监控页面底部的广告*/@SuppressWarnings({ "rawtypes", "unchecked" })@Bean@ConditionalOnProperty(name = "spring.datasource.druid.statViewServlet.enabled", havingValue = "true")public FilterRegistrationBean removeDruidFilterRegistrationBean(DruidStatProperties properties){// 获取web监控页面的参数DruidStatProperties.StatViewServlet config = properties.getStatViewServlet();// 提取common.js的配置路径String pattern = config.getUrlPattern() != null ? config.getUrlPattern() : "/druid/*";String commonJsPattern = pattern.replaceAll("\\*", "js/common.js");final String filePath = "support/http/resources/js/common.js";// 创建filter进行过滤Filter filter = new Filter(){@Overridepublic void init(javax.servlet.FilterConfig filterConfig) throws ServletException{}@Overridepublic void doFilter(ServletRequest request, ServletResponse response, FilterChain chain)throws IOException, ServletException{chain.doFilter(request, response);// 重置缓冲区，响应头不会被重置response.resetBuffer();// 获取common.jsString text = Utils.readFromResource(filePath);// 正则替换banner, 除去底部的广告信息text = text.replaceAll("<a.*?banner\"></a><br/>", "");text = text.replaceAll("powered.*?shrek.wang</a>", "");response.getWriter().write(text);}@Overridepublic void destroy(){}};FilterRegistrationBean registrationBean = new FilterRegistrationBean();registrationBean.setFilter(filter);registrationBean.addUrlPatterns(commonJsPattern);return registrationBean;}
}

2、创建枚举类

package com.netintech.core.aspectj.lang.enums;/*** 数据源* * @author admin*/
public enum DataSourceType
{/*** 主库*/MASTER,/*** 从库*/SLAVE,/*** 从库(136 网格在线)*/SLAVE136,/*** 从库(对接110)*/SLAVE110,/*** 公安局*/SLAVEGAJ,/*** 从库(指挥中心)*/SLAVEZHZX36,/*** 从库(中间表区镇对接)*/SLAVEQZDJ}

3、创建多数据源切换注解

package com.netintech.core.aspectj.lang.annotation;import com.netintech.core.aspectj.lang.enums.DataSourceType;import java.lang.annotation.*;/*** 自定义多数据源切换注解* * @author admin*/
@Target({ ElementType.METHOD, ElementType.TYPE })
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Inherited
public @interface DataSource
{/*** 切换数据源名称*/public DataSourceType value() default DataSourceType.MASTER;
}

4、数据源注解配置

package com.netintech.core.aspectj;import com.netintech.common.core.utils.StringUtils;
import com.netintech.core.aspectj.lang.annotation.DataSource;
import com.netintech.core.datasource.DynamicDataSourceContextHolder;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.aspectj.lang.reflect.MethodSignature;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;import java.lang.reflect.Method;/*** 多数据源处理* * @author admin*/
@Aspect
@Order(1)
@Component
public class DataSourceAspect
{protected Logger logger = LoggerFactory.getLogger(getClass());@Pointcut("@annotation(com.netintech.core.aspectj.lang.annotation.DataSource)"+ "|| @within(com.netintech.core.aspectj.lang.annotation.DataSource)")public void dsPointCut(){}@Around("dsPointCut()")public Object around(ProceedingJoinPoint point) throws Throwable{DataSource dataSource = getDataSource(point);if (StringUtils.isNotNull(dataSource)){DynamicDataSourceContextHolder.setDataSourceType(dataSource.value().name());}try{return point.proceed();}finally{// 销毁数据源 在执行方法之后DynamicDataSourceContextHolder.clearDataSourceType();}}/*** 获取需要切换的数据源*/public DataSource getDataSource(ProceedingJoinPoint point){MethodSignature signature = (MethodSignature) point.getSignature();Method method = signature.getMethod();DataSource dataSource = method.getAnnotation(DataSource.class);Class<? extends Object> targetClass = point.getTarget().getClass();DataSource targetDataSource = targetClass.getAnnotation(DataSource.class);if (StringUtils.isNotNull(dataSource)){return dataSource;}else{return targetDataSource;}}
}

5、数据库配置

spring:redis:host: 172.6.1.1port: 6379password: Netma213123rch@2022#datasource:type: com.alibaba.druid.pool.DruidDataSourcedriver-class-name: oracle.jdbc.OracleDriverdruid:# 主库数据源master: url: jdbc:oracle:thin:@1.1.1.3:1521/zhzxusername: KSSHZL_GDpassword: Netma1231rch_2022## 从库数据源slave:# 从数据源开关/默认关闭enabled: trueurl: jdbc:oracle:thin:@17.1.1.3:1521/zhzxusername: KSSHZL_OPERENTIONpassword: Netm1231arch_2022## 136slave136:enabled: trueurl: jdbc:oracle:thin:@17.1.9.1:1521:orclusername: kssm_141lltpassword: kssm_lQWEQltslave110:enabled: trueurl: jdbc:oracle:thin:@2.3.3.1:7110:dsdbusername: hxeQEQcspassword: dsdSXADb#2021# gajslavegaj:enabled: truedriver-class-name: com.mysql.jdbc.Driverurl: jdbc:mysql://2.36.25.162:3306/ks_shzlxdhzhzhzx_push?useUnicode=true&characterEncoding=utf-8&character_set_client=utf8mb4&useSSL=false&serverTimezone=Asia/Shanghaiusername: ks_shzlxdhzhzQWEQhzxpassword: Ks@Sh231zl!QAZ2wsxconnectionInitSqls: set names utf8mb4;# zhzx36slavezhzx36:# 从数据源开关/默认关闭enabled: trueurl: jdbc:oracle:thin:@17.1.19.35:1521/zhzxusername: KSSHZLWEACSZ_GDpassword: Netmar1132ch_2022## 初始连接数initialSize: 5# 最小连接池数量minIdle: 10# 最大连接池数量maxActive: 20# 配置获取连接等待超时的时间maxWait: 60000# 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒timeBetweenEvictionRunsMillis: 60000# 配置一个连接在池中最小生存的时间，单位是毫秒minEvictableIdleTimeMillis: 300000# 配置一个连接在池中最大生存的时间，单位是毫秒maxEvictableIdleTimeMillis: 900000# 配置检测连接是否有效validationQuery: SELECT 1 FROM DUALtestWhileIdle: truetestOnBorrow: falsetestOnReturn: falsewebStatFilter:enabled: truestatViewServlet:enabled: true# 设置白名单，不填则允许所有访问allow:url-pattern: /druid/*# 控制台管理用户名和密码login-username:login-password:filter:stat:enabled: true# 慢SQL记录log-slow-sql: trueslow-sql-millis: 1000merge-sql: falsewall:config:multi-statement-allow: true

6、注解切换数据源

package com.netintech.bussiness.mapper.gaj;import com.netintech.api.domain.operationsystemapplication.workflow.domain.GdJbxxCommon;
import com.netintech.api.domain.operationsystemapplication.workflow.gaj.GajCaseHfResult;
import com.netintech.api.domain.operationsystemapplication.workflow.gaj.GajCaseInfo;
import com.netintech.api.domain.operationsystemapplication.workflow.gaj.GajCaseResult;
import com.netintech.api.domain.operationsystemapplication.workflow.gaj.GajCaseVisit;
import com.netintech.core.aspectj.lang.annotation.DataSource;
import com.netintech.core.aspectj.lang.enums.DataSourceType;
import org.apache.ibatis.annotations.Param;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;import java.util.List;/*** @author: lh* @CreateDate: 2023/3/16 16:31  lh* @UpdateBy:* @UpdateDate:* @Description:* @Group 政法组*/
public interface GajCaseMapper {@DataSource(value = DataSourceType.SLAVEZHZX36)@Transactional(propagation = Propagation.NOT_SUPPORTED)List<GdJbxxCommon> getCaseInfo();@DataSource(value = DataSourceType.SLAVEZHZX36)@Transactional(propagation = Propagation.NOT_SUPPORTED)List<GdJbxxCommon> getCaseResult(@Param(value = "bjStatus") String bjStatus);@DataSource(value = DataSourceType.SLAVEZHZX36)@Transactional(propagation = Propagation.NOT_SUPPORTED)List<GajCaseHfResult> getCaseVisit();@DataSource(value = DataSourceType.SLAVEZHZX36)@Transactional(propagation = Propagation.NOT_SUPPORTED)int testSlave36();@DataSource(value = DataSourceType.SLAVE)@Transactional(propagation = Propagation.NOT_SUPPORTED)int testSlave();int testSlave36_2();@DataSource(value = DataSourceType.SLAVE)@Transactional(propagation = Propagation.NOT_SUPPORTED)int updateSlave36();}

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

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

相关文章

springboot基础(82):分布式定时任务解决方案shedlock

springboot基础(82):分布式定时任务解决方案shedlock

文章目录 前言简介shedlock dbSchedulerLock注解说明 shedlock redis遇到的问题1.配置shedlock不生效 前言 多节点或者多服务器拥有相同的定时任务&#xff0c;这种情况下&#xff0c;不同节点的相同定时任务会被重复执行。如何解决分布式定时任务重复执行问题&#xff1f;此…
阅读更多...
fpga_cpu加速

fpga_cpu加速

一 cpu流水线执行指令 二 计算机体系结构 注&#xff1a;ARM就是典型的哈佛结构 三 cpu加速 同样采用流水线&#xff0c;哈佛结构的指令效率更高&#xff0c;通过指令预取&#xff0c;提高了流水线的并行度。
阅读更多...
【初中生讲机器学习】11. 回归算法中常用的模型评价指标有哪些？here!

【初中生讲机器学习】11. 回归算法中常用的模型评价指标有哪些？here!

创建时间&#xff1a;2024-02-19 最后编辑时间&#xff1a;2024-02-23 作者&#xff1a;Geeker_LStar 你好呀~这里是 Geeker_LStar 的人工智能学习专栏&#xff0c;很高兴遇见你~ 我是 Geeker_LStar&#xff0c;一名初三学生&#xff0c;热爱计算机和数学&#xff0c;我们一起加…
阅读更多...
有趣且重要的JS知识合集（19）前端实现图片的本地上传/截取/导出

有趣且重要的JS知识合集（19）前端实现图片的本地上传/截取/导出

input[file]太丑了&#xff0c;又不想去改button样式&#xff0c;那就自己实现一个上传按钮的div&#xff0c;然后点击此按钮时&#xff0c;去触发file上传的事件, 以下就是 原生js实现图片前端上传 并且按照最佳宽高比例展示图片&#xff0c;然后可以自定义截取图片&#xff0…
阅读更多...
ChatGpt的初步认知(认知搬运工)

ChatGpt的初步认知(认知搬运工)

前言 ChatGpt火了有一段时间了&#xff0c;对各行各业也有了一定的渗透&#xff0c;当然发展过程中也做了一些安全约束&#xff0c;今天主要是来跟大家分享下关于chatGpt的初步认知。 一、chatGpt是什么&#xff1f; ChatGPT&#xff0c;全称聊天生成预训练转换器&#xff08;英…
阅读更多...
X-Rhodamine maleimide ，ROX 马来酰亚胺，实验室常用的荧光染料

X-Rhodamine maleimide ，ROX 马来酰亚胺，实验室常用的荧光染料

您好&#xff0c;欢迎来到新研之家 文章关键词&#xff1a;X-Rhodamine maleimide &#xff0c;X-Rhodamine mal&#xff0c;ROX-maleimide&#xff0c;ROX 马来酰亚胺 一、基本信息 【产品简介】&#xff1a;ROX, also known as Rhodamine 101, is a product whose active …
阅读更多...
使用ffmpeg实现视频片段截取并保持清晰度

使用ffmpeg实现视频片段截取并保持清晰度

1 原始视频信息 通过ffmpeg -i命令查看视频基本信息 ffmpeg -i input.mp4 ffmpeg version 6.1-essentials_build-www.gyan.dev Copyright (c) 2000-2023 the FFmpeg developersbuilt with gcc 12.2.0 (Rev10, Built by MSYS2 project)configuration: --enable-gpl --enable-ve…
阅读更多...
算法沉淀——FloodFill 算法（leetcode真题剖析）

算法沉淀——FloodFill 算法（leetcode真题剖析）

算法沉淀——FloodFill 算法 01.图像渲染02.岛屿数量03.岛屿的最大面积04.被围绕的区域05.太平洋大西洋水流问题06.扫雷游戏07.衣橱整理 Flood Fill&#xff08;泛洪填充&#xff09;算法是一种图像处理的基本算法&#xff0c;用于填充连通区域。该算法通常从一个种子点开始&am…
阅读更多...
nginx基础模块配置详解

nginx基础模块配置详解

目录 一、Nginx相关配置 1、nginx配置文件 2、nginx模块 二、nginx全局配置 1、关闭版本或修改版本 1.1 关闭版本 1.2 修改版本 2、修改nginx启动的子进程数 3、cpu与worker进程绑定 4、PID路径 5、nginx进程的优先级 6、调试worker进程打开文件的个数 7、nginx服…
阅读更多...
Linux命令-chcon命令（修改对象（文件）的安全上下文）

Linux命令-chcon命令（修改对象（文件）的安全上下文）

说明 chcon命令 是修改对象&#xff08;文件&#xff09;的安全上下文&#xff0c;比如&#xff1a;用户、角色、类型、安全级别。也就是将每个文件的安全环境变更至指定环境。使用 --reference 选项时&#xff0c;把指定文件的安全环境设置为与参考文件相同。chcon命令位于 /…
阅读更多...
【Java程序设计】【C00288】基于Springboot的篮球竞赛预约平台（有论文）

【Java程序设计】【C00288】基于Springboot的篮球竞赛预约平台（有论文）

基于Springboot的篮球竞赛预约平台&#xff08;有论文&#xff09; 项目简介项目获取开发环境项目技术运行截图 项目简介 这是一个基于Springboot的篮球竞赛预约平台 本系统分为前台功能模块、管理员功能模块以及用户功能模块。 前台功能模块&#xff1a;用户进入到平台首页&a…
阅读更多...
解释 C++ 中的拷贝构造函数和赋值运算符重载，并指出它们之间的区别。

解释 C++ 中的拷贝构造函数和赋值运算符重载，并指出它们之间的区别。

解释 C 中的拷贝构造函数和赋值运算符重载&#xff0c;并指出它们之间的区别。 拷贝构造函数和赋值运算符重载是 C 中用于实现对象拷贝的两种重要成员函数。它们的作用是将一个对象的值复制给另一个对象&#xff0c;但在使用方式和调用时机上有一些区别。 拷贝构造函数&#…
阅读更多...
无刷电机的2种电流采样方式以及优缺点比较

无刷电机的2种电流采样方式以及优缺点比较

低端电流采样&#xff1a; 在低端采样方式中&#xff0c;电流检测电阻&#xff08;分流电阻&#xff09;通常被放置在逆变器下桥臂MOSFET或IGBT的低端&#xff0c;即靠近电机绕组的地线侧。这种情况下&#xff0c;只有当对应相位的下管导通时&#xff0c;才能通过这个电阻来测量…
阅读更多...
C++基础入门（省略版本）（黑马笔记）

C++基础入门（省略版本）（黑马笔记）

C基础入门&#xff08;部分省略&#xff09; 数据类型 整型 数据类型占用空间取值范围short2字节(-215-215-1)int4字节(-231-231-1)longWindows为4字节&#xff0c;Linux为4字节(32位)&#xff0c;8字节(64位)(-231-231-1)long long8字节(-263-263-1) 浮点型 数据类型占用…
阅读更多...
【刷题记录】链表的回文结构

【刷题记录】链表的回文结构

本系列博客为个人刷题思路分享&#xff0c;有需要借鉴即可。 1.题目链接&#xff1a; LINK 2.详解思路&#xff1a; 思路&#xff1a;思路&#xff1a;先找到中间节点&#xff0c;然后逆置后半部分链表&#xff0c;一个指针指向链表的头节点&#xff0c;再一个指针指向逆置的头…
阅读更多...
深度学习介绍与环境搭建

深度学习介绍与环境搭建

深度学习介绍与环境搭建 慕课大学人工智能学习笔记&#xff0c;自己学习记录用的。&#xff08;赋上连接&#xff09; https://www.icourse163.org/learn/ZUCC-1206146808?tid1471365447#/learn/content?typedetail&id1256424053&cid1289366515人工智能、机器学习与…
阅读更多...
【工具类】阿里域名关联ip(python版)

【工具类】阿里域名关联ip(python版)

获取代码如下 # codingutf-8import argparse import json import urllib import logging# 加载 ali 核心 SDK from aliyunsdkcore.client import AcsClient from aliyunsdkalidns.request.v20150109 import (DescribeSubDomainRecordsRequest,AddDomainRecordRequest,UpdateDo…
阅读更多...
Java 序列化与反序列化的原理

Java 序列化与反序列化的原理

在Java中&#xff0c;序列化&#xff08;Serialization&#xff09;是将对象转换为字节流的过程&#xff0c;而反序列化&#xff08;Deserialization&#xff09;是将字节流转换回对象的过程。这种机制允许对象在网络上传输或在磁盘上持久化存储。 序列化的原理 标记接口 Ja…
阅读更多...
用nginx正向代理https网站

用nginx正向代理https网站

目录 1. 缘起2. 部署nginx3. 测试3.1 http测试3.2 https测试4 给centos设置代理访问外网 1. 缘起 最近碰到了一个麻烦事情&#xff0c;就是公司的centos测试服务器放在内网环境&#xff0c;而且不能直接上外网&#xff0c;导致无法通过yum安装软件&#xff0c;非常捉急。   幸…
阅读更多...
QPaint绘制自定义仪表盘组件02

QPaint绘制自定义仪表盘组件02

网上视频抄的&#xff0c;用来自己看一下&#xff0c;看完就删掉 最终效果 ui&#xff0c;创建一个空的widget widget.h #ifndef WIDGET_H #define WIDGET_H#include <QWidget> #include <QPainter> #include <QTimer>QT_BEGIN_NAMESPACE namespace Ui { c…
阅读更多...
最新文章

Copyright @ 2022~2023