JDBC控制管理事务
- 事务:一个包含多个步骤的业务操作。如果这个业务操作被事务管理,则这多个步骤要么同时成功,要么同时失败。
- 操作:
(1)开启事务
(2)提交事务
(3)回滚事务 - 使用Connection对象来管理事务
- 开启事务:setAutoCommit(boolean autoCommit):调用该方法设置参数为false,即开启事务。【在执行sql之前开启事务】
- 提交事务:commit()【当所有sql都执行完提交事务】
- 回滚事务:rollback()【在catch中回滚事务】
创建jbdc.properties
方便更改并连接数据库和数据库驱动。
url = jdbc:mysql:///demo?serverTimezone=UTC
user = root
password = 123123
driver = com.mysql.cj.jdbc.Driver
创建JDBCUtils工具类
能够更加的优化代码
package util;
import java.io.FileReader;
import java.io.IOException;
import java.net.URL;
import java.sql.*;
import java.util.Properties;
/*JDBC工具类*/
public class JDBCUtils {
private static String url;
private static String user;
private static String password;
private static String driver;
/*文件的读取,只需要读取一次即可拿到这些值。使用静态代码块*/
static{
//读取资源文件,获取值
try {
//1.创建Properties集合类。
Properties pro = new Properties();
//获取src路径下的文件的方式--->ClassLoader类加载器
ClassLoader classLoader = JDBCUtils.class.getClassLoader();
URL res = classLoader.getResource("jdbc.properties");
String path = res.getPath();
System.out.println(path);
//2.加载文件
//pro.load(new FileReader("src/jdbc.properties"));
pro.load(new FileReader(path));
//3.获取数据,赋值
url = pro.getProperty("url");
user = pro.getProperty("user");
password = pro.getProperty("password");
driver = pro.getProperty("driver");
//4.注册驱动
Class.forName(driver);
} catch (IOException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
/*获取连接,@return 连接对象*/
public static Connection getConnection() throws SQLException {
return DriverManager.getConnection(url,user,password);
}
//释放资源
public static void close(Statement stmt,Connection conn){
if (stmt !=null ){
try {
stmt.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (conn !=null ){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
/*释放资源重载*/
public static void close(ResultSet rs, Statement stmt, Connection conn){
if (rs !=null ){
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (stmt !=null ){
try {
stmt.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (conn !=null ){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
事务练习:张三借给李四500。
在数据库demo里面创建一张account表。
通过JDBC来实现事务,事务可以保证数据的一致性和完整性(避免异常和错误等导致的数据信息异常)。
package cn.itcase.jdbc;
import util.JDBCUtils;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
/**
* 演示事务操作
*/
public class JDBCDemo10 {
public static void main(String[] args) {
Connection conn = null;
PreparedStatement pstmt1 = null;
PreparedStatement pstmt2 = null;
try {
//1.获取连接
conn = JDBCUtils.getConnection();
//开启事务
conn.setAutoCommit(false);
//2.1定义sql 张三 -500
String sql1 = "update account set balance = balance - ? where id = ?";
//2.2定义sql 李四 +500
String sql2 = "update account set balance = balance + ? where id = ?";
//3.获取执行sql对象
pstmt1 = conn.prepareStatement(sql1);
pstmt2 = conn.prepareStatement(sql2);
//4.设置参数
pstmt1.setDouble(1,500);
pstmt1.setInt(2,1);
pstmt2.setDouble(1,500);
pstmt2.setInt(2,2);
//5.执行sql
pstmt1.executeUpdate();
//手动制造异常
int i = 3/0;
/*
* 运行时出现异常,如果不添加事务,那只能张三减500,而李四不能加500.
* 如果添加事务,那么尽管出现异常,会发生回滚事务,回滚到开启事务之前。
* 这样就不会出现"减而不加"的情况。
*/
pstmt2.executeUpdate();
//提交事务
conn.commit();
} catch (Exception e) {
//事务回滚
try {
if (conn != null) {
conn.rollback();
}
} catch (SQLException ex) {
ex.printStackTrace();
}
e.printStackTrace();
} finally {
JDBCUtils.close(pstmt1, conn);
JDBCUtils.close(pstmt2,null);
}
}
}
由于在开启事务后,代码出现异常那么数据就会回滚到开启事务之前。要是没有出现那么就会提交事务,数据发生变化。
上面出现了异常并且开启了事务,数据并没有发生改变。事务可以保证数据的一致性和完整性(避免异常和错误等导致的数据信息异常)
倘若将手动制造的异常 int i = 3/0;删除掉,那么数据就会发生变化。