spring事务

 Java EE 应用的传统事务有两种策略：全局事务和局部事务。全局事务由应用服务器管理，需要底层服务器对JTA的支持。局部事务和底层所采用的持久化技术有关，当采用JDBC持久化技术时，需要使用Connection对象来操作事务；而采用hibernate持久化技术时，需要使用session来操作事务。 

        Spring支持支持跨多个事务性资源（跨多个数据库资源）的全局事务。前提是应用服务器（webLogic、Jobss等）支持JTA全局事务。Spring本身没有任何事务支持，它只是负责包装底层的事务——应用程序面向PlatformTransactionManager接口编程时，Spring在底层负责将这些操作转换成具体的事务操作代码，因此应用的底层支持怎样的事务策略，那么spring就可支持怎样的事务策略。spring事务管理的优势在于将应用从具体的事务api中分离出来，而不是真正提供事务管理的底层实现。（降低代码耦合度）

       PlatformTransactionManager是一个与任何事务策略分离的接口，随着底层不同事务策略的切换，应用只需使用不同的PlatformTransactionManager实现类即可。

       在PlatformTransactionManager接口内，包含一个getTransaction(TransactionDefinition definition)方法，改方法根据TransactionDefinition 参数返回一个TransactionStatus对象，TransactionStatus对象表示一个事务，TransactionStatus被关联到当前执行的线程上。

       TransactionDefinition接口定义一个事务规则，该接口必须指定如下几个属性：

        事务隔离

        事务传播

        事务超时

        只读状态

    

一、事务配置，以下提供了几种不同的持久层访问环境对应的PlatformTransactionManager实现类的配置

   1）、JDBC数据源的局部事务管理器的配置文件如下：

    spring配置文件如下：               <bean id="dataSource" name="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">

       <property name="driverClass" value="${jdbc.driverClassName}"/> 

            <property name="jdbcUrl" value="${jdbc.url}"/>  

            <property name="user" value="${jdbc.username}"/>  

            <property name="password" value="${jdbc.password}"/>  

             <property name="maxPoolSize" value="${jdbc.maxPoolSize}"/>  

             <property name="minPoolSize" value="${jdbc.minPoolSize}"/>  

            <property name="initialPoolSize" value="${jdbc.initialPoolSize}"/>  

             <!-- 最大空闲时间,60秒内未使用则连接被丢弃。若为0则永不丢弃。 Default:0-->  

             <property name="maxIdleTime" value="${jdbc.maxIdleTime}"/>  

             <!-- 当连接池中的连接耗尽的时候c3p0一次同时获取的连接数. Default:3-->  

             <property name="acquireIncrement" value="${jdbc.acquireIncrement}"/>  

     </bean>

    <bean id="transactionManager"

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

        <property name="dataSource" ref="dataSource"/>

    </bean>

   

     2)、JTA全局事务管理器的配置文件如下：

                spring配置文件如下：             

           

            <bean id="dataSource" class="org.jdbcdslog.ConnectionPoolDataSourceProxy">

<property name="targetDSDirect" ref="dataSourceJndi_ST" />

   </bean>

 

          <!-- 配置JNDI 数据源Bean，其中Jndi name指定应用服务器（tomcat）管理数据源JNDI-->

          <bean id="dataSourceJndi_ST" class="org.springframework.jndi.JndiObjectFactoryBean">        

<property name="jndiName">

<value>java:comp/env/Oracle01</value>

</property>

   </bean>

        <!--  全局事务管理的实现 -->

        <bean id="transactionManager"

        class ="org.springframework.transaction.jta.JtaTransactionManager">

                 <property name="dataSource" ref="dataSource"/>

        </bean>

 

     3)采用hibernate持久层访问策略，局部事务配置如下：

         <bean id="dataSource" name="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">

       <property name="driverClass" value="${jdbc.driverClassName}"/> 

            <property name="jdbcUrl" value="${jdbc.url}"/>  

            <property name="user" value="${jdbc.username}"/>  

            <property name="password" value="${jdbc.password}"/>  

             <property name="maxPoolSize" value="${jdbc.maxPoolSize}"/>  

             <property name="minPoolSize" value="${jdbc.minPoolSize}"/>  

            <property name="initialPoolSize" value="${jdbc.initialPoolSize}"/>  

             <!-- 最大空闲时间,60秒内未使用则连接被丢弃。若为0则永不丢弃。 Default:0-->  

             <property name="maxIdleTime" value="${jdbc.maxIdleTime}"/>  

             <!-- 当连接池中的连接耗尽的时候c3p0一次同时获取的连接数. Default:3-->  

             <property name="acquireIncrement" value="${jdbc.acquireIncrement}"/>  

     </bean>

     <bean id="sessionFactory" class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">

                <property name="dataSource" ref="dataSource"/>

                <property name="packagesToScan" value="com.siebre"/>

                 <property name="annotatedPackages">

                           <list>

                                  <value>com.siebre.baf.hibernate</value>

                           </list>

                </property>

                <property name="annotatedClasses">

                       <list>

 

                     </list>

                 </property>

                <property name="mappingResources">

                      <list>

                         <value>Baf.hbm.xml</value>

                      </list>

                </property>

               <property name="hibernateProperties">

                       <props>

                            <!-- 指定数据库方言 -->

                             <prop key="hibernate.dialect">${hibernate.dialect}</prop>

                            <!-- 是否根据hibernate映射创建数据表 -->

                            <prop key="hibernate.hbm2ddl.auto">update</prop>

                        </props>

              </property>

         </bean>

         <bean id="transactionManager"

              class ="org.springframework.orm.hibernate4.HibernateTransactionManager">

                 <property name="sessionFactory" ref="sessionFactory"/>

        </bean>

 

