`

SSH框架系列：Spring配置多个数据源

 
阅读更多

原文来自：http://www.sjsjw.com/kf_web/article/13_31666_9704.asp

 

1.问题的引入 

         对于普通的SSH框架而言，一般配置一个数据源，一个SessionFactory，一个事务管理和对应的ProxyCreate。那么当项目需要操作多个数据库时，如何配置呢？ 

方案1 

配置2个数据源，2个对应的SessionFactory，2个事务等。Spring的配置如下： 

<?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:context="http://www.springframework.org/schema/context"
xmlns:tx="http://www.springframework.org/schema/tx" xmlns:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation="http://www.springframework.org/schema/beans
    http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/tx 
http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
http://www.springframework.org/schema/aop
    http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
    http://www.springframework.org/schema/context
    http://www.springframework.org/schema/context/spring-context-3.0.xsd">
<!-- 引入datasource配置文件 -->
<context:property-placeholder location="classpath:datasource.properties" />
<!--创建mysql jdbc数据源 -->
<bean id="mysqlDataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"
destroy-method="close">
<property name="driverClass" value="${jdbc.mysql.driver}" />
<property name="jdbcUrl" value="${jdbc.mysql.url}" />
<property name="user" value="${jdbc.mysql.username}" />
<property name="password" value="${jdbc.mysql.password}" />
<!-- 指定连接数据库连接池的最小连接数 -->
        <property name="minPoolSize" value="10" />
        <!-- 指定连接数据库连接池的最大连接数 -->
        <property name="maxPoolSize" value="30" />
        <!-- 指定连接数据库连接池的连接的最大空闲时间 -->
        <property name="maxIdleTime" value="1800" />
        <property name="acquireIncrement" value="2" />
        <property name="maxStatements" value="0" />
        <!-- 指定连接数据库连接池的初始化连接数 -->
        <property name="initialPoolSize" value="2" />
        <property name="idleConnectionTestPeriod" value="1800" />
        <!-- 当连接失败时，尝试重新连接的次数 -->
        <property name="acquireRetryAttempts" value="30" />
        <property name="breakAfterAcquireFailure" value="true" />
        <property name="testConnectionOnCheckout" value="false" />
</bean>
<!--创建oracle jdbc数据源 -->
<bean id="oracleDataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"
destroy-method="close">
<property name="driverClass" value="${jdbc.oracle.driver}" />
<property name="jdbcUrl" value="${jdbc.oracle.url}" />
<property name="user" value="${jdbc.oracle.username}" />
<property name="password" value="${jdbc.oracle.password}" />
<!-- 指定连接数据库连接池的最小连接数 -->
        <property name="minPoolSize" value="10" />
        <!-- 指定连接数据库连接池的最大连接数 -->
        <property name="maxPoolSize" value="30" />
        <!-- 指定连接数据库连接池的连接的最大空闲时间 -->
        <property name="maxIdleTime" value="1800" />
        <property name="acquireIncrement" value="2" />
        <property name="maxStatements" value="0" />
        <!-- 指定连接数据库连接池的初始化连接数 -->
        <property name="initialPoolSize" value="2" />
        <property name="idleConnectionTestPeriod" value="1800" />
        <!-- 当连接失败时，尝试重新连接的次数 -->
        <property name="acquireRetryAttempts" value="1" />
        <property name="breakAfterAcquireFailure" value="true" />
        <property name="testConnectionOnCheckout" value="false" />
</bean>
<!-- 创建MysqlSessionFactory-->
<bean id="mysqlSessionFactory"
class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">
<property name="dataSource" ref="mysqlDataSource" />
<property name="hibernateProperties">
<props>
   <prop key="hibernate.show_sql">true</prop>
<prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop>
<prop key="current_session_context_class">thread</prop>
</props>
</property>
<property name="mappingResources">
<list>
<value>edu/njupt/zhb/model/mysql/Student.hbm.xml</value>
</list>
</property>
</bean>
 
   <!-- 创建OracleSessionFactory-->
<bean id="oracleSessionFactory"
class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">
<property name="dataSource" ref="oracleDataSource" />
<property name="hibernateProperties">
<props>
   <prop key="hibernate.show_sql">true</prop>
<prop key="hibernate.dialect">org.hibernate.dialect.OracleDialect</prop>
<prop key="current_session_context_class">thread</prop>
</props>
</property>
<property name="mappingResources">
<list>
<value>edu/njupt/zhb/model/oracle/Student.hbm.xml</value>
</list>
</property>
</bean>
 
<!-- 配置Mysql事务 -->
<bean id="mysqlTransactionManager"
class="org.springframework.orm.hibernate4.HibernateTransactionManager">
<property name="sessionFactory">
<ref local="mysqlSessionFactory" />
</property>
</bean>
     <!--Mysql hibernate4必须配置为开启事务 否则 getCurrentSession()获取不到-->
<bean id="mysqlTransactionInterceptor"
class="org.springframework.transaction.interceptor.TransactionInterceptor">
<property name="transactionManager">
<ref local="mysqlTransactionManager" />
</property>
<property name="transactionAttributes">
<props>
<prop key="register">PROPAGATION_REQUIRED</prop>
<prop key="get*">PROPAGATION_REQUIRED,readOnly</prop>
<prop key="find*">PROPAGATION_REQUIRED,readOnly</prop>
<prop key="select*">PROPAGATION_REQUIRED,readOnly</prop>
<prop key="query*">PROPAGATION_REQUIRED,readOnly</prop>
<prop key="sync*">PROPAGATION_REQUIRED</prop>
<prop key="finish*">PROPAGATION_REQUIRED</prop>
<prop key="add*">PROPAGATION_REQUIRED</prop>
<prop key="insert*">PROPAGATION_REQUIRED</prop>
<prop key="edit*">PROPAGATION_REQUIRED</prop>
<prop key="update*">PROPAGATION_REQUIRED</prop>
<prop key="save*">PROPAGATION_REQUIRED</prop>
<prop key="remove*">PROPAGATION_REQUIRED</prop>
<prop key="delete*">PROPAGATION_REQUIRED</prop>
<prop key="modify*">PROPAGATION_REQUIRED</prop>
<prop key="*">PROPAGATION_REQUIRED,-java.lang.Exception</prop>
</props>
</property>
</bean>
 
<!-- 配置oracle事务 -->
<bean id="oracleTransactionManager"
class="org.springframework.orm.hibernate4.HibernateTransactionManager">
<property name="sessionFactory">
<ref local="oracleSessionFactory" />
</property>
</bean>
     <!--Mysql hibernate4必须配置为开启事务 否则 getCurrentSession()获取不到-->
<bean id="oracleTransactionInterceptor"
class="org.springframework.transaction.interceptor.TransactionInterceptor">
<property name="transactionManager">
<ref local="oracleTransactionManager" />
</property>
<property name="transactionAttributes">
<props>
<prop key="register">PROPAGATION_REQUIRED</prop>
<prop key="get*">PROPAGATION_REQUIRED,readOnly</prop>
<prop key="find*">PROPAGATION_REQUIRED,readOnly</prop>
<prop key="select*">PROPAGATION_REQUIRED,readOnly</prop>
<prop key="query*">PROPAGATION_REQUIRED,readOnly</prop>
<prop key="sync*">PROPAGATION_REQUIRED</prop>
<prop key="finish*">PROPAGATION_REQUIRED</prop>
<prop key="add*">PROPAGATION_REQUIRED</prop>
<prop key="insert*">PROPAGATION_REQUIRED</prop>
<prop key="edit*">PROPAGATION_REQUIRED</prop>
<prop key="update*">PROPAGATION_REQUIRED</prop>
<prop key="save*">PROPAGATION_REQUIRED</prop>
<prop key="remove*">PROPAGATION_REQUIRED</prop>
<prop key="delete*">PROPAGATION_REQUIRED</prop>
<prop key="modify*">PROPAGATION_REQUIRED</prop>
<prop key="*">PROPAGATION_REQUIRED,-java.lang.Exception</prop>
</props>
</property>
</bean>
 
<!-- autoproxy 自动创建代理-->
      <bean id="ProxyCreator" class="org.springframework.aop.framework.autoproxy.BeanNameAutoProxyCreator">
         <property name="beanNames">
             <list>
                <value>*ServiceImpl</value>
             </list>
         </property>
         <property name="interceptorNames">
             <list>
                <value>mysqlTransactionInterceptor</value>
                <value>oracleTransactionInterceptor</value>
             </list>
         </property>
      </bean>
<!--********************************注入Mysql Dao*********************************************-->
<bean id="mysqlBaseDao" class="edu.njupt.zhb.dao.MysqlBaseDao">
    <property name="sessionFactory" ref="mysqlSessionFactory"></property>
    </bean>
    <!--********************************注入Oracle Dao*********************************************-->
    <bean id="oracleBaseDao" class="edu.njupt.zhb.dao.OracleBaseDao">
    <property name="sessionFactory" ref="oracleSessionFactory"></property>
    </bean>
    <!--********************************注入Services********************************-->
<!--********************************注入Action********************************-->
</beans>

 

 

优缺点分析： 

优点：我们能够在程序中正常得使用2个不同的Dao，而且可以调用dao的getSessionFactory().getCurrentSession()，使用起来特别的方便。每个Dao都有自己的事务管理，安全性各方面和一个数据库一样。 

缺点：由于事务的配置和自动创建代理的配置，只要有一个数据库连接不了，即便两外一个数据库可以连接，整个项目仍然无法正常启动。对于一些特殊的应用场景，该方案有着很大的缺陷。 

比如某项目的需求为：一个项目需要同时操作2个数据库，如果一个数据库无法连接，那么项目就操作另外一个数据库，同时，将操作的动作记录下来，等另外一个数据库可以连接的时候，再将之前的操作同步到这个数据库中。而且要求，当项目启动的时候，即便只有一个数据库可以连接，那么项目仍然要正常运行。 

 

方案2 

为了解决上述的需求，我们将其中一个数据库作为本地数据库，另外一个作为远程数据库，当远程数据库无法连接时，我们跳过。整个项目使用本地数据库即可，同时将需要同步的数据，保存起来，待可连接时，再同步。 

<?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:context="http://www.springframework.org/schema/context"
xmlns:tx="http://www.springframework.org/schema/tx" xmlns:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation="http://www.springframework.org/schema/beans
    http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/tx 
http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
http://www.springframework.org/schema/aop
    http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
    http://www.springframework.org/schema/context
    http://www.springframework.org/schema/context/spring-context-3.0.xsd">
<!-- 引入datasource配置文件 -->
<context:property-placeholder location="classpath:datasource.properties" />
<!--创建mysql jdbc数据源 -->
<bean id="mysqlDataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"
destroy-method="close">
<property name="driverClass" value="${jdbc.mysql.driver}" />
<property name="jdbcUrl" value="${jdbc.mysql.url}" />
<property name="user" value="${jdbc.mysql.username}" />
<property name="password" value="${jdbc.mysql.password}" />
<!-- 指定连接数据库连接池的最小连接数 -->
        <property name="minPoolSize" value="10" />
        <!-- 指定连接数据库连接池的最大连接数 -->
        <property name="maxPoolSize" value="30" />
        <!-- 指定连接数据库连接池的连接的最大空闲时间 -->
        <property name="maxIdleTime" value="1800" />
        <property name="acquireIncrement" value="2" />
        <property name="maxStatements" value="0" />
        <!-- 指定连接数据库连接池的初始化连接数 -->
        <property name="initialPoolSize" value="2" />
        <property name="idleConnectionTestPeriod" value="1800" />
        <!-- 当连接失败时，尝试重新连接的次数 -->
        <property name="acquireRetryAttempts" value="30" />
        <property name="breakAfterAcquireFailure" value="true" />
        <property name="testConnectionOnCheckout" value="false" />
</bean>
<!--创建oracle jdbc数据源 -->
<bean id="oracleDataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"
destroy-method="close">
<property name="driverClass" value="${jdbc.oracle.driver}" />
<property name="jdbcUrl" value="${jdbc.oracle.url}" />
<property name="user" value="${jdbc.oracle.username}" />
<property name="password" value="${jdbc.oracle.password}" />
<!-- 指定连接数据库连接池的最小连接数 -->
        <property name="minPoolSize" value="10" />
        <!-- 指定连接数据库连接池的最大连接数 -->
        <property name="maxPoolSize" value="30" />
        <!-- 指定连接数据库连接池的连接的最大空闲时间 -->
        <property name="maxIdleTime" value="1800" />
        <property name="acquireIncrement" value="2" />
        <property name="maxStatements" value="0" />
        <!-- 指定连接数据库连接池的初始化连接数 -->
        <property name="initialPoolSize" value="2" />
        <property name="idleConnectionTestPeriod" value="1800" />
        <!-- 当连接失败时，尝试重新连接的次数 -->
        <property name="acquireRetryAttempts" value="1" />
        <property name="breakAfterAcquireFailure" value="true" />
        <property name="testConnectionOnCheckout" value="false" />
</bean>
<!-- 创建MysqlSessionFactory-->
<bean id="mysqlSessionFactory"
class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">
<property name="dataSource" ref="mysqlDataSource" />
<property name="hibernateProperties">
<props>
   <prop key="hibernate.show_sql">true</prop>
<prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop>
<prop key="current_session_context_class">thread</prop>
</props>
</property>
<property name="mappingResources">
<list>
<value>edu/njupt/zhb/model/mysql/Student.hbm.xml</value>
</list>
</property>
</bean>
 
   <!-- 创建OracleSessionFactory-->
<bean id="oracleSessionFactory"
class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">
<property name="dataSource" ref="oracleDataSource" />
<property name="hibernateProperties">
<props>
   <prop key="hibernate.show_sql">true</prop>
<prop key="hibernate.dialect">org.hibernate.dialect.OracleDialect</prop>
<prop key="current_session_context_class">thread</prop>
</props>
</property>
<property name="mappingResources">
<list>
<value>edu/njupt/zhb/model/oracle/Student.hbm.xml</value>
</list>
</property>
</bean>
 
<!-- 配置Mysql事务 -->
<bean id="mysqlTransactionManager"
class="org.springframework.orm.hibernate4.HibernateTransactionManager">
<property name="sessionFactory">
<ref local="mysqlSessionFactory" />
</property>
</bean>
     <!--Mysql hibernate4必须配置为开启事务 否则 getCurrentSession()获取不到-->
<bean id="mysqlTransactionInterceptor"
class="org.springframework.transaction.interceptor.TransactionInterceptor">
<property name="transactionManager">
<ref local="mysqlTransactionManager" />
</property>
<property name="transactionAttributes">
<props>
<prop key="register">PROPAGATION_REQUIRED</prop>
<prop key="get*">PROPAGATION_REQUIRED,readOnly</prop>
<prop key="find*">PROPAGATION_REQUIRED,readOnly</prop>
<prop key="select*">PROPAGATION_REQUIRED,readOnly</prop>
<prop key="query*">PROPAGATION_REQUIRED,readOnly</prop>
<prop key="sync*">PROPAGATION_REQUIRED</prop>
<prop key="finish*">PROPAGATION_REQUIRED</prop>
<prop key="add*">PROPAGATION_REQUIRED</prop>
<prop key="insert*">PROPAGATION_REQUIRED</prop>
<prop key="edit*">PROPAGATION_REQUIRED</prop>
<prop key="update*">PROPAGATION_REQUIRED</prop>
<prop key="save*">PROPAGATION_REQUIRED</prop>
<prop key="remove*">PROPAGATION_REQUIRED</prop>
<prop key="delete*">PROPAGATION_REQUIRED</prop>
<prop key="modify*">PROPAGATION_REQUIRED</prop>
<prop key="*">PROPAGATION_REQUIRED,-java.lang.Exception</prop>
</props>
</property>
</bean>
<!-- autoproxy 自动创建代理-->
      <bean id="ProxyCreator" class="org.springframework.aop.framework.autoproxy.BeanNameAutoProxyCreator">
         <property name="beanNames">
             <list>
                <value>*ServiceImpl</value>
             </list>
         </property>
         <property name="interceptorNames">
             <list>
                <value>mysqlTransactionInterceptor</value>
             </list>
         </property>
      </bean>
<!--********************************注入Mysql Dao*********************************************-->
<bean id="mysqlBaseDao" class="edu.njupt.zhb.dao.MysqlBaseDao">
    <property name="sessionFactory" ref="mysqlSessionFactory"></property>
    </bean>
    <!--********************************注入Oracle Dao*********************************************-->
    <bean id="oracleBaseDao" class="edu.njupt.zhb.dao.OracleBaseDao">
    <property name="sessionFactory" ref="oracleSessionFactory"></property>
    </bean>
    <!--********************************注入Services********************************-->
<!--********************************注入Action********************************-->
</beans>

 

 

这种配置下，oracleBaseDao的数据源的属性：acquireRetryAttempts的值配置为1，即便无法连接，我们也只需要连接一次，不会出现“卡住”的情况。而且，由于oracleBaseDao中，我们没有配置事务，因此，dao无法获得getCurrentSession，只能通过sessionFactory().openSession()来使用Hibernate。同时为了捕获异常，我们将session设置成手动提交的方式。 

分享到：
| JSP 如何 给 标签 赋值
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    SSH配置多个数据源

    总结来说，配置SSH框架以支持多个数据源需要对Spring的bean管理、Hibernate的数据库连接以及Struts2的请求处理有深入理解。这个过程包括定义和配置多个DataSource bean，调整Hibernate和Struts2的配置以适应不同的...

    针对SSH框架Spring管理Hibernate连接多个数据源配置文件

    该配置文件连接的是两个数据库结构相同的数据源，其他比如数据库结构不原理也可行。本人在遇到此问题时上网搜了很多答案结果都不怎么如意，有的太深奥不过思想很好，有的又太不给力，后来自己慢慢研究配置成功后想与...

    SSH 配置实例: Spring 3.1 + Hibernate 4.2 + Struts 2.3

    在SSH框架中，它会作为数据源，使得Hibernate可以与MySQL数据库进行交互。 4. jackson-mapper-asl-1.8.8.jar 和 jackson-core-asl-1.8.8.jar: 这是Jackson库的一部分，用于JSON序列化和反序列化，可以帮助Spring ...

    springssh 我上培训班时spring框架搭建课件

    综上所述，SSH框架的集成应用涉及多个层面的配置和设计，从数据访问到事务管理，再到Web应用的构建，每个环节都紧密相连，相互作用。掌握这一框架的搭建和使用，对于提升Java开发者的技能水平具有重要意义。

    ssh框架整合详细步骤（spring+struts2+hibernate）

    SSH框架的整合涉及多个步骤，从Web工程的创建、框架的引入、配置文件的编写，到各个组件之间的紧密集成，每一个环节都需精心设计和实现。只有当所有框架都顺利整合在一起，才能发挥出SSH组合的最大效能，为开发者...

    基于IDEA的SSH项目之二：配置Spring一---程序包

    4. **配置数据源**：Spring通常使用Apache Commons DBCP或C3P0来管理数据源。在`applicationContext.xml`中，添加如下配置： ```xml &lt;property name="url" value="jdbc:mysql://localhost:3306/test"/&gt; ...

    SSH框架：struts2+spring+hibernate 全部jar包

    Spring还包含了数据访问、Web、测试等多个模块，支持与各种数据库和ORM框架（如Hibernate）的集成。 Hibernate是Java中的一个持久化框架，主要用于简化数据库操作。它提供了一种对象-关系映射（ORM）机制，将数据库...

    ssh框架的源代码

    此外，Spring还包含了AOP（面向切面编程）、数据访问/集成、Web应用以及任务调度等多个模块，极大地提高了开发效率和代码的可维护性。 **Struts框架**：Struts是MVC设计模式的一个实现，主要用于构建基于J2EE的Web...

    SSH三大框架整合 struts2(使用xml配置)+hibernate(使用xml配置)+spring(使用xml配置)

    在XML配置文件中，我们指定数据源、连接池、实体类和表的映射关系。此外，使用SessionFactory和Session对象，我们可以方便地执行CRUD操作，而无需直接编写SQL语句。 Spring则作为核心的容器框架，管理应用中的对象...

    ssh框架struts2 spring hibernate

    在SSH框架中，Spring负责管理Action对象的生命周期，通过`struts.objectFactory`常量配置为"spring"，可以实现Spring对Action的创建和管理。 Hibernate则是SSH中的持久层框架，它简化了数据库操作，通过对象-关系...

    SSH框架简单搭建

    1. **Spring配置**：配置Spring的核心文件`applicationContext.xml`，包括Bean的定义、依赖注入以及数据源和事务管理器的配置。 2. **Struts配置**：配置Struts的主配置文件`struts-config.xml`，定义Action类、...

    实用SSH框架，用Spring来管理hibernate.

    SSH框架是Java开发中常用的三大框架整合，包括Struts、Hibernate和Spring。这些框架的结合提供了模型-视图-控制器（MVC）架构的支持，数据持久化以及依赖注入等功能，大大提高了开发效率和代码的可维护性。接下来，...

    SSH框架架包及配置

    在"配置文件"中，可能包含上述提到的`struts.xml`、`applicationContext.xml`和`hibernate.cfg.xml`，还有可能包含其他的配置文件，如Spring的数据库事务配置文件、Struts2的国际化配置、Hibernate的数据源配置等。...

    SSH框架基本包三大框架整合

    3. 集成Hibernate：配置Hibernate的实体类、数据源、SessionFactory，并通过Spring的HibernateTemplate或JPA进行数据操作。 4. 定义业务逻辑和服务层：创建Service层，利用Spring的依赖注入，将DAO层和业务逻辑层...

    SSH框架数据添加

    通常，SSH框架的项目会包含以下几个部分：Struts2的配置文件(struts.xml)，Spring的配置文件(spring-context.xml)，Hibernate的配置文件(hibernate.cfg.xml)，以及Action类、Service类、DAO类和实体类的Java源代码。...

    SSH框架整合模版，非常详细实用

    在实际项目中，SSH框架的整合不仅涉及到上述基础配置，还包括错误处理、国际化、权限控制等多个方面。理解每个组件的功能以及它们如何协同工作是实现高效、稳定应用的关键。同时，随着技术的发展，SSH已经被更现代的...

    SSH动态切换数据源

    每个数据源可以是单独的DataSource bean，也可以是JNDI查找的结果。然后，将这些数据源映射到之前定义的标识符上。 在Struts2中，你可以通过拦截器或者ActionContext来设置当前的上下文信息，这些信息随后会被...

    ssh配置多个数据库

    -- 配置多个数据源 --&gt; &lt;!-- 数据源相同部分 --&gt; &lt;bean class="org.springframework.jdbc.datasource.DriverManagerDataSource" id="parentDataSource"&gt; ${drivers}" /&gt; &lt;!-- 198 上的数据库 --&gt; ${...

Magicbox
Global site tag (gtag.js) - Google Analytics