论坛首页 → Java企业应用论坛 →

Spring的事务管理难点剖析(1):DAO和事务管理的牵绊

浏览 4531 次
锁定老帖子 主题：Spring的事务管理难点剖析(1):DAO和事务管理的牵绊
精华帖 (0) :: 良好帖 (1) :: 新手帖 (11) :: 隐藏帖 (0)
作者 正文
  • stamen
  • 等级: 五钻会员
  • 性别:
  • 文章: 449
  • 积分: 2310
  • 来自: 厦门
   发表时间：2012-03-07   最后修改：2012-03-07
--------------------------------------------------------------------------------------------------------------------------      
   引述：Spring给我们带来的最大的一个便利是透明地实现事务管理，但是一般开发者仅仅是了解如何配置，在实际应用过程中却往往遇到很多问题，存在很多困惑。有有鉴于此，我特意总结了各种实际应用中遇到的Spring事务管理的困惑，这些文章摘自于我的《Spring 3.x企业应用开发实战》的第10章，我将通过连载的方式，陆续在此发出。欢迎大家讨论。
-------------------------------------------------------------------------------------------------------------------------- 

     有些人很少使用Spring而不使用Spring事务管理器的应用，因此常常有人会问：是否用了Spring，就一定要用Spring事务管理器，否则就无法进行数据的持久化操作呢？事务管理器和DAO是什么关系呢？
     也许是DAO和事务管理如影随行的缘故吧，这个看似简单的问题实实在在地存在着，从初学者心中涌出，萦绕在老手的脑际。答案当然是否定的！我们都知道：事务管理是保证数据操作的事务性（即原子性、一致性、隔离性、持久性，即所谓的ACID），脱离了事务性，DAO照样可以顺利地进行数据的操作。

  JDBC访问数据库

  下面，我们来看一段使用Spring JDBC进行数据访问的代码：
  
package com.baobaotao.withouttx.jdbc;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.apache.commons.dbcp.BasicDataSource;

@Service("userService")
public class UserJdbcWithoutTransManagerService {
    @Autowired
    private JdbcTemplate jdbcTemplate;

    public void addScore(String userName,int toAdd){
        String sql = "UPDATE t_user u SET u.score = u.score + ? WHERE user_name =?";
        jdbcTemplate.update(sql,toAdd,userName);
    }

    public static void main(String[] args) {
        ApplicationContext ctx = new   
           ClassPathXmlApplicationContext("com/baobaotao/withouttx/jdbc/jdbcWithoutTx.xml");         
        UserJdbcWithoutTransManagerService service = 
                     (UserJdbcWithoutTransManagerService)ctx.getBean("userService");
        JdbcTemplate jdbcTemplate = (JdbcTemplate)ctx.getBean("jdbcTemplate");
        BasicDataSource basicDataSource = (BasicDataSource)jdbcTemplate.getDataSource();

        //①检查数据源autoCommit的设置
        System.out.println("autoCommit:"+ basicDataSource.getDefaultAutoCommit());

        //②插入一条记录，初始分数为10
        jdbcTemplate.execute("INSERT INTO t_user(user_name,password,score,last_logon_time) 
                              VALUES('tom','123456',10,"+System.currentTimeMillis()+")");

        //③调用工作在无事务环境下的服务类方法,将分数添加20分
        service.addScore("tom",20);

         //④查看此时用户的分数
        int score = jdbcTemplate.queryForInt(
                  "SELECT score FROM t_user WHERE user_name ='tom'");
        System.out.println("score:"+score);
        jdbcTemplate.execute("DELETE FROM t_user WHERE user_name='tom'");
    }
}

  其中，jdbcWithoutTx.xml的配置文件如下所示： 
<?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:p="http://www.springframework.org/schema/p"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
    http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd">     
    <context:component-scan base-package="com.baobaotao.withouttx.jdbc"/>

    <context:property-placeholder location="classpath:jdbc.properties"/>
    <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"
		destroy-method="close" 
		p:driverClassName="${jdbc.driverClassName}"
		p:url="${jdbc.url}" 
		p:username="${jdbc.username}"
		p:password="${jdbc.password}"/>

    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"
          p:dataSource-ref="dataSource"/>
</beans>

运行UserJdbcWithoutTransManagerService，在控制台上打出如下的结果：
引用

defaultAutoCommit:true
score:30

