Spring事务简化配置

Java代码

 

<beans>
	<!-- Transaction manager for a single Hibernate SessionFactory (alternative to JTA) -->
    <bean id="transactionManager"
          class="org.springframework.orm.hibernate3.HibernateTransactionManager">
          <property name="sessionFactory">
              <ref bean="sessionFactory"/>
          </property>
    </bean>	
	
	<bean id="transactionInterceptor" class="org.springframework.transaction.interceptor.TransactionInterceptor">
    	<property name="transactionManager" ref="transactionManager"/>
		<property name="transactionAttributeSource">
		  <value>
			com.skyon.user.manager.UserManager.*=PROPAGATION_REQUIRED
			#Add new defines here ->
		  </value>
		</property>
	</bean>
	
	<bean class="org.springframework.aop.framework.autoproxy.DefaultAdvisorAutoProxyCreator">
		<property name="interceptorNames">
			<list>
				<value>transactionInterceptor</value>
				<!--
				增加新的 Interceptor
				-->
			</list>
		</property>
	</bean>

	<bean class="org.springframework.transaction.interceptor.TransactionAttributeSourceAdvisor">
	  <property name="transactionInterceptor" ref="transactionInterceptor"/>
	</bean>
		
</beans>

这里利用 DefaultAdvisorAutoProxyCreator 实现了对容器中所有 bean 的自动代理,  增加一个需要事务的业务 bean 时只要在 transactionInterceptor 增加一行即可,  增加别的 interceptor 也非常方便，
极大减少了配置量

使得bean注入简捷的autowire，使得创建proxy简捷的autoproxy（实现有两个，一个是DefaultAdvisorAutoProxyCreator,BeanNameAutoProxyCreator）.
另外一些奇技淫巧可以查下实现了BeanPostProcessor接口的类．

 

配置Spring，针对Service层的bean做事务处理，以往的做法是这样：

Java代码

 

<bean id="txProxyTemplate" abstract="true" 
class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean"> 
    <property name="transactionManager">
        <ref bean="transactionManager"/>
    </property> 
    <property name="transactionAttributes"> 
        <props>
            <prop key="find*">PROPAGATION_REQUIRED, readOnly</prop> 
            <prop key="*">PROPAGATION_REQUIRED</prop> 
        </props> 
    </property> 
</bean> 

<bean id="userManager" parent="txProxyTemplate"> 
    <property name="target"> 
        <bean class="some.package.UserManagerImpl"> 
            <property name="userDAO"><ref bean="userDAO"/></property> 
        </bean> 
    </property> 
</bean> 

以后，如果增加新的Service/Manager，则XML配置的增量是这一段：

Java代码

 

<bean id="someOtherManager" parent="txProxyTemplate"> 
    <property name="target"> 
        <bean class="some.package.someOtherManagerImpl"> 
        </bean> 
    </property> 
</bean> 

上面说的是老的做法，比较传统。缺点是增量比较大，配置起来copy&paste让人觉得不太爽，比较臃肿。

下面的是Feiing给出的更好的方案，我有一些修改：

Java代码

 

<beans> 
        <!-- Transaction manager for a single Hibernate SessionFactory (alternative to JTA); --> 
    <bean id="transactionManager"           class="org.springframework.orm.hibernate3.HibernateTransactionManager"> 
          <property name="sessionFactory"> 
              <ref bean="sessionFactory"/> 
          </property> 
    </bean>        
        
        <bean id="transactionInterceptor" class="org.springframework.transaction.interceptor.TransactionInterceptor"> 
            <property name="transactionManager" ref="transactionManager"/> 
            <property name="transactionAttributes">
                <props>
                    <prop key="*">PROPAGATION_REQUIRED</prop>
                    <prop key="find*">PROPAGATION_REQUIRED,readOnly</prop>
                </props>
            </property>
        </bean> 
        
        <bean class="org.springframework.aop.framework.autoproxy.BeanNameAutoProxyCreator"> 
                <property name="beanNames">
                    <value>*Service,*Manager</value>
                </property>
                <property name="interceptorNames"> 
                        <list> 
                                <value>transactionInterceptor</value> 
                                <!-- 
                                此处增加新的Interceptor
                                --> 
                        </list> 
                </property> 
        </bean> 

        <bean class="org.springframework.transaction.interceptor.TransactionAttributeSourceAdvisor"> 
          <property name="transactionInterceptor" ref="transactionInterceptor"/> 
        </bean> 


        <bean id="userManager" class="some.package.UserManagerImpl" autoWire="byName"/>
                
