文档章节

springMVC项目-hibernate框架多数据源(切换数据库)配置

莫库什勒
 莫库什勒
发布于 2017/03/27 16:07
字数 1532
阅读 43
收藏 2

一个项目中需要用到多个数据库,那么此时关于粘合操作A数据库,操作B数据库时,就需要用到切换数据库了;

在此之前,特意百度搜索关于spring切换数据源的,主要为三个结果

1.JTA事务配置切换数据源(可保障切换数据源操作数据库不一致问题,但题主没有找到好的方法)

2.AOP拦截切换数据源(本次采用这种,事务一致的问题,头大,也在探索中)

这里说明下,有一篇文章也是基于AOP拦截,但其实采用注解的方式,可实现自动配置切换数据源的

@DataSource("dataSource2")

有兴趣的可以看文章: http://www.cnblogs.com/liujiduo/p/5004691.html ,亲测可用;

因为注解与我自身的项目不太符合,所以没有采用;

以下是我的方式: aop拦截指定模块切换数据源;

 

切换原理的话,看下图(图片源于网络)

   

    单个数据源绑定给sessionFactory,再在Dao层操作,若多个数据源的话,那不是就成了下图:

    

    可见,sessionFactory都写死在了Dao层,若我再添加个数据源的话,则又得添加一个sessionFactory。衍生出下图:

好了,下面是具体实现方式:

1.SpringApplication.xml配置(仅dataSourceBean)

<!-- 数据源公用属性 -->
	<bean id="commDataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close" >
			
		<!--连接池中保留的最小连接数。 -->
		<property name="minPoolSize">
			<value>${jdbc.pool.minPoolSize}</value>
		</property>
		<!--连接池中保留的最大连接数。Default: 15 -->
		<property name="maxPoolSize">
			<value>${jdbc.pool.maxPoolSize}</value>
		</property>
		<!--初始化时获取的连接数,取值应在minPoolSize与maxPoolSize之间。Default: 3 -->
		<property name="initialPoolSize">
			<value>${jdbc.pool.initialPoolSize}</value>
		</property>
		<!--最大空闲时间,60秒内未使用则连接被丢弃。若为0则永不丢弃。Default: 0 -->
		<property name="maxIdleTime">
			<value>60</value>
		</property>
		<!--当连接池中的连接耗尽的时候c3p0一次同时获取的连接数。Default: 3 -->
		<property name="acquireIncrement">
			<value>5</value>
		</property>
		<!--
			JDBC的标准参数,用以控制数据源内加载的PreparedStatements数量。但由于预缓存的statements
			属于单个connection而不是整个连接池。所以设置这个参数需要考虑到多方面的因素。
			如果maxStatements与maxStatementsPerConnection均为0,则缓存被关闭。Default: 0
		-->
		<property name="maxStatements">
			<value>0</value>
		</property>
		<!--每60秒检查所有连接池中的空闲连接。Default: 0 -->
		<property name="idleConnectionTestPeriod">
			<value>60</value>
		</property>
		<!--定义在从数据库获取新连接失败后重复尝试的次数。Default: 30 -->
		<property name="acquireRetryAttempts">
			<value>10</value>
		</property>
		<!--重新尝试的时间间隔,默认为:1000毫秒-->   
        <property name="acquireRetryDelay" value="1000" />  
		<!--
			获取连接失败将会引起所有等待连接池来获取连接的线程抛出异常。但是数据源仍有效
			保留,并在下次调用getConnection()的时候继续尝试获取连接。如果设为true,那么在尝试
			获取连接失败后该数据源将申明已断开并永久关闭。Default: false
		-->
		<property name="breakAfterAcquireFailure">
			<value>false</value>
		</property>
		<!--
			因性能消耗大请只在需要的时候使用它。如果设为true那么在每个connection提交的
			时候都将校验其有效性。建议使用idleConnectionTestPeriod或automaticTestTable
			等方法来提升连接测试的性能。Default: false
		-->
		<property name="testConnectionOnCheckout">
			<value>false</value>
		</property>
		<!-- 将连接放回池时异步检测连接有效性如无效则重连 -->
		<property name="testConnectionOnCheckin">
			<value>true</value>
		</property>
	</bean>
	
	<!-- 配置数据源 -->
	<bean id="dataSource1" parent="commDataSource">
		<property name="driverClass">
			<value>${jdbc.driverClassName}</value>
		</property>
		<property name="jdbcUrl">
			<value>${jdbc.url}</value>
		</property>
		<property name="user">
			<value>${jdbc.username}</value>
		</property>
		<property name="password">
			<value>${jdbc.password}</value>
		</property>
		
	</bean>
	<bean id="dataSource2" parent="commDataSource">
		<property name="driverClass">
			<value>${jdbc.driverClassName2}</value>
		</property>
		<property name="jdbcUrl">
			<value>${jdbc.url2}</value>
		</property>
		<property name="user">
			<value>${jdbc.username2}</value>
		</property>
		<property name="password">
			<value>${jdbc.password2}</value>
		</property>
	</bean>

    <bean id="dataSource" class="cn.XXX.XXX.base.datasource.DynamicDataSource">  
        <property name="targetDataSources">  
            <map key-type="java.lang.String">  
                <entry value-ref="dataSource1" key="temp1"></entry>  
                <entry value-ref="dataSource2" key="temp2"></entry>  
            </map>  
        </property>  
        <property name="defaultTargetDataSource" ref="dataSource1">  
        </property>  
    </bean>

 

