本指南将引导您完成用非侵入性事务操作数据库的过程，您将构建一个简单的JDBC应用程序，在该应用程序中，您可以使用事务操作数据库，而无需编写专门的JDBC代码。数据库事务是数据库管理系统执行过程中的一个逻辑单位，由一个有限的数据库操作序列构成。在实际项目中，经常用到，比如转帐，一个人的增加，一个人的钱减少，这个必须要一起完成，不能一个人钱增加了，另一个人钱没减少；或一个人钱减少，另一个人钱没增加。这些操作就需要放在一个事务里。面试经常问到事务的ACID的问题，大家可以自行了解。
我利用业余时间，翻译了Spring官网的例子，方便中文不好的同学，将陆续发到头条上，欢迎大家关注，也可以上我个人BLOG：itmanclub.com，上面有已经翻译过的。
程序结构
└── src └── main └── java └── hello
pom.xml文件
<?xml version="1.0" encoding="UTF-8"?> <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 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>org.springframework</groupId> <artifactId>gs-managing-transactions</artifactId> <version>0.1.0</version> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.1.6.RELEASE</version> </parent> <properties> <java.version>1.8</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-jdbc</artifactId> </dependency> <dependency> <groupId>com.h2database</groupId> <artifactId>h2</artifactId> <scope>runtime</scope> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>
Spring Boot将会你做如下的事:
- 将 classpath 里面所有用到的jar包构建成一个可执行的 JAR 文件，方便执行你的程序
- 搜索public static void main()方法并且将它当作可执行类
- 根据springboot版本，去查找相应的依赖类版本，当然你可以定义其它版本。
创建一个定单服务
从考虑服务交互开始这个过程。
首先，使用BookingService类创建一个基于JDBC的服务，该服务按名称将人员预订到系统中。
src/main/java/hello/BookingService.java
package hello;
import java.util.List;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;
@Component
public class BookingService {
private final static Logger logger = LoggerFactory.getLogger(BookingService.class);
private final JdbcTemplate jdbcTemplate;
public BookingService(JdbcTemplate jdbcTemplate) {
this.jdbcTemplate = jdbcTemplate;
}
@Transactional
public void book(String... persons) {
for (String person : persons) {
logger.info("预定 " + person + " 在一个座位上...");
jdbcTemplate.update("insert into BOOKINGS(FIRST_NAME) values (?)", person);
}
}
public List<String> findAllBookings() {
return jdbcTemplate.query("select FIRST_NAME from BOOKINGS",
(rs, rowNum) -> rs.getString("FIRST_NAME"));
}
}
代码有一个自动注入的JdbcTemplate，这是一个容易使用的模板类，可以完成下面代码所需的所有数据库交互。
您还有一个预定多人的预定方法。它循环浏览人员列表，并为每个人使用JdbcTemplate将其插入预订表中。此方法被标记为@Transactional，这意味着任何失败都会导致整个操作回滚到以前的状态，并重新引发原始异常。这意味着如果有多个人，一个人不能被添加到预订中，就不会有任何人被添加到预订中。
您还可以使用findAllBookings方法查询数据库。从数据库中提取的每一行都被转换成一个字符串，然后组合成一个列表。
创建一个Application
src/main/java/hello/Application.java
package hello;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}
您的应用程序是0配置。SpringBoot将在类路径上检测SpringJDBC，然后H2自动为您创建一个数据源和一个JdbcTemplate。因为这样的基础结构现在可用，并且您没有专用的配置，所以还将为您创建一个DataSourceTransactionManager ：这是拦截@Transactional注释方法（例如BookingService书籍）的组件。通过类路径扫描检测BookingService类。
本指南中演示的另一个Springboot功能是在启动时初始化数据库schema的能力：
src/main/resources/schema.sql
drop table BOOKINGS if exists; create table BOOKINGS(ID serial, FIRST_NAME varchar(5) NOT NULL);
还有一个CommandLineRunner ，它注入BookingService并展示各种事务性用例。
src/main/java/hello/AppRunner.java
package hello;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;
import org.springframework.util.Assert;
@Component
class AppRunner implements CommandLineRunner {
private final static Logger logger = LoggerFactory.getLogger(AppRunner.class);
private final BookingService bookingService;
public AppRunner(BookingService bookingService) {
this.bookingService = bookingService;
}
@Override
public void run(String... args) throws Exception {
bookingService.book("Alice", "Bob", "Carol");
Assert.isTrue(bookingService.findAllBookings().size() == 3,
"第一个预定应该没问题");
logger.info("Alice, Bob and Carol 已经预定");
try {
bookingService.book("Chris", "Samuel");
} catch (RuntimeException e) {
logger.info("v--- 这个抛出异常是因为'Samuel' 名字 " +
"太长了 ---v");
logger.error(e.getMessage());
}
for (String person : bookingService.findAllBookings()) {
logger.info("到目前为止, " + person + " 预定了.");
}
logger.info("在数据库里，你应该看不到Chris or Samuel. Samuel违反数据库限定, " +
"Chris会在同一个事务中回退");
Assert.isTrue(bookingService.findAllBookings().size() == 3,
"'Samuel'应该引发一个回退");
try {
bookingService.book("Buddy", null);
} catch (RuntimeException e) {
logger.info("v--- 这个异常是因为null不符 " +
"合数据限定 ---v");
logger.error(e.getMessage());
}
for (String person : bookingService.findAllBookings()) {
logger.info("到目前为止, " + person + " 预定了.");
}
logger.info("你应该看不到Buddy 或 null. null违反数据库限定, and " +
"Buddy会在同一个事务中回退");
Assert.isTrue(bookingService.findAllBookings().size() == 3,
"'null' 应该引发一个回退");
}
}
运行程序，你会看到
2016-09-01 09:47:55.031 INFO 16911 --- [ main] o.s.jdbc.datasource.init.ScriptUtils : Executing SQL script from URL [file:/Users/foo/workspace/gs-managing-transactions/target/classes/schema.sql] 2016-09-01 09:47:55.052 INFO 16911 --- [ main] o.s.jdbc.datasource.init.ScriptUtils : Executed SQL script from URL [file:/Users/foo/workspace/gs-managing-transactions/target/classes/schema.sql] in 21 ms. 2016-09-01 09:47:55.259 INFO 16911 --- [ main] o.s.j.e.a.AnnotationMBeanExporter : Registering beans for JMX exposure on startup 2016-09-01 09:47:55.282 INFO 16911 --- [ main] hello.BookingService : Booking Alice in a seat... 2016-09-01 09:47:55.292 INFO 16911 --- [ main] hello.BookingService : Booking Bob in a seat... 2016-09-01 09:47:55.292 INFO 16911 --- [ main] hello.BookingService : Booking Carol in a seat... 2016-09-01 09:47:55.306 INFO 16911 --- [ main] hello.AppRunner : Alice, Bob and Carol have been booked 2016-09-01 09:47:55.306 INFO 16911 --- [ main] hello.BookingService : Booking Chris in a seat... 2016-09-01 09:47:55.306 INFO 16911 --- [ main] hello.BookingService : Booking Samuel in a seat... 2016-09-01 09:47:55.312 INFO 16911 --- [ main] o.s.b.f.xml.XmlBeanDefinitionReader : Loading XML bean definitions from class path resource [org/springframework/jdbc/support/sql-error-codes.xml] 2016-09-01 09:47:55.419 INFO 16911 --- [ main] o.s.jdbc.support.SQLErrorCodesFactory : SQLErrorCodes loaded: [DB2, Derby, H2, HSQL, Informix, MS-SQL, MySQL, Oracle, PostgreSQL, Sybase, Hana] 2016-09-01 09:47:55.424 INFO 16911 --- [ main] hello.AppRunner : v--- The following exception is expect because 'Samuel' is too big for the DB ---v 2016-09-01 09:47:55.424 ERROR 16911 --- [ main] hello.AppRunner : PreparedStatementCallback; SQL [insert into BOOKINGS(FIRST_NAME) values (?)]; Value too long for column "FIRST_NAME VARCHAR(5) NOT NULL": "'Samuel' (6)"; SQL statement: insert into BOOKINGS(FIRST_NAME) values (?) [22001-192]; nested exception is org.h2.jdbc.JdbcSQLException: Value too long for column "FIRST_NAME VARCHAR(5) NOT NULL": "'Samuel' (6)"; SQL statement: insert into BOOKINGS(FIRST_NAME) values (?) [22001-192] 2016-09-01 09:47:55.424 INFO 16911 --- [ main] hello.AppRunner : So far, Alice is booked. 2016-09-01 09:47:55.424 INFO 16911 --- [ main] hello.AppRunner : So far, Bob is booked. 2016-09-01 09:47:55.424 INFO 16911 --- [ main] hello.AppRunner : So far, Carol is booked. 2016-09-01 09:47:55.424 INFO 16911 --- [ main] hello.AppRunner : You shouldn't see Chris or Samuel. Samuel violated DB constraints, and Chris was rolled back in the same TX 2016-09-01 09:47:55.425 INFO 16911 --- [ main] hello.BookingService : Booking Buddy in a seat... 2016-09-01 09:47:55.425 INFO 16911 --- [ main] hello.BookingService : Booking null in a seat... 2016-09-01 09:47:55.427 INFO 16911 --- [ main] hello.AppRunner : v--- The following exception is expect because null is not valid for the DB ---v 2016-09-01 09:47:55.427 ERROR 16911 --- [ main] hello.AppRunner : PreparedStatementCallback; SQL [insert into BOOKINGS(FIRST_NAME) values (?)]; NULL not allowed for column "FIRST_NAME"; SQL statement: insert into BOOKINGS(FIRST_NAME) values (?) [23502-192]; nested exception is org.h2.jdbc.JdbcSQLException: NULL not allowed for column "FIRST_NAME"; SQL statement: insert into BOOKINGS(FIRST_NAME) values (?) [23502-192] 2016-09-01 09:47:55.427 INFO 16911 --- [ main] hello.AppRunner : So far, Alice is booked. 2016-09-01 09:47:55.427 INFO 16911 --- [ main] hello.AppRunner : So far, Bob is booked. 2016-09-01 09:47:55.427 INFO 16911 --- [ main] hello.AppRunner : So far, Carol is booked. 2016-09-01 09:47:55.427 INFO 16911 --- [ main] hello.AppRunner : You shouldn't see Buddy or null. null violated DB constraints, and Buddy was rolled back in the same TX
预订表对第一列有两个约束：
名称不能超过五个字符。
名称不能为空。
插入的前三个名字是Alice, Bob, and Carol。应用程序断言该表中添加了三个人。如果这不起作用，该应用程序早就退出。
接下来，又为Chris和Samuel预订了一个房间。Samuel的名字故意太长，导致插入错误。事务行为规定Chris和Samuel都要进行，也就是说，这个事务应该回滚。因此，该表中应该只有三个人，这一点由断言证明。
最后，伙伴和空值都被预订了。如输出所示，空值也会导致回滚，从而使相同的三个人被预订。
祝贺你！您刚刚使用Spring开发了一个简单的JDBC应用程序，该应用程序被非侵入性事务。
