玩轉spring boot——結合JPA事務

一、準備工作

修改pom.xml文件

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 <modelVersion>4.0.0</modelVersion>

 <groupId>com.github.carter659</groupId>
 <artifactId>spring06</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <packaging>jar</packaging>

 <parent>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-parent</artifactId>
 <version>1.4.2.RELEASE</version>
 </parent>

 <name>spring06</name>
 <url>http://maven.apache.org</url>

 <properties>
 <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 <java.version>1.8</java.version>
 </properties>

 <dependencies>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-devtools</artifactId>
 <optional>true</optional>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-thymeleaf</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-data-jpa</artifactId>
 </dependency>
 <dependency>
 <groupId>mysql</groupId>
 <artifactId>mysql-connector-java</artifactId>
 </dependency>
 <dependency>
 <groupId>commons-dbcp</groupId>
 <artifactId>commons-dbcp</artifactId>
 </dependency>

 </dependencies>

 <build>
 <plugins>
 <plugin>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-maven-plugin</artifactId>
 </plugin>
 </plugins>
 </build>
</project>

pom.xml

添加src/resources/application.properties文件

spring.datasource.initialize=false
spring.datasource.url=jdbc:mysql://localhost:3306/demo
spring.datasource.username=root
spring.datasource.password=
spring.datasource.driver-class-name=com.mysql.jdbc.Driver

application.properties

添加src/resources/templates/index.html文件

<!DOCTYPE html>
<html xmlns:th="http://www.thymeleaf.org">
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8" />
<title>玩轉spring boot——結合JPA</title>
<script src="//cdn.bootcss.com/angular.js/1.5.6/angular.min.js"></script>
<script type="text/javascript">
 /*<![CDATA[*/
 var app = angular.module('app', []);
 app.controller('MainController', function(rootScope, scope, http) {

 scope.data = {};
 scope.rows = [];

 //添加
 scope.add = function() {
 scope.data = {
 no : 'No.1234567890',
 quantity : 100,
 'date' : '2017-01-01'
 };
 }

 //保存
 scope.save = function() {
 http({
 url : '/save',
 method : 'POST',
 data : scope.data
 }).success(function(r) {
 //保存成功后刷新
 window.location.reload();
 });
 }

 //初始化載入數據
 http({
 url : '/findAll',
 method : 'POST'
 }).success(function(rows) {
 for ( var i in rows) {
 var row = rows[i];
 scope.rows.push(row);
 }
 });

 });

 /*]]>*/
</script>
</head>
<body ng-app="app" ng-controller="MainController">
 <h1>玩轉spring boot——JPA事務</h1>
 <h4>
 <a href="http://www.cnblogs.com/GoodHelper/">from 劉冬的博客</a>
 </h4>
 <input type="button" value="添加" ng-click="add()" />
 <input type="button" value="保存" ng-click="save()" />
 <br />
 <br />
 <h3>訂單信息:</h3>
 <input type="hidden" ng-model="data.id" />
 <table cellspacing="1" style="background-color: #a0c6e5">
 <tr>
 <td>編號:</td>
 <td><input ng-model="data.no" /></td>
 <td>日期:</td>
 <td><input ng-model="data.date" /></td>
 <td>數量:</td>
 <td><input ng-model="data.quantity" /></td>
 </tr>
 </table>
 <br />

 <h3>訂單列表:</h3>
 <table cellspacing="1" style="background-color: #a0c6e5">
 <tr ng-repeat="row in rows" bgcolor='#F4FAFF'>
 <td>{{row.no}}</td>
 <td>{{row.date}}</td>
 <td>{{row.quantity}}</td>
 </tr>
 </table>

 <br />
 <a href="http://www.cnblogs.com/GoodHelper/">點擊訪問原版博客</a>
</body>
</html>

View Code

同上篇的Order類

package com.github.carter659.spring06;

import java.util.Date;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.Id;
import javax.persistence.Table;
import javax.persistence.Temporal;
import javax.persistence.TemporalType;

import org.hibernate.annotations.GenericGenerator;

/**
 * 博客出處:http://www.cnblogs.com/GoodHelper/
 * 
 * @author 劉冬
 *
 */
@Entity
@Table(name = "t_order")
public class Order {

 @Id
 @GeneratedValue(generator = "uuid")
 @GenericGenerator(name = "uuid", strategy = "uuid2")
 @Column(name = "order_id", length = 36)
 public String id;

