使用TransactionTemplate来完成Spring的编程式事务管理

<!-- 资源文件 -->
	<!-- DB2 dataSource-->
	<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
		<property name="driverClassName" value="${jdbc.driver}" />
		<property name="url" value="${jdbc.url}" />
		<property name="username" value="${jdbc.username}" />
		<property name="password" value="${jdbc.password}" />
	</bean>

	<!-- 定义事务管理器 -->
	<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
		<property name="dataSource" ref="dataSource" />
	</bean>
	
	<!-- 编程式事务模板,Spring的编程式事务可以通过TransactionTemplate的execute(TransactionCallback<T> action)方法来完成 -->
	<bean id="transactionTemplate" class="org.springframework.transaction.support.TransactionTemplate">
		<property name="transactionManager" ref="transactionManager" />
	</bean>

	<!-- jdbcTemplate -->
	 <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
		<property name="dataSource" ref="dataSource"/>
	</bean>
	
	<!-- TransactionTemplateFz -->
	 <bean id="transactionTemplateFz" class="com.suning.sel.eps.main.service.TransactionTemplateFz">
	</bean>
	
	<context:annotation-config />

import java.util.List;
import java.util.Map;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.testng.AbstractTestNGSpringContextTests;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.TransactionCallback;
import org.springframework.transaction.support.TransactionTemplate;
import org.testng.annotations.Test;

/**
 * 使用TransactionTemplate来完成Spring的编程式事务管理<br>
 * 〈功能详细描述〉
 * 
  * @see [相关类/方法]（可选）
 * @since [产品/模块版本] （可选）
 */
@ContextConfiguration(locations = { "file:src/main/webapp/WEB-INF/applicationContext.xml" })
public class TestTransactionTemplate extends AbstractTestNGSpringContextTests {
    // AbstractTestNGSpringContextTests方法执行完不会回滚,
    // AbstractTransactionalTestNGSpringContextTests在每个方法执行结束之后会把事务回滚，这样每次修改、新增、删除操作都可以执行多次

    @Autowired
    private JdbcTemplate jdbcTemplate;
    @Autowired
    private TransactionTemplate transactionTemplate;

    /**
     * 
     * 直接使用TransactionTemplate进行编程式事务管理 <br>
     * 〈功能详细描述〉
     * 
     * @see [相关类/方法](可选)
     * @since [产品/模块版本](可选)
     */
    @Test
    public void testTransactionTemplate() {
        // 设置事务的传播行为,默认是PROPAGATION_REQUIRED,也可使用默认值
        transactionTemplate.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);
        // 设置事务的隔离级别,默认是ISOLATION_DEFAULT:使用的是底层数据库的默认的隔离级别,也可使用默认值
        transactionTemplate.setIsolationLevel(TransactionDefinition.ISOLATION_READ_COMMITTED);
        // 设置是否只读，默认是false,也可使用默认值
        transactionTemplate.setReadOnly(true);
        // 默认使用的是数据库底层的默认的事务的超时时间,也可使用默认值
        transactionTemplate.setTimeout(30000);

        List<Map<String, Object>> userList = transactionTemplate
                .execute(new TransactionCallback<List<Map<String, Object>>>() {
                    @Override
                    public List<Map<String, Object>> doInTransaction(TransactionStatus status) {
                        return jdbcTemplate.queryForList("select * from sym_t_user");
                    }

                });
        System.out.println(userList);
    }
}

评论

1 楼 hzxlb910 2016-07-05