</beans> 

以后每次的增量是这一段：

Java代码

 

        <bean id="userManager" class="some.package.UserManagerImpl" autoWire="byName"/>

跟配置普通bean的方法一样，非常简洁、直观。对现有的Service接口也无须任何修改

我把Feiing的transactionAttributesSource改成叻transactionAttributes，并且将DefaultAdvisorAutoProxyCreator改成了BeanNameAutoProxyCreator，我觉得毕竟不是context下的每个bean都需要事务，只要在Service层做AOP就可以叻。

和Robbin一致认为，Feiing的做法非常可取，因为它分离了XML配置文件关注点

 

以下是spring+iBatis的配置

作为开源的Orm对象映射框架，ibatis是一个线程安全，学习容易，但是开发相对于hibernate来说的话，就要繁锁些，没有很好的工具支持ibatis所有的配置几乎是通过手写，这样增加了开发者的难度、、好啦，言归正转。下面编写实现。

一、引入spring,ibatis jar包.

二、编写log4j.properties日志文件

      log4j.rootLogger=DEBUG,stdout

      log4j.appender.stdout=org.apache.log4j.ConsoleAppender
      log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
      log4j.appender.stdout.layout.ConversionPattern=%c{1}% - %m%n

      log4j.logger.java.sql.PreparedStatement=DEBUG

      

 

 

三、建立Student.java类映象属性

package org.terry.ibatis.pojo;

public class Student {
 private Long id;

 private String name;

 private String subject;

 private Long score;

 public Long getId() {
  return id;
 }

 public void setId(Long id) {
  this.id = id;
 }

 public String getName() {
  return name;
 }

 public void setName(String name) {
  this.name = name;
 }

 public Long getScore() {
  return score;
 }

 public void setScore(Long score) {
  this.score = score;
 }

 public String getSubject() {
  return subject;
 }

 public void setSubject(String subject) {
  this.subject = subject;
 }
}

 

 

 

四、编写 student.xml 映象文件

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

<!DOCTYPE sqlMap      
    PUBLIC "-//ibatis.apache.org//DTD SQL Map 2.0//EN"      
    "http://ibatis.apache.org/dtd/sql-map-2.dtd">
    