二、事务管理。

       Spring提供了两种事务管理方式：

             编程式事务管理

            声明式事务管理

 

        1）、编程式事务管理配置实例

                 程序清单：

             public class NewDaoImpl imlements NewsDao{

                     private DataSource ds;

                     public void setDs(DataSource ds){

                            this.ds=ds;

                     }

                    public void insert(String title,String content){

                         JdbcTemplate jt = new JdbcTemplate(ds);

                         jt.update("insert into news_inf  values(null,?,?)",title,content);

                         //两次插入的数据违反唯一键约束

                         jt.update("insert into news_inf  values(null,?,?)",title,content);

                         //如果没有事务控制，则第一条记录可以被插入

                        //如果增加事务控制，则第一条记录也插不进去

                        }

              }

             spring配置文件中增加如下配置：

            <bean id="dataSource" name="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">

       <property name="driverClass" value="${jdbc.driverClassName}"/> 

            <property name="jdbcUrl" value="${jdbc.url}"/>  

            <property name="user" value="${jdbc.username}"/>  

            <property name="password" value="${jdbc.password}"/>  

             <property name="maxPoolSize" value="${jdbc.maxPoolSize}"/>  

             <property name="minPoolSize" value="${jdbc.minPoolSize}"/>  

            <property name="initialPoolSize" value="${jdbc.initialPoolSize}"/>  

             <!-- 最大空闲时间,60秒内未使用则连接被丢弃。若为0则永不丢弃。 Default:0-->  

             <property name="maxIdleTime" value="${jdbc.maxIdleTime}"/>  

             <!-- 当连接池中的连接耗尽的时候c3p0一次同时获取的连接数. Default:3-->  

             <property name="acquireIncrement" value="${jdbc.acquireIncrement}"/>  

     </bean>

    <bean id="transactionManager"

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

        <property name="dataSource" ref="dataSource"/>

    </bean>

    <bean id="newsDao" class="org.crazyit.app.dao.impl.NewsDaoImpl"

           p:ds-ref="dataSource"/>

     <!--  --配置事务增强处理Bean，指定事务管理器 -->

     <tx:advice id=“txAdive"

           transaction-manager="transactionManager">

              <!--    用于配置详细的事务定义    -->

              <tx:attributes>

                   <!--   所有以get开头的方法是只读的 --->

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

                   <!--  其他方法使用默认的事务配置，指定超时时间为5秒 -->

                   <tx:method name =" * " isolation="DEFAULT”

                          propagation="REQUIRED"  timeout="5"/>

               <tx:attributes>

      </tx:advice>

      <!--  AOP配置的元素 -->

        <aop:config>

             <!--  配置一个切入点，匹配org.crazyit.app.dao.impl包下所有以impl结尾的类所有方法执行 --》

              <aop:pointcut  id="myPointcut"

                       expression="execution(* org.crazyit.app.dao.impl.*impl.*(..))"/>

              <!-- 指定myPointcut切入点应用txAdvice事务增强处理 -->

              <aop:advisor  advice-ref="txAdvice“

                        pointcut-ref="myPointcut"/>

        </aop:config>

程序清单：

 　　　pbulic class springTest{

                  public static void main(String[] args) throws Exception{

                            ApplicationContext ctx = new ClassPathXmlApplicationContext("spring-config.xml");

                            NewsDao dao =  (NewsDao)ctx.getBean("newsDao",NewsDao.class);

                            dao.insert("疯狂java","轻量级Java EE企业应用实战”);

                 }

            }

 

      2)、使用@Transactional

             如果使用@Transactional修饰Bean类，则表明这些事务设置对整个bean类起作用，如果使用@Transactional修饰Bean类的某个方法，则表明这些事务设置只对该方法有效。

            spring配置文件如下：

                  <bean id="transactionManager"

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

                        <property name="dataSource" ref="dataSource"/>

                  </bean>

                   <tx:annotation-driven transaction-manager="transactionManager".>

          程序清单：

              public class NewDaoImpl imlements NewsDao{

                     private DataSource ds;

                     public void setDs(DataSource ds){

                            this.ds=ds;

                     }

                                                               @Transactional(propagation=Propagation.REQUIRED,isolation=Isolation.DEFAULT,

                            timeout=5)

                    public void insert(String title,String content){

                     }

                 }