通过识别方法注解，自动切换主备数据源DynamicDataSource

y806839048

浏览: 1108180 次
性别:
来自: 上海

最近访客更多访客>>

Jamnsin

mengqingyu

一往无前bhz

VeChar

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

2019-12 ( 14)
2019-11 ( 18)
2019-10 ( 29)
更多存档...

博客分类：

data

data

org.springframework.jdbc.datasource.lookup，数据库主备配置

mysql.properties：

crm.jdbc.driverClassName=com.mysql.jdbc.Driver

crm.jdbc.url=jdbc:mysql://10.100.163.77:3306/financial_sales_prod?useUnicode=true&characterEncoding=utf-8

crm.jdbc.username=telsale/-pl

crm.jdbc.password=0OKM

crm.dbcp.initialSize=5

crm.dbcp.minIdle=5

crm.dbcp.maxActive=20

crm.dbcp.maxWait=10000

crm.dbcp.timeBetweenEvictionRunsMillis=60000

crm.dbcp.minEvictableIdleTimeMillis=300000

crm.dbcp.testWhileIdle=true

crm.dbcp.testOnBorrow=true

crm.dbcp.testOnReturn=false

crm.dbcp.poolPreparedStatements=true

crm.dbcp.maxPoolPreparedStatementPerConnectionSize=20

bigdata.jdbc.driverClassName=com.mysql.jdbc.Driver

bigdata.jdbc.url=jdbc:mysql://10.100.163.78:3306/financial_sales_prod?useUnicode=true&characterEncoding=utf-8

bigdata.jdbc.username=telsale/-pl

bigdata.jdbc.password=0OKM

bigdata.dbcp.initialSize=5

bigdata.dbcp.minIdle=5

bigdata.dbcp.maxActive=20

bigdata.dbcp.maxWait=10000

bigdata.dbcp.timeBetweenEvictionRunsMillis=60000

bigdata.dbcp.minEvictableIdleTimeMillis=300000

bigdata.dbcp.testWhileIdle=true

bigdata.dbcp.testOnBorrow=true

bigdata.dbcp.testOnReturn=false

bigdata.dbcp.poolPreparedStatements=true

bigdata.dbcp.maxPoolPreparedStatementPerConnectionSize=20

applicationContext-dao.xml：

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xmlns:context="http://www.springframework.org/schema/context"

xmlns:tx="http://www.springframework.org/schema/tx"

xmlns:aop="http://www.springframework.org/schema/aop"

xmlns="http://www.springframework.org/schema/beans"

xsi:schemaLocation="

http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd

http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd

http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd

http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd">

<bean id="crm_dataSource" class="com.alibaba.druid.pool.DruidDataSource"

init-method="init" destroy-method="close">

<property name="maxPoolPreparedStatementPerConnectionSize"

value="${crm.dbcp.maxPoolPreparedStatementPerConnectionSize}"/>

<!-- <property name="proxyFilters">

<list>

</list>

</property> -->

</bean>

<bean id="bigdata_dataSource" class="com.alibaba.druid.pool.DruidDataSource"

init-method="init" destroy-method="close">

<property name="maxPoolPreparedStatementPerConnectionSize"

value="${bigdata.dbcp.maxPoolPreparedStatementPerConnectionSize}"/>

<list>

</list>

</property>

</bean>

</bean>

<map>

<entry key="crm_dataSource" value-ref="crm_dataSource" /> //两个数据源

</map>

</property>

<property name="defaultTargetDataSource" ref="crm_dataSource" /> //主库

</bean>

<array>