   在jdbcWithoutTx.xml中，没有配置任何事务管理器，但是数据已经成功持久化到数据库中。在默认情况下，dataSource数据源的autoCommit被设置为true——这也意谓着所有通过JdbcTemplate执行的语句马上提交，没有事务。如果将dataSource的defaultAutoCommit设置为false，再次运行UserJdbcWithoutTransManagerService，将抛出错误，原因是新增及更改数据的操作都没有提交到数据库，所以代码清单10-1④处的语句因无法从数据库中查询到匹配的记录而引发异常。
   对于强调读速度的应用，数据库本身可能就不支持事务：如使用MyISAM引擎的MySQL数据库。这时，无须在Spring应用中配置事务管理器，因为即使配置了，也是没有实际用处的。

Hibernate访问数据库

   对于Hibernate来说，情况就有点复杂了。因为Hibernate的事务管理拥有其自身的意义，它和Hibernate一级缓存在密切的关系：当我们调用Session的save、update等方法时，Hibernate并不直接向数据库发送SQL语句，只在提交事务（commit）或flush一级缓存时才真正向数据库发送SQL。所以，即使底层数据库不支持事务，Hibernate的事务管理也是有一定好处的，不会对数据操作的效率造成负面影响。所以，如果是使用Hibernate数据访问技术，没有理由不配置HibernateTransactionManager事务管理器。
   但是，不使用Hibernate事务管理器，在Spring中，Hibernate照样也可以工作，来看下面的例子： 
package com.baobaotao.withouttx.hiber;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.io.ClassPathResource;
import org.springframework.core.io.Resource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.simple.SimpleJdbcTemplate;
import org.springframework.stereotype.Service;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.orm.hibernate3.HibernateTemplate;
import org.apache.commons.dbcp.BasicDataSource;
import org.springframework.test.jdbc.SimpleJdbcTestUtils;

import com.baobaotao.User;

@Service("hiberService")
public class UserHibernateWithoutTransManagerService {
    
   @Autowired
    private HibernateTemplate hibernateTemplate;

    public void addScore(String userName,int toAdd){
        User user = hibernateTemplate.get(User.class,userName);
        user.setScore(user.getScore()+toAdd);
        hibernateTemplate.update(user);
    }

    public static void main(String[] args) {
        ApplicationContext ctx = new
             ClassPathXmlApplicationContext("com/baobaotao/withouttx/hiber/hiberWithoutTx.xml");
        UserHibernateWithoutTransManagerService service = 
             (UserHibernateWithoutTransManagerService)ctx.getBean("hiberService");

        JdbcTemplate jdbcTemplate = (JdbcTemplate)ctx.getBean("jdbcTemplate");
        BasicDataSource basicDataSource = (BasicDataSource)jdbcTemplate.getDataSource();

        //①检查数据源autoCommit的设置
        System.out.println("autoCommit:"+ basicDataSource.getDefaultAutoCommit());

        //②插入一条记录，初始分数为10
        jdbcTemplate.execute("INSERT INTO t_user(user_name,password,score,last_logon_time) 
                            VALUES('tom','123456',10,"+System.currentTimeMillis()+")");

        //③调用工作在无事务环境下的服务类方法,将分数添加20分
        service.addScore("tom",20);
        
        //④查看此时用户的分数
        int score = jdbcTemplate.queryForInt(
                   "SELECT score FROM t_user WHERE user_name ='tom'");
        System.out.println("score:"+score);
        jdbcTemplate.execute("DELETE FROM t_user WHERE user_name='tom'");
    }
}

此时，采用hiberWithoutTx.xml的配置文件，其配置内容如下所示： 
<?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:p="http://www.springframework.org/schema/p"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
    http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd">
    <context:component-scan base-package="com.baobaotao.withouttx.hiber"/>
    …
    <bean id="sessionFactory"
          class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean"
          p:dataSource-ref="dataSource">
        <property name="annotatedClasses">
            <list>
                <value>com.baobaotao.User</value>
            </list>
        </property>
        <property name="hibernateProperties">
            <props>
                <prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop>
                <prop key="hibernate.show_sql">true</prop>
            </props>
        </property>
    </bean>

