Java之JDBC事务代码案例

注：大家觉得博客好的话，别忘了点赞收藏呀，本人每周都会更新关于人工智能和大数据相关的内容，内容多为原创，Python Java Scala SQL 代码，CV NLP 推荐系统等，Spark Flink Kafka Hbase Hive Flume等等~写的都是纯干货，各种顶会的论文解读，一起进步。
今天和大家分享一下Java之JDBC事务代码案例
#博学谷IT学习技术支持#

​在我们今天要讲的数据库中的事务，就可以理解为一条或一组SQL语句，这个事务成功的执行的必要条件就是其中的SQL全部执行成功，如果其中的任一SQL执行失败（没有达到预期效果），则此次事务执行失败，所有的SQL都不会对数据库中的数据产生变更。
简单的说就是要么一起成功，要么一起失败。

create table aaa.account(
    aid int primary key ,
    aname varchar(20),
    money double
);

insert into  aaa.account (aid,aname,money) VALUES (1001,'zhangsan',1000);
insert into  aaa.account (aid,aname,money) VALUES (1002,'lisi',1000);

DriverClass=com.mysql.cj.jdbc.Driver
Url=jdbc:mysql://localhost:3306/aaa
Username=root
Password=12345678

import java.io.InputStream;
import java.sql.*;
import java.util.Properties;

public class JDBCUtils {

    private static Properties map;
    private static String driverClass;
    private static String url;
    private static String username;
    private static String password;
    private static String sql;

    private JDBCUtils(){}
    //封装注册驱动.这里是mysql 8.0的版本
    static {
        try {
            InputStream inputStream =
                    JDBCUtils.class.getClassLoader().getResourceAsStream("jdbc.properties");

            map = new Properties();
            map.load(inputStream);
            driverClass = map.getProperty("DriverClass");
            url = map.getProperty("Url");
            username = map.getProperty("Username");
            password = map.getProperty("Password");
            sql = map.getProperty("Sql");

            Class.forName(driverClass);
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }
    //封装获得连接
    public static Connection getConnection(){
        try {

            return DriverManager.getConnection(url, username, password);
        } catch (SQLException e) {
            throw new RuntimeException(e);
        }
    }

}

//事务案例
//1开启事务
//2提交事务
//3回滚事务

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class demo1 {
    public static void main(String[] args) {
        Connection connection = JDBCUtils.getConnection();
        try {
            //关闭事务的自动提交
            //默认情况下一条sql单独开启事务
            connection.setAutoCommit(false);

            PreparedStatement pst1 = connection.prepareStatement("update account set money = money -1000 where aname = 'zhangsan'");
            int rows1 = pst1.executeUpdate();

			//这里故意报个错，如果发生错误就整体运行失败，之前代码也不会执行，要么一起成功，要么一起失败。
            System.out.println(1 / 0);

            PreparedStatement pst2 = connection.prepareStatement("update account set money = money +1000 where aname = 'lisi'");
            int rows2 = pst2.executeUpdate();

            //提交事务
            if (rows1 == 1 && rows2 == 1) {
                connection.commit();
            }
        } catch (Exception e) {
            e.printStackTrace();
            //回滚事务
            try {
                connection.rollback();
            } catch (SQLException ex) {
                throw new RuntimeException(ex);
            }
        }

    }
}

connection.setAutoCommit(false);
connection.commit();
connection.rollback();
事务其实非常简单，如果事务中发生错误就整体运行失败，之前sql代码也不会执行，要么一起成功，要么一起失败。一般就用这个。