Spring 的动态数据源实现

时间 2019-12-01

标签 spring 动态数据实现栏目 Spring 繁體版

原文原文链接

1. 配置多个数据源spring

这里以两个c3p0数据库链接池的数据源做为实例。在Spring框架下使用c3p0的数据库须要加入c3p0-0.9.1.2.jar(如今最新的)这个支持包。这里以数据同步项目为例：sql

数据来源库的链接池数据源配置：数据库

Xml代码

<bean id="dataSourceFrom" class="com.mchange.v2.c3p0.ComboPooledDataSource">
<property name="driverClass" value="${jdbc.driver}" />
<property name="jdbcUrl" value="${jdbc.from.url}" />
<property name="user" value="${jdbc.from.username}" />
<property name="password" value="${jdbc.from.password}" />
<property name="autoCommitOnClose" value="true" />
<property name="checkoutTimeout" value="${cpool.checkoutTimeout}" />
<property name="initialPoolSize" value="${cpool.minPoolSize}" />
<property name="minPoolSize" value="${cpool.minPoolSize}" />
<property name="maxPoolSize" value="${cpool.maxPoolSize}" />
<property name="maxIdleTime" value="${cpool.maxIdleTime}" />
<property name="acquireIncrement" value="${cpool.acquireIncrement}" />
<property name="maxIdleTimeExcessConnections" value="${cpool.maxIdleTimeExcessConnections}" />
</bean>

数据插入库的链接池数据源配置：安全

Xml代码

<bean id="dataSourceTo" class="com.mchange.v2.c3p0.ComboPooledDataSource">
<property name="driverClass" value="${jdbc.driver}" />
<property name="jdbcUrl" value="${jdbc.to.url}" />
<property name="user" value="${jdbc.to.username}" />
<property name="password" value="${jdbc.to.password}" />
<property name="autoCommitOnClose" value="true" />
<property name="checkoutTimeout" value="${cpool.checkoutTimeout}" />
<property name="initialPoolSize" value="${cpool.minPoolSize}" />
<property name="minPoolSize" value="${cpool.minPoolSize}" />
<property name="maxPoolSize" value="${cpool.maxPoolSize}" />
<property name="maxIdleTime" value="${cpool.maxIdleTime}" />
<property name="acquireIncrement" value="${cpool.acquireIncrement}" />
<property name="maxIdleTimeExcessConnections" value="${cpool.maxIdleTimeExcessConnections}" />
</bean>

注意：上面url，user，password等值是从classpath下的jdbc.properties中取得的。session

经过Spring获取属性文件中的值，以供配置文件使用：app

Xml代码

<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="locations" value="classpath:jdbc.properties" />
</bean>

2. 扩展Spring的AbstractRoutingDataSource抽象类，实现动态数据源。框架

AbstractRoutingDataSource中的抽象方法determineCurrentLookupKey是实现数据源的route的核心.这里对该方法进行Override。xss

Java代码

public class DynamicDataSource extends AbstractRoutingDataSource{
@Override
protected Object determineCurrentLookupKey() {
return DBContextHolder.getDBType();
}
}

上下文DbContextHolder为一线程安全的ThreadLocal，具体代码以下：ide

Java代码

public class DBContextHolder{
public static final String DATA_SOURCE_FROM = "dataSourceFrom";
public static final String DATA_SOURCE_TO = "dataSourceTo";
private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>();
public static void setDBType(String dbType) {
contextHolder.set(dbType);
}
public static String getDBType() {
return contextHolder.get();
}
public static void clearDBType() {
contextHolder.remove();
}
}

3.配置动态数据源ui

将DynamicDataSource Bean加入到Spring的上下文xml配置文件中去，同时配置DynamicDataSource的targetDataSources(多数据源目标)属性的Map映射。

Xml代码

<bean id="dynamicDataSource" class="datasource.DynamicDataSource" >
<property name="targetDataSources">
<map>
<entry value-ref="dataSourceFrom" key="dataSourceFrom"></entry>
<entry value-ref="dataSourceTo" key="dataSourceTo"></entry>
</map>
</property>
<property name="defaultTargetDataSource" ref="dataSourceFrom" />
</bean>

4.使用动态数据源

例子中DynamicDataSource是继承与AbstractRoutingDataSource，而AbstractRoutingDataSource又是继承于org.springframework.jdbc.datasource.AbstractDataSource，AbstractDataSource实现了统一的DataSource接口，因此DynamicDataSource一样能够当一个DataSource使用。

在Spring的JdbcTemplate使用动态数据源的配置示例：

Xml代码

<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource">
<ref bean="dynamicDataSource" />
</property>
</bean>
<bean id="sqlBaseDAO" class="com.whty.dao.BaseDAOImpl">
<property name="jdbcTemplate">
<ref bean="jdbcTemplate" />
</property>
</bean>

在ORM框架Hibernate中的使用配置示例：

Xml代码

<bean id="sessionFactory" class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
<property name="dataSource" ref="dynamicDataSource" />
<property name="configLocations" value="classpath:hibernate.cfg.xml" />
<property name="hibernateProperties">
<props>
<prop key="hibernate.dialect">${hibernate.dialect}</prop>
</property>
</bean>

5.事务管理

使用动态数据源的时候，能够看出和使用单数据源的时候相比，在使用配置上几乎没有差异，在进行性事务管理配置的时候也没有差异：

使用Spring的JdbcTemplate的事务管理配置示例：

Xml代码

<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dynamicDataSource" />
</bean>
<bean id="sqlBaseDAOProxy" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
<property name="transactionManager" ref="transactionManager" />
<property name="target" ref="sqlBaseDAO" />
<property name="transactionAttributes">
<props>
<prop key="insert*">PROPAGATION_REQUIRED</prop>
<prop key="*">PROPAGATION_REQUIRED,readOnly</prop>
</props>
</property>
</bean>

使用Hibernate时的事务管理配置示例：

Xml代码

<tx:annotation-driven transaction-manager="transactionManager"/>
<bean id="transactionManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager">
<property name="sessionFactory" ref="sessionFactory" />
</bean>

6.动态数据源的管理控制

如何选择控制每一个业务中须要的具体数据源，但是使用手动控制：

Java代码

ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
BaseDAO dao = (BaseDAO) context.getBean("sqlBaseDAO", BaseDAOImpl.class);
try {
DBContextHolder.setCustomerType(DBContextHolder.DATA_SOURCE_FROM);
System.err.println(dao.select("select count(*) sum from TEST t ").get(0).get("SUM"));
DBContextHolder.setCustomerType(DBContextHolder.DATA_SOURCE_TO);
System.err.println(dao.select("select count(*) sum from TEST t ").get(0).get("SUM"));
} catch (Exception e) {
e.printStackTrace();
}

也能够采用AOP的控制方式：

Java代码

@Aspect
public class DynamicDataSourceAspect {
@Pointcut("execution (public service.impl..*.*(..))")
public void serviceExecution(){}
@Before("serviceExecution()")
public void setDynamicDataSource(JoinPoint jp) {
for(Object o : jp.getArgs()) {
//处理具体的逻辑，根据具体的境况CustomerContextHolder.setCustomerType()选取DataSource
}
}
}

7.总结

经过扩展Spring的AbstractRoutingDataSource能够很好的实现多数据源的rout效果，并且对扩展更多的数据源有良好的伸缩性，只要增长数据源和修改DynamicDataSource的targetDataSources属性配置就好。在数据源选择控制上，能够采用手动控制(业务逻辑并很少的时候)，也能够很好的用AOP的@Aspect在Service的入口加入一个切面@Pointcut，在@Before里判断JoinPoint的类容选定特定的数据源。