手机端小强原创文章,java小强个人博客站点
当前位置: 首页 >> 框架 >> Spring 编程事物管理

Spring 编程事物管理

21920 框架 | 2014-11-24

除了Spring的DIST下的包外,加入:

commons-pool.jar
commons-dbcp.jar
mysql-connector-java-5.1.5-bin.jar

这里使用的是mysql数据库,在test库内创建表:

DROP TABLE IF EXISTS `user`;
CREATE TABLE `user` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `age` int(11) DEFAULT NULL,
  `name` varchar(255) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

编程式事物相对声明式事物有些繁琐,但是还是有其独到的优点。编程式的事物管理可以清楚的控制事务的边界,自行控制事物开始、撤销、超时、结束等,自由控制事物的颗粒度。
借用Spring MVC 入门示例http://www.javacui.com/Framework/224.html 的代码。这里直接在Action层直接做代码示例,并使用注解进行属性注入:

首先编辑applicationContext.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:mvc="http://www.springframework.org/schema/mvc"
       xmlns:p="http://www.springframework.org/schema/p"
       xmlns:context="http://www.springframework.org/schema/context"
       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-3.0.xsd
   http://www.springframework.org/schema/context 
   http://www.springframework.org/schema/context/spring-context-3.0.xsd
   http://www.springframework.org/schema/aop 
   http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
   http://www.springframework.org/schema/tx 
   http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
   http://www.springframework.org/schema/mvc 
   http://www.springframework.org/schema/mvc/spring-mvc-3.0.xsd
   http://www.springframework.org/schema/context 
   http://www.springframework.org/schema/context/spring-context-3.0.xsd">
 <!-- 数据源 -->
 <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
  <property name="driverClassName" value="com.mysql.jdbc.Driver" />
  <property name="url" value="jdbc:mysql://localhost:3306/test?useUnicode=true&amp;characterEncoding=UTF-8" />
  <property name="username" value="root" />
  <property name="password" value="root" />
 </bean>
</beans>

Spring提供两种实现方式,使用PlatformTransactionManager或TransactionTemplate。
以下示例使用PlatformTransactionManager的实现类DataSourceTransactionManager来完成。

package test;
import java.util.Date;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.sql.DataSource;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.DefaultTransactionDefinition;
import org.springframework.web.bind.annotation.RequestMapping;
// http://localhost:8080/spring/hello.do?user=java
@org.springframework.stereotype.Controller
public class HelloController{
 private DataSourceTransactionManager transactionManager;
 private DefaultTransactionDefinition def;
 private JdbcTemplate jdbcTemplate;
 @SuppressWarnings("unused")
 // 使用注解注入属性
 @Autowired
 private void setDataSource(DataSource dataSource){
  jdbcTemplate = new JdbcTemplate(dataSource);
  transactionManager = new DataSourceTransactionManager(dataSource);
  // 事物定义
  def = new DefaultTransactionDefinition();
  // 事物传播特性
  def.setPropagationBehavior(DefaultTransactionDefinition.PROPAGATION_REQUIRED);
//  def.setReadOnly(true); // 指定后会做一些优化操作,但是必须搭配传播特性,例如:PROPAGATION_REQUIRED,PROPAGATION_REQUIRES_NEW,PROPAGATION_NESTED
//  def.setTimeout(1000); // 合理的超时时间,有助于系统更加有效率
 }
 @SuppressWarnings("deprecation")
 @RequestMapping("/hello.do")
 public String hello(HttpServletRequest request,HttpServletResponse response){
  request.setAttribute("user", request.getParameter("user") + "-->" + new Date().toLocaleString());
  TransactionStatus status = transactionManager.getTransaction(def);
  try {
   jdbcTemplate.update(" update user set age=age+1; ");
   // 发生异常
   jdbcTemplate.update(" update user set age='test'; ");
   transactionManager.commit(status);
  } catch (Exception e) {
   transactionManager.rollback(status);
  }
  return "hello";
 }
}

也可以使用TransactionTemplate来实现,它需要一个TransactionManager实例,代码如下:

package test;
import java.util.Date;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.sql.DataSource;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.DefaultTransactionDefinition;
import org.springframework.transaction.support.TransactionCallback;
import org.springframework.transaction.support.TransactionTemplate;
import org.springframework.web.bind.annotation.RequestMapping;
@org.springframework.stereotype.Controller
public class HelloController{
 private DataSourceTransactionManager transactionManager;
 private DefaultTransactionDefinition def;
 private JdbcTemplate jdbcTemplate;
 @SuppressWarnings("unused")
 @Autowired
 private void setDataSource(DataSource dataSource){
  jdbcTemplate = new JdbcTemplate(dataSource);
  transactionManager = new DataSourceTransactionManager(dataSource);
  def = new DefaultTransactionDefinition();
  def.setPropagationBehavior(DefaultTransactionDefinition.PROPAGATION_REQUIRED);
 }
 @SuppressWarnings({ "deprecation", "unchecked" })
 @RequestMapping("/hello.do")
 public String hello(HttpServletRequest request,HttpServletResponse response){
  request.setAttribute("user", request.getParameter("user") + "-->" + new Date().toLocaleString());
  TransactionTemplate transactionTemplate = new TransactionTemplate(transactionManager);
  Object obj = null;
  try {
   // 不需要返回值使用TransactionCallbackWithoutResultback
   obj = transactionTemplate.execute(new TransactionCallback(){
    public Object doInTransaction(TransactionStatus arg0) {
     jdbcTemplate.update(" update user set age=age+1; ");
     // 发生异常
     jdbcTemplate.update(" update user set age='test'; ");
     return 1;
    }
   });
  } catch (Exception e) {
   e.printStackTrace();
  }
  System.out.println(obj);
  return "hello";
 }
}

注意,不要再doInTransaction内做异常捕捉,否则无法控制事物。


推荐您阅读更多有关于“ spring mvc 事物 撤销 applicationContext ”的文章

上一篇:Spring MVC 入门示例 下一篇:努力,就是在酿酒

猜你喜欢

发表评论:

个人资料
blogger

java小强
没有思考,人生的路会越走越难!

搜索
分类
最新微语
  • 今日北京再次沙尘暴来袭,吃了几年细粮,终于能来口粗粮了,不过大早上看见这场景,还是吓我一跳,不过随后就平静了,毕竟是老朋友了。进公司又发现一股烤糊的味道,真是祸不单行啊,例外都是污染。发了两个口罩,开启保护模式。

    2017-05-04 10:16

  • 今天同学问我,最近还在写代码吗?我想了想,这个问题怎么回答呢,我好像确实很长时间,虽然写了一些,但是主要内容已经不是写代码了。然后再想想,自己也7年多了,这么多年了,我收获了什么,我的目标到底是什么。眼看就奔三了,人生啊,开启感叹模式。

    2017-03-30 22:52

  • 也许大家都已经注意到了,今年的房价,好多地方都是翻了一番,跟着就是,各地房东开始变相涨租。今年之所以搬走,就是为此,这两天同学也是如此。很多房东只认钱,别谈感情,伤钱。而对于这个城市来说,你怎么定位自己,你真把自己当成她的一份子?你来此为何?将来何去何从?自己掂量清楚。

    2016-12-05 10:03

  • 为什么一直不写了呢?因为当爸爸了,没空了。今年的冬天,有些寒冷,除了这寒冬带来的不适,更有因乐视公司遇到危机,而带来的同事别离。送别同事,看着空旷的工位,心中有些悲凉。临近年关,此时此刻,该怎么做,似乎不再是脑子一热那么简单了。

    2016-11-24 11:28

  • 已经请假,加上国庆,要很长一段时间不在北京了。919加班,搞的现在有点心累,胸闷,身体不适。看来,我要好好休息一下了。这几天有些冷,2016的冬天,一步步来了,各位亲友,记得添衣加粗啊。

    2016-09-23 17:29

  • 更多»

最新文章
热门文章
随机文章