sessFactory及事务和往常一样,照样注入bean

<bean id="sessionFactory" class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
		<property name="dataSource" ref="dataSource" />
		<property name="packagesToScan" value="cn.*.*.*.beans,cn.*.*.*.beans.po,cn.*.*.*.model" />
		<property name="hibernateProperties">
			<props>
				<prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop>
				<prop key="hibernate.show_sql">true</prop>
				<prop key="hibernate.autoReconnect">true</prop>
				<prop key="javax.persistence.validation.mode">none</prop>
				<!-- <prop key="hibernate.connection.autocommit">false</prop> -->
				<!--<prop key="hibernate.current_session_context_class">thread</prop>
			--></props>
		</property>
	</bean>
<!-- 事务管理器(在service层面上实现事务管理) -->
	
	<bean id="transactionManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager">
		<property name="sessionFactory" ref="sessionFactory" />
	</bean>
	<!-- 事物模板 -->
	<bean id="transactionTemplate" class="org.springframework.transaction.support.TransactionTemplate">
	    <property name="transactionManager" ref="transactionManager" />
	</bean>
	
	<bean id="hibernateTemplate" class="org.springframework.orm.hibernate3.HibernateTemplate">
		<property name="sessionFactory" ref="sessionFactory" />
	</bean>
	
	<aop:aspectj-autoproxy proxy-target-class="true"/>
	
	<!-- 注解事务支持  	-->
    <tx:annotation-driven transaction-manager="transactionManager"/> 

      
	<!-- 事务通知 -->
	<tx:advice id="txAdvice" transaction-manager="transactionManager">
		<tx:attributes>
			<tx:method name="save*" propagation="REQUIRED" isolation="DEFAULT"/>
			<tx:method name="add*" propagation="REQUIRED" isolation="DEFAULT"/>
			<tx:method name="edit*" propagation="REQUIRED" isolation="DEFAULT"/>
			<tx:method name="remove*" propagation="REQUIRED" isolation="DEFAULT"/>
			<tx:method name="*Tran"  propagation="REQUIRED" isolation="DEFAULT" />
			<tx:method name="*" propagation="REQUIRED" isolation="DEFAULT" />
		</tx:attributes>
	</tx:advice>

 

aop切入,切换数据源(这里是,扫描了user模块下切换数据库2)

 <!-- 配置事务拦截器拦截哪些类的哪些方法,一般设置成拦截Service -->
	<aop:config proxy-target-class="true">
		<aop:pointcut id="serviceMethod" expression=" execution(* cn.*.*.*.service..*.*(..)) or  execution(* cn.*.*.*.*.impl..*.*(..))" />
		<aop:advisor pointcut-ref="serviceMethod" advice-ref="txAdvice" />
	</aop:config>
	
	 <!-- 数据源切换类 -->
	<bean id="dataSourceChoose" class="cn.XXX.XXXX.datasource.DataSourceChoose" />
	<aop:config proxy-target-class="true">
		<!-- usermanager 下的方法: 指定扫码in,注入数据源yuntu -->
		<aop:pointcut id="userServiceMethod" expression=" execution(* cn.*.*.user.service..*.*(..)) or  execution(* cn.*.*.*.user.impl..*.*(..))" />
		<aop:aspect ref="dataSourceChoose" order="1">
			<aop:before method="before" pointcut-ref="userServiceMethod"  />
			<aop:after method="after" pointcut-ref="userServiceMethod"  />
		</aop:aspect>
	</aop:config>

4.DataSourceChoose.java 切换数据源

 temp2 :即xml>dataSource的key

import org.aspectj.lang.JoinPoint;
import org.springframework.stereotype.Component;
@Component
public class DataSourceChoose {
	public void before(JoinPoint jp){
		String methodName = jp.getSignature().getName();
        System.out.println("(扫描指定模块方法,切入user数据源):"+methodName);
        DatabaseContextHolder.setCustomerType("temp2");
    }
	
