`

对TransactionTemplate进行封装,使用程序调用更加简单

阅读更多
<!-- 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 org.springframework.transaction.TransactionDefinition;

/**
 * 事务特性进行封装<br>
 * 〈功能详细描述〉
 * 
 * @see [相关类/方法](可选)
 * @since [产品/模块版本] (可选)
 */
public class TransactionDefinitionFz {

    /**
     * 事务的传播行为:默认是TransactionDefinition.PROPAGATION_REQUIRED
     */
    private int propagationBehavior = TransactionDefinition.PROPAGATION_REQUIRED;

    /**
     * 事务的隔离级别:默认是ISOLATION_DEFAULT:使用的是底层数据库的默认的隔离级别,也可使用默认值TransactionDefinition.ISOLATION_DEFAULT
     */
    private int isolationLevel = TransactionDefinition.ISOLATION_DEFAULT;

    /**
     * 是否可读:默认是false
     */
    private boolean readOnly = false;

    /**
     * 事务的超时时间:默认使用的是数据库底层的默认的事务的超时时间,也可使用默认值TransactionDefinition.TIMEOUT_DEFAULT
     */
    private int timeout = TransactionDefinition.TIMEOUT_DEFAULT;

    public int getPropagationBehavior() {
        return propagationBehavior;
    }

    public void setPropagationBehavior(int propagationBehavior) {
        this.propagationBehavior = propagationBehavior;
    }

    public int getIsolationLevel() {
        return isolationLevel;
    }

    public void setIsolationLevel(int isolationLevel) {
        this.isolationLevel = isolationLevel;
    }

    public boolean isReadOnly() {
        return readOnly;
    }

    public void setReadOnly(boolean readOnly) {
        this.readOnly = readOnly;
    }

    public int getTimeout() {
        return timeout;
    }

    public void setTimeout(int timeout) {
        this.timeout = timeout;
    }

}


/**
 * 对TransactionTemplate进行封装,使用程序调用更加简单<br>
 * 〈功能详细描述〉
 * 
 * @see [相关类/方法](可选)
 * @since [产品/模块版本] (可选)
 */
public class TransactionTemplateFz {
    @Autowired
    private TransactionTemplate transactionTemplate;

    /**
     * 
     * 使用默认的事务的相关特性进行编程事务管理 <br>
     * 〈功能详细描述〉
     * 
     * @param action
     * @return
     * @see [相关类/方法](可选)
     * @since [产品/模块版本](可选)
     */
    public <T> T execute(final TransactionCallbackFz<T> action) {
        return transactionTemplate.execute(new TransactionCallback<T>() {
            @Override
            public T doInTransaction(TransactionStatus status) {
                return action.doInTransaction();
            }
        });
    }

    public <T> T execute(final TransactionCallbackFz<T> action, TransactionDefinitionFz transactionDefinitionFz) {
        if (transactionDefinitionFz != null) {
            // 设置事务的传播行为,默认是PROPAGATION_REQUIRED,也可使用默认值
            transactionTemplate.setPropagationBehavior(transactionDefinitionFz.getPropagationBehavior());
            // 设置事务的隔离级别,默认是ISOLATION_DEFAULT:使用的是底层数据库的默认的隔离级别,也可使用默认值
            transactionTemplate.setIsolationLevel(transactionDefinitionFz.getIsolationLevel());
            // 设置是否只读,默认是false,也可使用默认值
            transactionTemplate.setReadOnly(transactionDefinitionFz.isReadOnly());
            // 默认使用的是数据库底层的默认的事务的超时时间,也可使用默认值
            transactionTemplate.setTimeout(transactionDefinitionFz.getTimeout());
        }

        return transactionTemplate.execute(new TransactionCallback<T>() {
            @Override
            public T doInTransaction(TransactionStatus status) {
                return action.doInTransaction();
            }
        });
    }
}



/**
 * 回调接口,在使用编程事务管理时使用回调接口传入相关的DB操作<br>
 * 〈功能详细描述〉
 * 
 * @see [相关类/方法](可选)
 * @since [产品/模块版本] (可选)
 */
public interface TransactionCallbackFz<T> {
    T doInTransaction();
}



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.testng.annotations.Test;

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

    @Autowired
    private JdbcTemplate jdbcTemplate;

    @Autowired
    private TransactionTemplateFz transactionTemplatefz;

    /**
     * 
     * 直接使用TransactionTemplate进行编程式事务管理 <br>
     * 〈功能详细描述〉
      * 
     * @see [相关类/方法](可选)
     * @since [产品/模块版本](可选)
     */
    @Test
    public void testTransactionTemplateFz() {
        TransactionDefinitionFz definition = new TransactionDefinitionFz();
        definition.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);
        definition.setIsolationLevel(TransactionDefinition.ISOLATION_READ_COMMITTED);
        definition.setReadOnly(true);
        definition.setTimeout(3000);

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

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


分享到:
评论

相关推荐

    Mybatis通用DAO设计封装(mybatis)

    Mybatis通用DAO设计封装主要涉及的是在Java开发中如何高效地使用Mybatis框架进行数据库操作。Mybatis是一款轻量级的持久层框架,它避免了几乎所有的JDBC代码和手动设置参数以及获取结果集。通过提供自定义SQL、存储...

    springboot+redis+mybatis事务和引擎模板

    - 验证Key是否存在可以调用`keys()`方法,设置超时时间使用`expireAt()`或`expire()`。 5. **事务管理**: - Spring Boot支持声明式事务管理,通过`@Transactional`注解在方法级别启用事务。当方法执行过程中出现...

    详细说明spring事务配置的5种方式

    `TransactionTemplate`封装了`PlatformTransactionManager`,你可以通过`execute`方法传递一个回调函数,该函数将在事务上下文中执行。 每种事务配置方式都有其适用场景,选择哪种方式取决于项目需求和团队偏好。...

    Spring事务与Java事务比较

    总结来说,Spring 框架的事务管理与 Java 原生的事务管理相比,具有更高的抽象层次和更好的可配置性,使得事务管理更加简单和高效。通过 Spring 的 IOC 容器和 AOP 机制,开发者可以更专注于业务逻辑的实现,而将...

    spring学习之八--Hibernate编程式事务

    以下是一个简单的示例,展示了如何使用TransactionTemplate进行事务管理: ```java @Autowired private TransactionTemplate transactionTemplate; @Autowired private HibernateTemplate hibernateTemplate; ...

    spring-jdbc.rar_goldenw65_map25w_sellwof_spring-jdbc

    例如,如何使用`JdbcTemplate`进行简单的查询和更新操作,以及如何在复杂场景下利用`NamedParameterJdbcTemplate`处理带参数的SQL。 五、最佳实践与注意事项 1. **使用PreparedStatement**:Spring JDBC鼓励使用...

    Spring对JDBC的支持jar包.rar

    "spring-jdbc-4.3.7.RELEASE.jar"是Spring对JDBC进行抽象和封装的模块,它提供了数据库访问的高层API,使得数据库操作变得简单且易管理。主要特性包括: 1. 数据源管理:Spring通过DataSource接口,帮助开发者配置...

    spring hibernatetemplate

    然而,正如描述中所指出的,直接使用`HibernateTemplate`进行事务管理并不总是最佳实践,尤其是在涉及复杂的事务控制时。在本文中,我们将深入探讨`HibernateTemplate`的工作原理以及为什么在某些情况下应考虑使用`...

    spring编程式事务实现

    本篇文章将聚焦于编程式事务管理,特别是如何通过`TransactionTemplate`进行事务控制。 1. **Spring编程式事务管理**: 编程式事务管理允许开发者在代码中直接控制事务的开始、提交、回滚等操作。这种方式提供了更...

    Spring教程

    - **使用TransactionTemplate**:简化了事务管理的过程。 - **使用PlatformTransactionManager**:提供了更高级别的事务管理。 **7.3 JDBC声明式事务管理** 除了编程序事务管理外,还可以使用声明式事务管理: - *...

    Spring事务管理和SpringJDBC思维导图

    接着,我们来看Spring JDBC,它是Spring对Java数据库连接(JDBC)的封装,简化了数据库操作。Spring JDBC提供了一个JdbcTemplate类,该类处理了JDBC的琐碎部分,如打开和关闭连接、处理异常和自动提交。JdbcTemplate...

    Spring高级之注解驱动开发视频教程

    AOP是让方法间的各个部分更加独立,达到统一调用执行,使后期维护更加的方便。 SpringMVC本身是对Servlet和JSP的API进行了封装,同时在此基础上进一步加强。它推出的一套注解,可以降低开发人员的学习成本,从而更...

    spring 的详细使用

    编程式事务管理则通过 TransactionTemplate 或 PlatformTransactionManager 接口手动进行事务操作。 **Spring 注解** Spring 提供了一系列注解,如 @Component、@Service、@Repository 和 @Controller,用于组件...

    Spring事务管理4种方式

    它封装了事务的开始、提交和回滚,使得事务处理更加简洁。示例代码如下: ```java TransactionTemplate transactionTemplate = new TransactionTemplate(transactionManager); transactionTemplate.execute(new ...

    spring jdbc 事务

    3. 使用TransactionTemplate或者直接调用PlatformTransactionManager的方法来管理事务的生命周期。 **声明式事务管理**: 1. 基于注解(@Transactional):在需要事务的方法上添加该注解,Spring会自动处理事务的...

    java事务 - 模板设计模式

    通过这种方式,我们可以将事务管理的复杂性封装在一个模板类中,使得业务代码更加简洁和易于维护。在实际项目中,我们可能还会利用ThreadLocal来进一步优化事务的管理。ThreadLocal是一个线程局部变量,它可以为每个...

    千锋最新版spring6.0框架GA版详解.pdf

    它提供了一种简单的方式来解决企业级应用中常见的问题,并通过依赖注入(Dependency Injection, DI)和面向切面编程(Aspect-Oriented Programming, AOP)等技术实现了对应用程序的解耦。 2. **Spring起源** ...

    spring4和hibernate4.2和axis2整合

    3. 集成Hibernate:在Service层,使用@Autowired注解注入SessionFactory和TransactionTemplate,然后在需要的地方调用它们。这将确保Spring在适当的时候创建和管理Hibernate的对象。 4. 创建Axis2服务:定义一个...

    火炬博客系统5

    使用该框架开发MVC程序变的非常简单,Struts对 MVC层的Model、View、和Controller都提供了对应的实现组件。Struts框架中Controller角色是由一个中心Servlet类和众多Action类合作扮演的,中心Servlet类为控制器提供...

Global site tag (gtag.js) - Google Analytics