文章詳情頁

Spring-基于Spring使用自定義注解及Aspect實現(xiàn)數(shù)據(jù)庫切換操作

瀏覽：95日期：2023-08-13 11:44:07

實現(xiàn)思路

重寫Spring的AbstractRoutingDataSource抽象類的determineCurrentLookupKey方法。

我們來看下Spring-AbstractRoutingDataSource的源碼

AbstractRoutingDataSource獲取數(shù)據(jù)源之前會先調(diào)用determineCurrentLookupKey方法查找當(dāng)前的lookupKey。

Object lookupKey = determineCurrentLookupKey();DataSource dataSource = this.resolvedDataSources.get(lookupKey);.......return dataSource;

lookupKey為數(shù)據(jù)源標(biāo)識，因此通過重寫這個查找數(shù)據(jù)源標(biāo)識的方法就可以讓spring切換到指定的數(shù)據(jù)源.

從變量定義中可以知道resolvedDataSources為Map類型的對象。

private Map<Object, DataSource> resolvedDataSources;

示例

Spring-基于Spring使用自定義注解及Aspect實現(xiàn)數(shù)據(jù)庫切換操作

步驟一新建Maven工程

依賴如下： pom.xml

<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 http://maven.apache.org/xsd/maven-4.0.0.xsd'><modelVersion>4.0.0</modelVersion><groupId>com.artisan</groupId><artifactId>dynamicDataSource</artifactId><version>0.0.1-SNAPSHOT</version><packaging>jar</packaging><name>dynamicDataSource</name><url>http://maven.apache.org</url><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><file.encoding>UTF-8</file.encoding><spring.version>4.3.9.RELEASE</spring.version><servlet.version>3.1.0</servlet.version><aspectj.version>1.8.1</aspectj.version><commons-dbcp.version>1.4</commons-dbcp.version><jetty.version>8.1.8.v20121106</jetty.version><log4j.version>1.2.17</log4j.version><log4j2.version>2.8.2</log4j2.version><testng.version>6.8.7</testng.version><oracle.version>11.2.0.4.0</oracle.version><jstl.version>1.2</jstl.version></properties><dependencies><dependency><groupId>org.springframework</groupId><artifactId>spring-beans</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-context</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-context-support</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-jdbc</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-webmvc</artifactId><version>${spring.version}</version></dependency><dependency><groupId>commons-dbcp</groupId><artifactId>commons-dbcp</artifactId><version>${commons-dbcp.version}</version></dependency><dependency><groupId>org.aspectj</groupId><artifactId>aspectjweaver</artifactId><version>${aspectj.version}</version></dependency><dependency><groupId>org.testng</groupId><artifactId>testng</artifactId><version>${testng.version}</version><scope>test</scope></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-test</artifactId><version>${spring.version}</version><scope>test</scope></dependency><dependency><groupId>com.oracle</groupId><artifactId>ojdbc6</artifactId><version>${oracle.version}</version></dependency><dependency><groupId>org.testng</groupId><artifactId>testng</artifactId><version>${testng.version}</version><scope>test</scope></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-test</artifactId><version>${spring.version}</version><scope>test</scope></dependency><dependency><groupId>org.apache.logging.log4j</groupId><artifactId>log4j-api</artifactId><version>${log4j2.version}</version></dependency><dependency><groupId>org.apache.logging.log4j</groupId><artifactId>log4j-core</artifactId><version>${log4j2.version}</version></dependency></dependencies><build><plugins><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-compiler-plugin</artifactId><version>3.1</version><configuration><source>1.7</source><target>1.7</target></configuration></plugin></plugins></build></project>

步驟二 繼承AbstractRoutingDataSource并重寫determineCurrentLookupKey方法獲取特定數(shù)據(jù)源

package com.artisan.dynamicDB;import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;/** * * * @ClassName: DynamicDataSource * * @Description: * AbstractRoutingDataSource中的抽象方法determineCurrentLookupKey是實現(xiàn)數(shù)據(jù)源的route的核心 * .需要重寫該方法 * * @author: Mr.Yang * * @date: 2017年7月24日下午8:28:46 */public class DynamicDataSource extends AbstractRoutingDataSource {@Overrideprotected Object determineCurrentLookupKey() {return DynamicDataSourceHolder.getDataSource();}}

