[SXT][WY]Spring08 事务

===============  采用编程式事务 =====================

 

引入这个机制的情况：系统日志在hibernate存入数据库的时候，涉及到 tbluser 和 tbllog 两个表。这两个表要么同时存入数据，要么同时不存入。所以把这两个表的操作 放到一个事务中。

 

（系统日志 区别与 编程常用的 调试日志，调试日志 是输出到文件或者控制台 的。他们的作用也不一样）

 

本例子中，和之前hibernate的例子比较，改动地方如下(本例子中，没有涉及到spring)：

 

a、hibernate.cfg.xml

<!DOCTYPE hibernate-configuration PUBLIC
    "-//Hibernate/Hibernate Configuration DTD 3.0//EN"
    "http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd">

<hibernate-configuration>
    <session-factory>
        <property name="hibernate.connection.url">jdbc:mysql://localhost/spring_hibernate_1</property>
        <property name="hibernate.connection.driver_class">com.mysql.jdbc.Driver</property>
        <property name="hibernate.connection.username">root</property>
        <property name="hibernate.connection.password">bjsxt</property>
        <property name="hibernate.dialect">org.hibernate.dialect.MySQLDialect</property>
        <property name="hibernate.show_sql">true</property>
        <property name="hibernate.current_session_context_class">thread</property>
        <!--
        <property name="hibernate.current_session_context_class">jta</property>
         -->       
        <mapping resource="com/bjsxt/usermgr/model/User.hbm.xml"/>
        <mapping resource="com/bjsxt/usermgr/model/Log.hbm.xml"/>
    </session-factory>
</hibernate-configuration>

 

b、UserManagerImpl.java

import java.util.Date;
import org.hibernate.Session;
import com.bjsxt.usermgr.model.Log;
import com.bjsxt.usermgr.model.User;
import com.bjsxt.usermgr.util.HibernateUtils;

public class UserManagerImpl implements UserManager {

    public void addUser(User user) {
        Session session = null;
        try {
            //session = HibernateUtils.getSession();

            // 下面这句话的含义是，拿到当前线程中的session
            session = HibernateUtils.getSessionFactory().getCurrentSession();
            session.beginTransaction();
            // 这里保存，既 完成了 本事物的一半的任务
            session.save(user);

            //Integer.parseInt("asdfsdfsfsd"); // 这句话 做回滚实验用
            Log log = new Log();
            log.setType("安全日志");
            log.setDetail("xxx进入系统");
            log.setTime(new Date());

            LogManager logManager = new LogManagerImpl();

            // 这里调用保存， 完成 本 事务的另一半任务
            logManager.addLog(log);

            session.getTransaction().commit();
        }catch(Exception e) {
            e.printStackTrace();
            session.getTransaction().rollback();
//        }finally {
//            HibernateUtils.closeSession(session);
        }
    }
}

 

LogManagerImpl.java

import com.bjsxt.usermgr.model.Log;
import com.bjsxt.usermgr.util.HibernateUtils;

public class LogManagerImpl implements LogManager {

    public void addLog(Log log) {

        // 这里拿到的session 是 和 上面的 一样的session
        HibernateUtils.getSessionFactory().getCurrentSession() .save(log);
    }

}

 

下面是 视频 中的总结：

 

1、getCurrentSession()与openSession()的区别？
    * 采用getCurrentSession()创建的session会绑定到当前线程中，而采用openSession()
      创建的session则不会
    * 采用getCurrentSession()创建的session在commit或rollback时会自动关闭，而采用openSession()
      创建的session必须手动关闭
     
2、使用getCurrentSession()需要在hibernate.cfg.xml文件中加入如下配置：
    * 如果使用的是本地事务（jdbc事务）
    <property name="hibernate.current_session_context_class">thread</property>
    * 如果使用的是全局事务（jta事务）
    <property name="hibernate.current_session_context_class">jta</property>      

 

 

===============  采用声明式事务 =====================

 

编写业务逻辑方法：
    * 继承HibernateDaoSupport类，使用HibernateTemplate来持久化，HibernateTemplate是
      Hibernate Session的轻量级封装
    * 默认情况下运行期异常 才会回滚（包括继承了RuntimeException子类），普通异常 是不会滚的
    * 编写业务逻辑方法时，最好将异常一直向上抛出，在表示层（struts）处理
    * 关于事务边界的设置，通常设置到业务层 ，不要添加到Dao上 

 

相关的类如下：