	public void after(){
		DatabaseContextHolder.clearCustomerType();
        System.out.println("切换user数据源完毕,清除数据源,重新绑定回默认数据源");
    }
}

DatabaseContextHolder.java

public class DatabaseContextHolder{  
  
    private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>();  
    //设置要使用的数据源  
    public static void setCustomerType(String customerType) {  
        contextHolder.set(customerType);  
    }  
    //获取数据源  
    public static String getCustomerType() {  
        return contextHolder.get();  
    }  
    //清除数据源,使用默认的数据源  
    public static void clearCustomerType() {  
        contextHolder.remove();  
    }  
} 

 

好了,总结完毕,其实内心还是倾向于JTA事务的配置方法,但JTA事务配置,网络各种问题,没有成功案例,基于项目进度紧,待后期有时间,在去切换; 毕竟以上的实现方式一般并发性不是很大,出现错误的概率很小;

 

© 著作权归作者所有

莫库什勒

莫库什勒

粉丝 22
博文 179
码字总数 70973
作品 0
杭州
高级程序员
私信 提问
Java通用数据访问层 Fastser-DAL 1.0.2 发布

Fastser-DAL是Java通用数据访问组件,基于mybatis、spring jdbc、hibernate等ORM框架开发,同时支持基于多数据源的读写分离、主备切换、故障转移,自动恢复、负载均衡、缓存等。 Fastser-DA...

冶卫军
2014/12/24
6.7K
31
咕泡-装饰器 decorator 设计模式笔记

装饰器模式(Decorator) 应用场景:在我们的项目中遇到这样一个问题:我们的项目需要连接多个数据库,而且不同的客户在每 次访问中根据需要会去访问不同的数据库。我们以往在Spring 和Hiber...

职业搬砖20年
2018/09/04
39
0
Spring动态创建,加载,使用多数据源

项目中我们经常会遇到多数据源的问题,尤其是数据同步或定时任务等项目更是如此。多数据源让人最头痛的,不是配置多个数据源,而是如何能灵活动态的切换数据源。例如在一个spring和hibernate...

Java编程思想
2014/02/26
9.8K
3
Maven搭建SpringMVC+Hibernate项目详解 【转】

今天复习一下SpringMVC+Hibernate的搭建,本来想着将Spring-Security权限控制框架也映入其中的,但是发现内容太多了,Spring-Security的就留在下一篇吧,这篇主要搭建SpringMVC4.1.4和Hiber...

梵蒂冈考虑过
2016/10/19
58
1
JeeWeb敏捷开发平台/jeeweb

JeeWeb敏捷开发平台 QQ交流群: 570062301 官方网站: https://www.jeeweb.cn 官方论坛: http://bbs.jeeweb.cn 项目演示: https://demo.jeeweb.cn 简介 JeeWeb是一款基于SpringMVC+Spring+...

JeeWeb敏捷开发平台
2017/07/06
0
0

没有更多内容

加载失败,请刷新页面

加载更多

爬虫可以采集哪些数据?爬虫借用什么代理可以提高效率

学习爬虫的门槛非常低,特别是通过Python学习爬虫,即使是网上也能找到许多学习爬虫的方法,而且爬虫在数据采集方面效果比较好,比如可以采集几万、上百万网页数据进行分析,带来极有价值的数...

xiaotaomi
25分钟前
4
0
redis自建笔记

自建redis笔记 最近在linux安装了一下redis,特做一些笔记! 本文先单节点启动redis,然后再进行持久化配置,在次基础上,再分享搭建主从模式的配置以及Sentinel 哨兵模式及集群的搭建 单节点...

北极之北
27分钟前
4
0
没想到Spring Boot居然这么耗内存,有点惊讶

Spring Boot总体来说,搭建还是比较容易的,特别是Spring Cloud全家桶,简称亲民微服务,但在发展趋势中,容器化技术已经成熟,面对巨耗内存的Spring Boot,小公司表示用不起。如今,很多刚诞...

程序员修BUG
30分钟前
4
0
Spring Security 实战干货:Spring Boot 中的 Spring Security 自动配置初探

1. 前言 我们在前几篇对 Spring Security 的用户信息管理机制,密码机制进行了探讨。我们发现 Spring Security Starter相关的 Servlet 自动配置都在spring-boot-autoconfigure-2.1.9.RELEASE...

码农小胖哥
32分钟前
4
0
Docker 容器时区时间不一致 问题解决

解决方案: 1,最傻瓜也最方便的处理方式,运行新的容器前设置本机时区和时间文件与容器的映射 docker run -v /etc/timezone:/etc/timezone -v /etc/localtime:/etc/localtime ...1 -v /etc/...

突突突酱
33分钟前
5
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部