步驟三 創(chuàng)建DynamicDataSourceHolder用于持有當(dāng)前線程中使用的數(shù)據(jù)源標(biāo)識

package com.artisan.dynamicDB;/** * * * @ClassName: DynamicDataSourceHolder * * @Description:創(chuàng)建DynamicDataSourceHolder用于持有當(dāng)前線程中使用的數(shù)據(jù)源標(biāo)識 * * @author: Mr.Yang * * @date: 2017年7月24日下午8:23:50 */public class DynamicDataSourceHolder { /** * 數(shù)據(jù)源標(biāo)識保存在線程變量中，避免多線程操作數(shù)據(jù)源時互相干擾 */ private static final ThreadLocal<String> dataSourceHolder = new ThreadLocal<String>(); /** * * * @Title: setDataSource * * @Description: 設(shè)置數(shù)據(jù)源 * * @param dataSource * * @return: void */ public static void setDataSource(String dataSource) { dataSourceHolder.set(dataSource); } /** * * * @Title: getDataSource * * @Description: 獲取數(shù)據(jù)源 * * @return * * @return: String */ public static String getDataSource() { return dataSourceHolder.get(); } /** * * * @Title: clearDataSource * * @Description: 清除數(shù)據(jù)源 * * * @return: void */ public static void clearDataSource() { dataSourceHolder.remove(); }}

步驟四 配置多個數(shù)據(jù)源和DynamicDataSource的bean

<?xml version='1.0' encoding='UTF-8' ?><beans xmlns='http://www.springframework.org/schema/beans' xmlns:xsi='http://www.w3.org/2001/XMLSchema-instance' xmlns:p='http://www.springframework.org/schema/p' xmlns:context='http://www.springframework.org/schema/context' xmlns:aop='http://www.springframework.org/schema/aop' xmlns:tx='http://www.springframework.org/schema/tx' xmlns:util='http://www.springframework.org/schema/util' xsi:schemaLocation='http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util.xsd'>  <context:component-scan base-package='com.artisan'/>  <context:property-placeholder location='classpath:jdbc.properties' />   <bean destroy-method='close' p:driverClassName='${jdbc.driverClassNamePR}' p:url='${jdbc.urlPR}' p:username='${jdbc.usernamePR}' p:password='${jdbc.passwordPR}' />  <bean destroy-method='close' p:driverClassName='${jdbc.driverClassNameDR}' p:url='${jdbc.urlDR}' p:username='${jdbc.usernameDR}' p:password='${jdbc.passwordDR}' />  <bean destroy-method='close' p:driverClassName='${jdbc.driverClassNameCC}' p:url='${jdbc.urlCC}' p:username='${jdbc.usernameCC}' p:password='${jdbc.passwordCC}' /> <bean class='com.artisan.dynamicDB.DynamicDataSource'> <property name='targetDataSources' ref='dynamicDatasourceMap' />  <property name='defaultTargetDataSource' ref='dataSourcePR' /> </bean>  <util:map key-type='java.lang.String'> <entry key='dataSourcePR' value-ref='dataSourcePR' /> <entry key='dataSourceDR' value-ref='dataSourceDR' /> <entry key='dataSourceCC' value-ref='dataSourceCC' /> </util:map>  <bean p:dataSource-ref='dynamicDataSource' />  <bean /> <aop:config> <aop:aspect ref='dataSourceAspect'>  <aop:pointcut expression='execution(* com.artisan..*(..))'/> <aop:before pointcut-ref='dataSourcePointcut' method='intercept' /> </aop:aspect> </aop:config>  <bean p:dataSource-ref='dynamicDataSource' />  <aop:config proxy-target-class='true'> <aop:pointcut expression='(execution(* com.artisan..*(..))) and (@annotation(org.springframework.transaction.annotation.Transactional))' /> <aop:advisor pointcut-ref='serviceMethod' advice-ref='txAdvice' /> </aop:config> <tx:advice transaction-manager='transactionManager'> <tx:attributes> <tx:method name='*' /> </tx:attributes> </tx:advice></beans>

配置到這里，我們就可以使用多個數(shù)據(jù)源了，只需要在操作數(shù)據(jù)庫之前只要DynamicDataSourceHolder.setDataSource(“dataSourcePR”)即可切換到數(shù)據(jù)源dataSourcePR并對數(shù)據(jù)庫dataSourcePR進(jìn)行操作了。