UserManagerImpl.java(这个类可以理解为BO，实现业务逻辑。对象的保存功能应该放到DAO中，这里直接存是为了方便)

import java.util.Date;

import org.hibernate.Session;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

import com.bjsxt.usermgr.model.Log;
import com.bjsxt.usermgr.model.User;
import com.bjsxt.usermgr.util.HibernateUtils;

public class UserManagerImpl extends HibernateDaoSupport implements UserManager {
   
    private LogManager logManager;
   
    public void addUser(User user) {
        this.getHibernateTemplate().save(user); // 在这个方法调用之前，就已经启动了 事务
        Log log = new Log();
        log.setType("安全日志");
        log.setDetail("xxx进入系统");
        log.setTime(new Date());
        logManager.addLog(log); // 这个方法中存储动作，使用的是一个事务
        throw new java.lang.RuntimeException();
    }

 

/*  这里是 通过抛出异常 做 回滚 测试

public void addUser(User user)
    throws Exception {
        this.getHibernateTemplate().save(user);
        Log log = new Log();
        log.setType("安全日志");
        log.setDetail("xxx进入系统");
        log.setTime(new Date());
        logManager.addLog(log);
        throw new Exception();
    }*/

    public void setLogManager(LogManager logManager) {
        this.logManager = logManager;
    }
}

 

LogManagerImpl.java

import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

import com.bjsxt.usermgr.model.Log;
import com.bjsxt.usermgr.util.HibernateUtils;

public class LogManagerImpl extends HibernateDaoSupport implements LogManager {

    public void addLog(Log log) {
        this.getHibernateTemplate().save(log);
    }
}

 

Client.java

import org.springframework.beans.factory.BeanFactory;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.bjsxt.usermgr.manager.UserManager;
import com.bjsxt.usermgr.manager.UserManagerImpl;
import com.bjsxt.usermgr.model.User;

public class Client {

    public static void main(String[] args) {
        User user = new User();
        user.setName("张三");
        // 注意这里的写法
        BeanFactory factory = new ClassPathXmlApplicationContext("applicationContext-*.xml");
        UserManager userManager = (UserManager)factory.getBean("userManager");
        try {
            userManager.addUser(user);
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

spring的配置文件 按照功能 分两块写，

applicationContext-Common.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:aop="http://www.springframework.org/schema/aop"
         xmlns:tx="http://www.springframework.org/schema/tx"
         xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
           http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.0.xsd
           http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.0.xsd">
    <!-- 配置sessionFactory -->
    <bean id="sessionFactory" class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
        <property name="configLocation">
            <value>classpath:hibernate.cfg.xml</value>   // 这里的 hibernate配置，在另外一个文件中
        </property>   
    </bean>           
   
    <!-- 配置事务管理器 -->
    <bean id="transactionManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager">
        <property name="sessionFactory">
            <ref bean="sessionFactory"/>
        </property>   
    </bean>
   
    <!-- 配置事务的传播特性 -->
    <tx:advice id="txAdvice" transaction-manager="transactionManager">
        <tx:attributes>
            <tx:method name="add*" propagation="REQUIRED"/> // 其他类型的 传播特性 很少用到
            <tx:method name="del*" propagation="REQUIRED"/>
            <tx:method name="modify*" propagation="REQUIRED"/>
            <tx:method name="*" read-only="true"/> //意思是 除了上面三个方法外，其他方法都是”只读“，这样就不用开启 事务 ， 可以提高运行效率。
        </tx:attributes>
    </tx:advice>
   
    <!-- 那些类的哪些方法参与事务 -->
    <aop:config>
        <aop:pointcut id="allManagerMethod" expression="execution(* com.bjsxt.usermgr.manager.*.*(..))"/>
        <aop:advisor pointcut-ref="allManagerMethod" advice-ref="txAdvice"/>
    </aop:config>
</beans>

 

 

applicationContext-beans.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:aop="http://www.springframework.org/schema/aop"
         xmlns:tx="http://www.springframework.org/schema/tx"
         xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
           http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.0.xsd
           http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.0.xsd">
   
    <bean id="userManager" class="com.bjsxt.usermgr.manager.UserManagerImpl">
        <property name="sessionFactory" ref="sessionFactory"/>
        <property name="logManager" ref="logManager"/>
    </bean>
   
    <bean id="logManager" class="com.bjsxt.usermgr.manager.LogManagerImpl">
        <property name="sessionFactory" ref="sessionFactory"/>
    </bean>
</beans>