韩震博客|关注于学习java与交流

Spring 编程事物管理

java从业者 2017年07月07日 java框架知识 396 0

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

javacui.com/framework/223.html#" class="toolbar_item command_help help" style="color: rgb(0, 153, 204); text-decoration: none !important; border-radius: 0px !important; background: none !important; border: 0px !important; bottom: auto !important; float: none !important; height: auto !important; left: auto !important; line-height: 1.1em !important; margin: 0px !important; outline: 0px !important; overflow: visible !important; padding: 1px 0px 0px !important; position: static !important; right: auto !important; text-align: center !important; top: auto !important; vertical-align: baseline !important; width: auto !important; box-sizing: content-box !important; font-size: 1em !important; min-height: auto !important; display: block !important;">?
1
2
3
commons-pool.jar
commons-dbcp.jar
mysql-connector-java-5.1.5-bin.jar

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

1
2
3
4
5
6
7
DROP TABLE IF EXISTS `user`;
CREATE TABLE `user` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `age` int(11) DEFAULT NULL,
  `namevarchar(255) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

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

首先编辑applicationContext.xml,配置数据库连接属性:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="springframework.org/schema/beans" style="text-decoration: none; color: rgb(0, 153, 204); border-radius: 0px !important; background: none !important; border: 0px !important; bottom: auto !important; float: none !important; height: auto !important; left: auto !important; line-height: 1.1em !important; margin: 0px !important; outline: 0px !important; overflow: visible !important; padding: 0px !important; position: static !important; right: auto !important; top: auto !important; vertical-align: baseline !important; width: auto !important; box-sizing: content-box !important; font-size: 1em !important; min-height: auto !important;">http://www.springframework.org/schema/beans"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
 <!-- 数据源 -->
 <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
  <property name="driverClassName" value="com.mysql.jdbc.Driver" />
  <property name="username" value="root" />
  <property name="password" value="root" />
 </bean>
</beans>

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
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;
@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实例,代码如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
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内做异常捕捉,否则无法控制事物。


记得把网站分享出去哦,如果觉得网站不错的话,可以支持一下我哦!
看到这里如果这篇文章真的帮到你了,不妨打赏一下哦!

以上就是红色火线JAVA加油站整理的关于Spring 编程事物管理的文章,
希望可以帮到你,如果你有不同的见解可以留言指正哦,避免让别的java小伙伴在走挫折路。
Spring jdbcTemplate 常用操作示例
你是第一个吃螃蟹的人
发表评论

◎欢迎参与讨论,请在这里发表您的看法、交流您的观点。

分享:

支付宝

微信