 @Column(name = "order_no", length = 50)
 public String no;

 @Temporal(TemporalType.DATE)
 @Column(name = "order_date")
 public Date date;

 @Column(name = "quantity")
 public int quantity;

 /**
 * 省略 get set
 */
}

Order.java

新建實現JpaRepository的OrderRepository接口

package com.github.carter659.spring06;

import org.springframework.data.jpa.repository.JpaRepository;

/**
 * 博客出處:http://www.cnblogs.com/GoodHelper/
 * 
 * @author 劉冬
 *
 */
public interface OrderRepository extends JpaRepository<Order, String> {

}

OrderRepository.java

新建OrderDao類

package com.github.carter659.spring06;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;

import com.mysql.jdbc.StringUtils;

@Repository
public class OrderDao {

 @Autowired
 private OrderRepository orderRepository;

 /**
 * 獲取全部
 * 
 * @return
 */
 public List<Order> findAll() {
 return orderRepository.findAll();
 }

 /**
 * 持久化
 * 
 * @param entity
 * @return
 */
 public void save(Order entity) throws Exception {
 // 持久化
 orderRepository.save(entity);
 // 如果持久化成功,就拋出異常。如果開啟事務,那么剛才持久化的數據應回滾
 if (!StringUtils.isNullOrEmpty(entity.id))
 throw new Exception("測試無法持久化第一條數據的異常");
 }
}

假設:當成功insert一條數據后,拋出異常。如果事務生效,則數據會回滾。反之,則不回滾。

控制器:MainController

package com.github.carter659.spring06;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.propertyeditors.CustomDateEditor;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.WebDataBinder;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.InitBinder;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.ResponseBody;

/**
 * 博客出處:http://www.cnblogs.com/GoodHelper/
 * 
 * @author 劉冬
 *
 */
@Controller
public class MainController {

 @Autowired
 private OrderDao orderDao;

 /**
 * 處理日期類型
 * 
 * @param binder
 */
 @InitBinder
 public void initBinder(WebDataBinder binder) {
 SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
 dateFormat.setLenient(false);
 binder.registerCustomEditor(Date.class, new CustomDateEditor(dateFormat, true));
 }

 @GetMapping("/")
 public String index() {
 return "index";
 }

 /**
 * 持久化
 * 
 * @param entity
 * @return
 */
 @PostMapping("/save")
 public @ResponseBody Map<String, Object> save(@RequestBody Order entity) {
 Map<String, Object> result = new HashMap<>();
 try {
 orderDao.save(entity);
 result.put("success", true);
 } catch (Exception e) {
 result.put("success", false);
 }
 return result;
 }

 /**
 * 獲取全部
 * 
 * @return
 */
 @PostMapping("/findAll")
 public @ResponseBody Object findAll() {
 return orderDao.findAll();
 }
}

MainController.java

程序入口:App.java

package com.github.carter659.spring06;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

/**
 * 博客出處:http://www.cnblogs.com/GoodHelper/
 * 
 * @author 劉冬
 *
 */
@SpringBootApplication
public class App {

 public static void main(String[] args) {
 SpringApplication.run(App.class, args);
 }
}

App.java

運行效果:

添加數據

點擊保存按鈕,并觀察數據是否回滾:

雖然拋出異常,但數據并未回滾。

二、實現事務

這時,我修改OrderDao類,增加@Transactional(readOnly = false, rollbackFor = Throwable.class)注解:

package com.github.carter659.spring06;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import org.springframework.transaction.annotation.Transactional;

import com.mysql.jdbc.StringUtils;

@Repository
@Transactional(readOnly = false, rollbackFor = Throwable.class)
public class OrderDao {

 @Autowired
 private OrderRepository orderRepository;

 /**
 * 獲取全部
 * 
 * @return
 */
 public List<Order> findAll() {
 return orderRepository.findAll();
 }

 /**
 * 持久化
 * 
 * @param entity
 * @return
 */
 public void save(Order entity) throws Exception {
 // 持久化
 orderRepository.save(entity);
 // 如果持久化成功,就拋出異常。如果開啟事務,那么剛才持久化的數據應回滾
 if (!StringUtils.isNullOrEmpty(entity.id))
 throw new Exception("測試無法持久化第一條數據的異常");
 }
}