JDBC事务案例学习

Posted 码上加油站

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了JDBC事务案例学习相关的知识,希望对你有一定的参考价值。

package com.loaderman.demo.d_tx;

import com.loaderman.demo.utils.JdbcUtil;

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


public class AccountDao {

    // 全局参数
    private Connection con;
    private PreparedStatement pstmt;

    // 1. 转账,没有使用事务
    public void trans1() {

        String sql_zs = "UPDATE account SET money=money-1000 WHERE accountName=‘张三‘;";
        String sql_ls = "UPDATE account SET money=money+1000 WHERE accountName=‘李四‘;";

        try {
            con = JdbcUtil.getConnection(); // 默认开启的隐士事务
            con.setAutoCommit(true);

            /*** 第一次执行SQL ***/
            pstmt = con.prepareStatement(sql_zs);
            pstmt.executeUpdate();

            /*** 第二次执行SQL ***/
            pstmt = con.prepareStatement(sql_ls);
            pstmt.executeUpdate();

        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            JdbcUtil.closeAll(con, pstmt, null);
        }

    }

    // 2. 转账,使用事务
    public void trans2() {

        String sql_zs = "UPDATE account SET money=money-1000 WHERE accountName=‘张三‘;";
        String sql_ls = "UPDATE1 account SET money=money+1000 WHERE accountName=‘李四‘;";

        try {
            con = JdbcUtil.getConnection(); // 默认开启的隐士事务
            // 一、设置事务为手动提交
            con.setAutoCommit(false);

            /*** 第一次执行SQL ***/
            pstmt = con.prepareStatement(sql_zs);
            pstmt.executeUpdate();

            /*** 第二次执行SQL ***/
            pstmt = con.prepareStatement(sql_ls);
            pstmt.executeUpdate();

        } catch (Exception e) {
            try {
                // 二、 出现异常,需要回滚事务
                con.rollback();
            } catch (SQLException e1) {
            }
            e.printStackTrace();
        } finally {
            try {
                // 三、所有的操作执行成功, 提交事务
                con.commit();
                JdbcUtil.closeAll(con, pstmt, null);
            } catch (SQLException e) {
            }
        }

    }

    // 3. 转账,使用事务, 回滚到指定的代码段
    public void trans() {
        // 定义个标记
        Savepoint sp = null;

        // 第一次转账
        String sql_zs1 = "UPDATE account SET money=money-1000 WHERE accountName=‘张三‘;";
        String sql_ls1 = "UPDATE account SET money=money+1000 WHERE accountName=‘李四‘;";

        // 第二次转账
        String sql_zs2 = "UPDATE account SET money=money-500 WHERE accountName=‘张三‘;";
        String sql_ls2 = "UPDATE1 account SET money=money+500 WHERE accountName=‘李四‘;";

        try {
            con = JdbcUtil.getConnection(); // 默认开启的隐士事务
            con.setAutoCommit(false);       // 设置事务手动提交

            /*** 第一次转账 ***/
            pstmt = con.prepareStatement(sql_zs1);
            pstmt.executeUpdate();
            pstmt = con.prepareStatement(sql_ls1);
            pstmt.executeUpdate();

            // 回滚到这个位置?
            sp = con.setSavepoint();


            /*** 第二次转账 ***/
            pstmt = con.prepareStatement(sql_zs2);
            pstmt.executeUpdate();
            pstmt = con.prepareStatement(sql_ls2);
            pstmt.executeUpdate();


        } catch (Exception e) {
            try {
                // 回滚 (回滚到指定的代码段)
                con.rollback(sp);
            } catch (SQLException e1) {
            }
            e.printStackTrace();
        } finally {
            try {
                // 提交
                con.commit();
            } catch (SQLException e) {
            }
            JdbcUtil.closeAll(con, pstmt, null);
        }

    }
}
package com.loaderman.demo.d_tx;
import org.junit.Test;
public class App {
    @Test
    public void testname() throws Exception {
    
        AccountDao accountDao = new AccountDao();
        accountDao.trans();
    }
}

 

以上是关于JDBC事务案例学习的主要内容,如果未能解决你的问题,请参考以下文章

事务的学习,从jdbc开始:jdbc对事务的支持与实现

Mysql4jdbc:事务,登陆案例,预编译,连接池

理解片段事务期间片段的生命周期方法调用

JDBC-04-笔记

JDBC管理事务

JDBC——事务