    <bean id="hibernateTemplate"
          class="org.springframework.orm.hibernate3.HibernateTemplate"
          p:sessionFactory-ref="sessionFactory"/>
                
</beans>

com.baobaotao.User是使用了Hibernate注解的领域对象，代码如下所示： 
package com.baobaotao;

import javax.persistence.Entity;
import javax.persistence.Table;
import javax.persistence.Column;
import javax.persistence.Id;
import java.lang.reflect.Field;
import java.io.Serializable;

@Entity
@Table(name="T_USER")
public class User implements Serializable{
    @Id
    @Column(name = "USER_NAME")
    private String userName;

    private String password;

    private int score;

    @Column(name = "LAST_LOGON_TIME")
    private long lastLogonTime = 0;

    …
}

   运行UserHibernateWithoutTransManagerService，程序正确执行，并得到类似于UserJdbcWithoutTransManagerService的执行结果。这说明Hibernate在Spring中，在没有事务管理器的情况下，依然可以正常地进行数据的访问。

  注：以上内容摘自《Spring 3.x企业应用开发实战》
返回顶楼
         
  • com0606
  • 等级: 初级会员
  • 性别:
  • 文章: 43
  • 积分: 60
  • 来自: 北京
   发表时间：2012-03-08  
通俗易懂，期待继续啊
返回顶楼
          回帖地址
0 请登录后投票
  • xiangxiangtang
  • 等级: 初级会员
  • 文章: 7
  • 积分: 40
  • 来自: 苏州
   发表时间：2012-03-08  
还好 我一般没有这样的问题，倒是觉得在分布式事务管理上，觉得问题挺多的，我不想用JTA，毕竟太慢了。
返回顶楼
          回帖地址
0 请登录后投票
  • richard_2010
  • 等级: 初级会员
  • 性别:
  • 文章: 272
  • 积分: 60
  • 来自: 杭州
   发表时间：2012-03-09  
xiangxiangtang 写道
还好 我一般没有这样的问题，倒是觉得在分布式事务管理上，觉得问题挺多的，我不想用JTA，毕竟太慢了。



分布式事务JTA实现比较复杂
现在一般分布式系统的实现考虑比较简单，就是把分布式事务分成两个本地事务
返回顶楼
          回帖地址
0 请登录后投票
  • yuechen323
  • 等级: 初级会员
  • 性别:
  • 文章: 29
  • 积分: 50
  • 来自: 北京
   发表时间：2012-03-09  
在mysql中如果表类型使用InnoDB Tables 或 BDB tables 就可以使用事务处理
返回顶楼
          回帖地址
0 请登录后投票
  • pudong
  • 等级: 初级会员
  • 性别:
  • 文章: 23
  • 积分: 0
  • 来自: 北京
   发表时间：2012-04-10  
我的配置如下：<?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:p="http://www.springframework.org/schema/p"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
    http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd">
<context:component-scan base-package="com.baobaotao.withouttx.hiber" />
<context:property-placeholder location="classpath:jdbc.properties" />
<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"
destroy-method="close" p:driverClassName="${jdbc.driverClassName}"
p:url="${jdbc.url}" p:username="${jdbc.username}" p:password="${jdbc.password}" />

<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"
p:dataSource-ref="dataSource" />

<bean id="sessionFactory"
class="org.springframework.orm.hibernate4.LocalSessionFactoryBean"
p:dataSource-ref="dataSource">
<property name="annotatedClasses">
<list>
<value>com.baobaotao.User</value>
</list>
</property>
<property name="hibernateProperties">
<props>
<prop key="hibernate.dialect">org.hibernate.dialect.OracleDialect</prop>
<prop key="hibernate.show_sql">true</prop>
<prop key="hibernate.current_session_context_class">thread</prop>
</props>
</property>
</bean>
</beans>

但是运行提示：
autoCommit:true
Exception in thread "main" org.hibernate.HibernateException: get is not valid without active transaction
at org.hibernate.context.internal.ThreadLocalSessionContext$TransactionProtectionWrapper.invoke(ThreadLocalSessionContext.java:348)
at $Proxy11.get(Unknown Source)
at com.baobaotao.withouttx.hiber.UserHibernateWithoutTransManagerService.addScore(UserHibernateWithoutTransManagerService.java:20)
at com.baobaotao.withouttx.hiber.UserHibernateWithoutTransManagerService.main(UserHibernateWithoutTransManagerService.java:45)
为什么？？？？
返回顶楼
          回帖地址
0 请登录后投票
论坛首页 → Java企业应用版

跳转论坛:
Global site tag (gtag.js) - Google Analytics