Spring框架深入（三）--事务

/*
 * 当前线程上下文空间
 * 将session放入当前线程变量中
 * 如果当前线程有该对象，就直接拿来用
 * 如果没有，才去新建对象
 * */
public class SessionFactoryUtil {
    private static ThreadLocal threadLocal = new ThreadLocal();    
    public static SqlSession getSqlSession() {    
        SqlSession session = (SqlSession) threadLocal.get();
        if(session!=null) {
            return session;
        }
        else{
            session=new SqlSession();
            threadLocal.set(session);
            return session;
        }
    }
}

public void run() {
    //这两个dao操作时属于同一个事务的，也就是dao操作所使用的sqlSession是同一个
    userDao.buy();
    productDao.updatePruduct();
}

public class Author {
    private int id;
    private String username;
    private String password;
    private String email;
    private String bio;
}

public interface AuthorMapper {
    public Author findById(int id);

    public void insertAuthor(Author aut);
}

<!-- 
    AOP 事务配置 
        核心业务：service——已完成
        切面bean：Spring提供支持类，进行配置
        建立切入点aop关联，进行配置
-->
    
<!-- 配置事务管理器：切面的一部分 -->
<bean id="transManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <property name="dataSource" ref="dataSource"></property>
</bean>
    
<!-- 
    配置事务策略状态：切面的一部分 
    事务通知的配置
-->
<tx:advice id="txAdvice" transaction-manager="transManager">
    <tx:attributes>
        <!-- 
            对应的方法与事务的使用 
            REQUIRED：在事务中执行，如果事务不存在，则会重新创建一个
            SUPPORTS：使用当前的环境执行，如果当前存在事务，则会使用这个事务，如果当前没有这个事务，则不使用事务
        -->
        <tx:method name="add*" propagation="REQUIRED"/>
        <tx:method name="insert*" propagation="REQUIRED"/>
        <tx:method name="del*" propagation="REQUIRED"/>
        <tx:method name="update*" propagation="REQUIRED"/>
        <tx:method name="find*" propagation="SUPPORTS" read-only="true"/>
        <tx:method name="get*" propagation="SUPPORTS" read-only="true"/>
        <tx:method name="select*" propagation="SUPPORTS" read-only="true"/>
    </tx:attributes>
</tx:advice>
    
<!-- 核心业务与事务关联起来 -->
<aop:config>
    <!-- 切入点 -->
    <aop:pointcut expression="execution(* service.*.*.*(..))" id="transPointCut"/>
    <!-- 关联操作 -->
    <aop:advisor advice-ref="txAdvice" pointcut-ref="transPointCut"/>
</aop:config>    

<!-- 配置注解驱动，标注@Transactional的类和方法都具有事务性 -->
<tx:annotation-driven transaction-manager="transManager"/>

@Transactional
@Override
public void doFindAndInsert() {
    Author aut=new Author();
    aut.setBio("test");
    aut.setEmail("test");
    aut.setPassword("test");
    aut.setUsername("test");
    authorMapper.insertAuthor(aut);
                
    //报错的时候，回滚
    int i=5/0;
                
    Author author = authorMapper.findById(1);
    System.out.println(author);
    return null;    
}

<!-- 
    基于事务模板
    用于支持事务的模板bean
 -->
<bean id="txTemplate" class="org.springframework.transaction.support.TransactionTemplate">
    <constructor-arg type="org.springframework.transaction.PlatformTransactionManager" ref="transManager"></constructor-arg>
</bean>

public void doFindAndInsert() {
    txTemplate.execute(new  TransactionCallback<Integer>() {

        @Override
        public Integer doInTransaction(TransactionStatus arg0) {
            // TODO Auto-generated method stub
            Author aut=new Author();
            aut.setBio("test");
            aut.setEmail("test");
            aut.setPassword("test");
            aut.setUsername("test");
            authorMapper.insertAuthor(aut);
                
            //报错的时候，回滚
            int i=5/0;
                
            Author author = authorMapper.findById(1);
            System.out.println(author);
            return null;
        }
    });
}