問題：每次使用都需要調(diào)用DynamicDataSourceHolder#setDataSource，十分繁瑣，并且難以維護(hù)。

我們可以通過Spring的AOP和注解，直接通過注解的方式指定需要訪問的數(shù)據(jù)源。繼續(xù)改進(jìn)下吧

步驟五 定義名為@DataSource的注解

package com.artisan.dynamicDB;import java.lang.annotation.Documented;import java.lang.annotation.ElementType;import java.lang.annotation.Retention;import java.lang.annotation.RetentionPolicy;import java.lang.annotation.Target;/** * * * @ClassName: DataSource * * * @Description: 注解@DataSource既可以加在方法上，也可以加在接口或者接口的實現(xiàn)類上，優(yōu)先級別：方法>實現(xiàn)類>接口。 * 如果接口、接口實現(xiàn)類以及方法上分別加了@DataSource注解來指定數(shù)據(jù)源，則優(yōu)先以方法上指定的為準(zhǔn)。 * * @author: Mr.Yang * * @date: 2017年7月24日下午9:59:29 */@Target({ ElementType.METHOD, ElementType.TYPE })@Retention(RetentionPolicy.RUNTIME)@Documentedpublic @interface DataSource { // 和配置文件中 dynamicDatasourceMap中的key保持一致 public static String PR_RB = 'dataSourcePR'; public static String DR_RB = 'dataSourceDR'; public static String PR_CC = 'dataSourceCC'; /** * * * @Title: name * * @Description: 如果僅標(biāo)注@DataSource 默認(rèn)為PR_RB數(shù)據(jù)庫實例 * * @return * * @return: String */ String name() default DataSource.PR_RB;}

步驟六 定義AOP切面以便攔截所有帶有注解@DataSource的方法，取出注解的值作為數(shù)據(jù)源標(biāo)識放到DynamicDataSourceHolder的線程變量中

package com.artisan.dynamicDB;import java.lang.reflect.Method;import org.aspectj.lang.JoinPoint;import org.aspectj.lang.reflect.MethodSignature;/** * * * @ClassName: DataSourceAspect * * @Description: * 定義AOP切面以便攔截所有帶有注解@DataSource的方法，取出注解的值作為數(shù)據(jù)源標(biāo)識放到DBContextHolder的線程變量中 * * @author: Mr.Yang * * @date: 2017年7月25日上午10:51:41 */public class DataSourceAspect { /** * * * @Title: intercept * * @Description: 攔截目標(biāo)方法，獲取由@DataSource指定的數(shù)據(jù)源標(biāo)識，設(shè)置到線程存儲中以便切換數(shù)據(jù)源 * * @param point * @throws Exception * * @return: void */ public void intercept(JoinPoint point) throws Exception { Class<?> target = point.getTarget().getClass(); MethodSignature signature = (MethodSignature) point.getSignature(); // 默認(rèn)使用目標(biāo)類型的注解，如果沒有則使用其實現(xiàn)接口的注解 for (Class<?> clazz : target.getInterfaces()) { resolveDataSource(clazz, signature.getMethod()); } resolveDataSource(target, signature.getMethod()); } /** * * * @Title: resolveDataSource * * @Description: 提取目標(biāo)對象方法注解和類型注解中的數(shù)據(jù)源標(biāo)識 * * @param clazz * @param method * * @return: void */ private void resolveDataSource(Class<?> clazz, Method method) { try { Class<?>[] types = method.getParameterTypes(); // 默認(rèn)使用類型注解 if (clazz.isAnnotationPresent(DataSource.class)) { DataSource source = clazz.getAnnotation(DataSource.class); DynamicDataSourceHolder.setDataSource(source.name()); } // 方法注解可以覆蓋類型注解 Method m = clazz.getMethod(method.getName(), types); if (m != null && m.isAnnotationPresent(DataSource.class)) { DataSource source = m.getAnnotation(DataSource.class); DynamicDataSourceHolder.setDataSource(source.name()); } } catch (Exception e) { System.out.println(clazz + ':' + e.getMessage()); } }}

步驟七 在spring配置文件中配置攔截規(guī)則

<bean /> <aop:config> <aop:aspect ref='dataSourceAspect'>  <aop:pointcut expression='execution(* com.artisan..*(..))'/> <aop:before pointcut-ref='dataSourcePointcut' method='intercept' /> </aop:aspect> </aop:config>

步驟八 使用注解切換多數(shù)據(jù)源

ExtractDataService.javapackage com.artisan.extractService;import java.sql.ResultSet;import java.sql.SQLException;import org.apache.logging.log4j.LogManager;import org.apache.logging.log4j.Logger;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.jdbc.core.JdbcTemplate;import org.springframework.jdbc.core.RowCallbackHandler;import org.springframework.stereotype.Service;import com.artisan.dynamicDB.DataSource;/** * * * @ClassName: ExtractDataService * * @Description: 業(yè)務(wù)類，這里暫時作為測試多數(shù)據(jù)源切換用 * * @author: Mr.Yang * * @date: 2017年7月24日下午9:07:38 */@Servicepublic class ExtractDataService { private static final Logger logger = LogManager .getLogger(ExtractDataService.class.getName()); private JdbcTemplate jdbcTemplate; @Autowired public void setJdbcTemplate(JdbcTemplate jdbcTemplate) { this.jdbcTemplate = jdbcTemplate; } /** * * * @Title: selectDataFromPR * * @Description: * * * @return: void */ @DataSource(name = DataSource.PR_RB) public void selectDataFromPR_RB() { String sql = 'select subs_id from owe_event_charge where event_inst_id = 10229001 '; jdbcTemplate.query(sql, new RowCallbackHandler() { @Override public void processRow(ResultSet rs) throws SQLException { logger.info(rs.getInt('subs_id')); } }); } @DataSource(name = DataSource.DR_RB) public void selectDataFromDR_RB() { // 改為通過注解指定DB // DynamicDataSourceHolder.setDataSource(DBContextHolder.DATA_SOURCE_DR); String sql = ' select a.task_comments from nm_task_type a where a.task_name = ’ALARM_LOG_LEVEL’ '; jdbcTemplate.query(sql, new RowCallbackHandler() { @Override public void processRow(ResultSet rs) throws SQLException { logger.info(rs.getString('task_comments')); } }); } @DataSource(name = DataSource.PR_CC) public void selectDataFromPR_CC() { // DBContextHolder.setDataSource(DBContextHolder.DATA_SOURCE_CC); String sql = 'select acc_nbr from acc_nbr where acc_nbr_id = 82233858 '; jdbcTemplate.query(sql, new RowCallbackHandler() { @Override public void processRow(ResultSet rs) throws SQLException { logger.info(rs.getString('acc_nbr')); } }); }}

步驟九測試

package com.artisan;import java.io.IOException;import org.apache.logging.log4j.LogManager;import org.apache.logging.log4j.core.LoggerContext;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;import org.springframework.core.io.Resource;import org.springframework.core.io.ResourceLoader;import org.springframework.core.io.support.PathMatchingResourcePatternResolver;import com.artisan.extractService.ExtractDataService;/** * * * @ClassName: App * * @Description: 入口類 * * @author: Mr.Yang * * @date: 2017年7月24日下午8:50:25 */public class App { public static void main(String[] args) { try { // 加載日志框架 log4j2 LoggerContext context = (LoggerContext) LogManager .getContext(false); ResourceLoader loader = new PathMatchingResourcePatternResolver(); Resource resource = loader.getResource('classpath:log4j2.xml'); context.setConfigLocation(resource.getFile().toURI()); // 加載spring配置信息 ApplicationContext ctx = new ClassPathXmlApplicationContext( 'classpath:spring-context.xml'); // 從容器中獲取Bean ExtractDataService service = ctx.getBean('extractDataService', ExtractDataService.class); // 從PR的RB實例中獲取數(shù)據(jù) service.selectDataFromPR_RB(); // 從DR的RB實例中獲取數(shù)據(jù) service.selectDataFromDR_RB(); // 從PR的CC實例中獲取數(shù)據(jù) service.selectDataFromPR_CC(); } catch (IOException e) { e.printStackTrace(); } }}

其他代碼

log4j2.xml

<?xml version='1.0' encoding='UTF-8'?><configuration status='info' monitorInterval='180'>  <Properties> <Property name='backupFilePatch'>D:/workspace/workspace-sts/backupOracle/log/</Property> <Property name='fileName'>backupOracle.log</Property> </Properties>  <appenders>  <Console name='Console' target='SYSTEM_OUT'>  <ThresholdFilter level='trace' onMatch='ACCEPT' onMismatch='DENY' />  <PatternLayout pattern='%d{HH:mm:ss.SSS} %-5level %class{36} %L %M - %msg%xEx%n' /> </Console>  <RollingFile name='RollingFile' fileName='${backupFilePatch}${fileName}' filePattern='${backupFilePatch}$${date:yyyy-MM}/app-%d{yyyyMMddHHmmssSSS}.log.gz'> <PatternLayout pattern='%d{yyyy.MM.dd ’at’ HH:mm:ss.SSS z} %-5level %class{36} %L %M - %msg%xEx%n' />  <SizeBasedTriggeringPolicy size='20MB' />  <DefaultRolloverStrategy max='20'/> </RollingFile> </appenders>  <loggers>  <logger name='org.springframework' level='INFO'></logger> <logger name='org.mybatis' level='INFO'></logger> <root level='trace'> <appender-ref ref='RollingFile'/> <appender-ref ref='Console'/> </root> </loggers></configuration>

jdbc.properties

################################ dbcp datasource pool ,basic configuration first.## the other parameters keep default for now , you can change them if you want ###############################Database in Lapazjdbc.driverClassNamePR=oracle.jdbc.driver.OracleDriverjdbc.urlPR=jdbc:oracle:thin:@172.25.243.4:1521:xxjdbc.usernamePR=xxxjdbc.passwordPR=xxxxxxxx#Database in Scluzjdbc.driverClassNameDR=oracle.jdbc.driver.OracleDriverjdbc.urlDR=jdbc:oracle:thin:@172.25.246.1:1521:xxjdbc.usernameDR=xxxjdbc.passwordDR=xxxxxxx#Database in Lapazjdbc.driverClassNameCC=oracle.jdbc.driver.OracleDriverjdbc.urlCC=jdbc:oracle:thin:@172.25.243.3:1521:xxjdbc.usernameCC=xxxjdbc.passwordCC=xxxxxx

運(yùn)行結(jié)果：

Spring-基于Spring使用自定義注解及Aspect實現(xiàn)數(shù)據(jù)庫切換操作

代碼

https://github.com/yangshangwei/DynamicDataSource

以上這篇Spring-基于Spring使用自定義注解及Aspect實現(xiàn)數(shù)據(jù)庫切換操作就是小編分享給大家的全部內(nèi)容了，希望能給大家一個參考，也希望大家多多支持好吧啦網(wǎng)。

Spring

上一條：Spring Security 中細(xì)化權(quán)限粒度的方法下一條：spring Retryable注解實現(xiàn)重試詳解

相關(guān)文章：

1. IntelliJ IDEA創(chuàng)建web項目的方法2. ASP.NET MVC通過勾選checkbox更改select的內(nèi)容3. Python寫捕魚達(dá)人的游戲?qū)崿F(xiàn)4. Python Request類源碼實現(xiàn)方法及原理解析5. python實現(xiàn)與redis交互操作詳解6. python基礎(chǔ)之匿名函數(shù)詳解7. python numpy中setdiff1d的用法說明8. HTTP協(xié)議常用的請求頭和響應(yīng)頭響應(yīng)詳解說明（學(xué)習(xí)）9. python中的bool數(shù)組取反案例10. Python多線程實現(xiàn)支付模擬請求過程解析

排行榜

					
					IntelliJ IDEA創(chuàng)建web項目的方法
Vue+ElementUI 中級聯(lián)選擇器Bug問題的解決
利用Python實現(xiàn)Excel的文件間的數(shù)據(jù)匹配功能
java多線程CountDownLatch與線程池ThreadPoolExecutor/ExecutorService案例
python實現(xiàn)與redis交互操作詳解
淺談java中的聲明常量為什么要用static修飾
Python多線程實現(xiàn)支付模擬請求過程解析
淺談JAVA 線程狀態(tài)中可能存在的一些誤區(qū)
Python寫捕魚達(dá)人的游戲?qū)崿F(xiàn)
Django如何繼承AbstractUser擴(kuò)展字段
在vue項目中引用Antv G2,以餅圖為例講解
				