<sqlMap namespace="student">
 <typeAlias alias="student" type="org.terry.ibatis.pojo.Student"/>
 <resultMap class="student" id="studentResult">
  <result property="id" column="id" jdbcType="number" javaType="java.lang.Long"/>
  <result property="name" column="name"/>
  <result property="subject" column="subject"/>
  <result property="score" column="score"/>
 </resultMap>
 
 <select id="selectAll" resultMap="studentResult">
  select * from student
 </select>
 
 <select id="findbyId" parameterClass="java.lang.Long" resultClass="student">
  select * from student where id=#id#
 </select>
 <insert id="insert" parameterClass="student">
  insert into student(id,name,subject,score) values(#id#,#name#,#subject#,#score#)
 </insert>
 <update id="update" parameterClass="student">
  update student set name=#name#,subject=#subject#,score=#score# where id=#id#
 </update>
 <delete id="delete" parameterClass="java.lang.Long">
  delete from student where id=#id#
 </delete>
</sqlMap>

 

 

五、编写 SqlMapConfig.xml文件

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

<!DOCTYPE sqlMapConfig      
    PUBLIC "-//ibatis.apache.org//DTD SQL Map Config 2.0//EN"      
    "http://ibatis.apache.org/dtd/sql-map-config-2.dtd">
    
<sqlMapConfig>
 <sqlMap resource="org/terry/ibatis/pojo/student.xml"/>
</sqlMapConfig>

 

 

六、编写 StudentDao.java(实现类)

package org.terry.ibatis.dao;

import java.io.IOException;
import java.sql.SQLException;
import java.util.List;

import org.springframework.beans.factory.xml.XmlBeanFactory;
import org.springframework.core.io.ClassPathResource;
import org.springframework.core.io.Resource;
import org.springframework.orm.ibatis.SqlMapClientCallback;
import org.springframework.orm.ibatis.support.SqlMapClientDaoSupport;
import org.terry.ibatis.pojo.Student;

import com.ibatis.sqlmap.client.SqlMapExecutor;

public class StudentDao extends SqlMapClientDaoSupport implements Idao{

 public void delete(Long id) {
  this.getSqlMapClientTemplate().delete("delete", id);
 }

 public Object findbyId(Long id) {
  return this.getSqlMapClientTemplate().queryForObject("findbyId", id);
 }

 public List getAll() {
  return (List)this.getSqlMapClientTemplate().execute(new SqlMapClientCallback(){

   public Object doInSqlMapClient(SqlMapExecutor sqlMapper) throws SQLException {
    return sqlMapper.queryForList("selectAll");
   }
   
  });
 }

 public void save(Object o) {
  this.getSqlMapClientTemplate().insert("insert", o);
 }

 public void update(Object o) {
  this.getSqlMapClientTemplate().update("update", o);
 }
 
 public static void main(String[] args) throws IOException {
   Resource re=new ClassPathResource("Ibatis-Context.xml");
   XmlBeanFactory xml=new XmlBeanFactory(re);
   StudentDao student=(StudentDao)xml.getBean("studentDao");
   Student stu=new Student();
   stu.setId(Long.valueOf(16));
   stu.setName("terry");
   stu.setScore(Long.valueOf(99));
   stu.setSubject("数学");
   student.delete(Long.valueOf(16));
 }
}

 

 

七、配置 ApplicationContext.xml文件

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">

<beans>
 <bean id="dataSource"
  class="org.apache.commons.dbcp.BasicDataSource">
  <property name="driverClassName">
   <value>oracle.jdbc.driver.OracleDriver</value>
  </property>
  <property name="url">
   <value>jdbc:oracle:thin:@localhost:1521:orcl</value>
  </property>
  <property name="username">
   <value>terry</value>
  </property>
  <property name="password">
   <value>terry</value>
  </property>
 </bean>
 
 <bean id="sqlMapClient" class="org.springframework.orm.ibatis.SqlMapClientFactoryBean">
  <property name="configLocation" value="SqlMapConfig.xml"/>
  <property name="dataSource" ref="dataSource"></property>
 </bean>
 
 <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  <property name="dataSource" ref="dataSource"></property>
 </bean>
  <!-- 配置事务拦截器 -->
   <bean id="transactionIterceptor" class="org.springframework.transaction.interceptor.TransactionInterceptor">
    <!-- 事务拦截器需要注入一个事务管理器 -->
    <property name="transactionManager" ref="transactionManager"></property>
    <property name="transactionAttributes">
     <props>
      <prop key="insert*">PROPAGATION_REQUIRED</prop>
      <prop key="find*,get*">PROPAGATION_REQUIRED,readOnly</prop>
      <prop key="*">PROPAGATION_REQUIRED</prop>
     </props>
    </property>
   </bean>
   
   <bean class="org.springframework.aop.framework.autoproxy.BeanNameAutoProxyCreator">
    <property name="beanNames">
     <list>
      <value>*Dao</value>
     </list>
    </property>
    <property name="interceptorNames">
     <list>
      <value>transactionIterceptor</value>
     </list>
    </property>
   </bean>
 <bean id="studentDao" class="org.terry.ibatis.dao.StudentDao">
  <property name="sqlMapClient" ref="sqlMapClient"></property>
 </bean>
</beans>

 

 

这样Ibatis 集成 Spring就实现啦

分享到：

使用BeanPostProcessor接口对受管Bean进行 ... | Axis实践入门

• 2008-12-31 10:30
• 浏览 2273
• 评论(1)
• 查看更多

评论

1 楼 geek87 2010-01-30  

很好，，不错