<value>classpath*:mapper/*.xml</value>

<value>classpath*:WorkProcessorMapper/*.xml</value>

</array>

</property>

</bean>

</bean>

<bean id="dataSourceAspect" class="com.houbank.incoming.dao.datasource.DynamicDataSourceAspect" /> //切面配置

<bean id="transactionManager"

class="org.springframework.jdbc.datasource.DataSourceTransactionManager">

</bean>

<tx:annotation-driven/>

<tx:advice id="txAdvice" transaction-manager="transactionManager">

<tx:attributes>

<tx:method name="delete*" propagation="REQUIRED" read-only="false" rollback-for="java.lang.Exception"/>

<tx:method name="remove*" propagation="REQUIRED" read-only="false" rollback-for="java.lang.Exception"/>

<tx:method name="insert*" propagation="REQUIRED" read-only="false" rollback-for="java.lang.Exception"/>

<tx:method name="add*" propagation="REQUIRED" read-only="false" rollback-for="java.lang.Exception"/>

<tx:method name="update*" propagation="REQUIRED" read-only="false" rollback-for="java.lang.Exception"/>

<tx:method name="save*" propagation="REQUIRED" read-only="false" rollback-for="java.lang.Exception"/>

<tx:method name="submit*" propagation="REQUIRED" read-only="false" rollback-for="java.lang.Exception"/>

<tx:method name="newTrans*" propagation="REQUIRES_NEW" read-only="false"

rollback-for="java.lang.Exception"/>

<tx:method name="modify*" propagation="REQUIRED" read-only="false" rollback-for="java.lang.Exception"/>

<tx:method name="find*" propagation="SUPPORTS" read-only="true"/>

<tx:method name="get*" propagation="SUPPORTS" read-only="true"/>

<tx:method name="select*" propagation="SUPPORTS" read-only="true"/>

<tx:method name="query*" propagation="SUPPORTS" read-only="true"/>

</tx:attributes>

</tx:advice>

<aop:config>

<aop:pointcut id="servicePointCut"

expression="execution(public * com.houbank.incoming.service.*.*(..))"/>

<aop:advisor pointcut-ref="servicePointCut" advice-ref="txAdvice"/>

<aop:advisor advice-ref="dataSourceAspect" pointcut-ref="servicePointCut" order="1" />

</aop:config>

</beans>

java:

自定义数据源：

package com.houbank.incoming.dao.datasource;

import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;

import javax.sql.DataSource;

/**

* Created by xiaogaoxu on 2016/8/25.

public class DynamicDataSource extends AbstractRoutingDataSource {

@Override

protected Object determineCurrentLookupKey() {

return DatasourceHold.getDBType();

}

@Override

public DataSource determineTargetDataSource() {

return super.determineTargetDataSource();

}

自定义数据源切面：

package com.houbank.incoming.dao.datasource;

import java.lang.reflect.Method;

import org.springframework.aop.AfterReturningAdvice;

import org.springframework.aop.MethodBeforeAdvice;

/**

* Created by xiaogaoxu on 2016/8/25.

public class DynamicDataSourceAspect implements MethodBeforeAdvice, AfterReturningAdvice {

@Override

public void afterReturning(Object returnValue, Method method,

Object[] args, Object target) throws Throwable {

DatasourceHold.clearDBType();

}

@Override

public void before(Method method, Object[] args, Object target)

throws Throwable {

if (method.isAnnotationPresent(DataSource.class)) { //这里通过方法的注解区分哪些方式使用哪种数据库，大数据查询的专门使用查询的库

DataSource datasource = method.getAnnotation(DataSource.class);

DatasourceHold.setDBType(datasource.name());

} else {

DatasourceHold.clearDBType();

}

package com.houbank.incoming.dao.datasource;

import java.lang.annotation.ElementType;

import java.lang.annotation.Retention;

import java.lang.annotation.RetentionPolicy;

import java.lang.annotation.Target;

@Retention(RetentionPolicy.RUNTIME)

@Target(ElementType.METHOD)

public @interface DataSource {

/**

* CRM系统的主数据源系统默认

String CRM_DATASOURCE = "crm_dataSource";

/**

* 大数据的数据源只读同步数据

String BIGDATA_DATASOURCE = "bigdata_dataSource";

String name();

}

mybatis采用的是多数据源配置

crm_dataSource CRM系统的主数据源
bigdata_dataSource 大数据的数据源 只读同步数据

示例：
@DataSource(name = DataSource.BIGDATA_DATASOURCE)
   public List<TagFilterRel> selectByCondition(TagFilterRel rel) {
           return tagFilterRelMapper.selectByCondition(rel);
       }

mybatis数据源及事务配置见applicationContext-dao.xml

data.rar (183.7 KB)
下载次数: 0

分享到：