day47-JDBC和連接池03

JDBC和連接池03

8.事務

8.1事務介紹

  • 基本介紹
  1. JDBC程式中當一個Connection對象創建時，默認情況下是自動提交事務：每次執行一個SQL語句時，如果執行成功，就會向資料庫自動提交，而不能回滾。
  2. JDBC程式中為了讓多個SQL語句作為一個整體執行，需要使用事務
  3. 調用Connection的setAutoCommit（false）可以取消自動提交事務
  4. 在所有的SQL語句都執行成功後，調用Connection的commit();方法提交事務
  5. 在其中某個操作失敗或者出現異常時，調用Connection的rollback();方法回滾事務

image-20221015162932968

image-20221015163022844

8.2事務處理

應用實例

模擬經典的轉賬業務

首先創建一張account表，插入兩條數據

CREATE TABLE ACCOUNT(
	id INT PRIMARY KEY AUTO_INCREMENT,
	NAME VARCHAR(32) NOT NULL DEFAULT '',
	balance DOUBLE NOT NULL DEFAULT 0
)CHARACTER SET utf8;

INSERT INTO ACCOUNT VALUES(NULL,'馬雲',3000),(NULL,'馬化騰',10000);

SELECT * FROM ACCOUNT;
image-20221015164021758 
package li.jdbc.transaction_;

import li.jdbc.utils.JDBCUtils;
import org.junit.Test;

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

/**
 * 演示JDBC中如何使用事務
 */
public class Transaction_ {

    //沒有使用事務
    @Test
    public void noTransaction() {
        //操作轉賬業務
        //1.得到連接
        Connection connection = null;

        //2.組織sql語句
        String sql = "update account set balance=baLance-100 where id=1";
        String sql2 = "update account set balance=baLance+100 where id=2";

        //3.創建PreparedStatement對象
        PreparedStatement preparedStatement = null;
        try {
            connection = JDBCUtils.getConnection();//在默認情況下，connection默認自動提交
            preparedStatement = connection.prepareStatement(sql);
            preparedStatement.executeUpdate(); //執行第一條sql

            int i = 1 / 0;//拋出異常--模擬異常可能--可以看到出現異常狀態之後的語句沒有執行
            preparedStatement = connection.prepareStatement(sql2);
            preparedStatement.executeUpdate();//執行第二條sql

        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            //關閉資源
            JDBCUtils.close(null, preparedStatement, connection);
        }
    }

    //使用事務來解決
    @Test
    public void useTransaction() {
        //操作轉賬業務
        //1.得到連接
        Connection connection = null;

        //2.組織sql語句
        String sql = "update account set balance=baLance-100 where id=1";
        String sql2 = "update account set balance=baLance+100 where id=2";

        //3.創建PreparedStatement對象
        PreparedStatement preparedStatement = null;
        try {
            connection = JDBCUtils.getConnection();//在默認情況下，connection默認自動提交
            //將connection設置為不自動提交
            connection.setAutoCommit(false);
            preparedStatement = connection.prepareStatement(sql);
            preparedStatement.executeUpdate(); //執行第一條sql

            int i = 1 / 0;//拋出異常
            preparedStatement = connection.prepareStatement(sql2);
            preparedStatement.executeUpdate();//執行第二條sql

            //在這裡提交事務
            connection.commit();
        } catch (Exception e) {
            //如果在try裡面出現了異常，就會進入catch語句，
            // 這意味著我們可以在catch語句裡面進行回滾，即撤銷執行的SQL語句
            System.out.println("執行發生了異常，撤銷已執行的SQL");
            try {
                connection.rollback();//沒有填寫保存點就默認回滾到事務開始的狀態
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
            e.printStackTrace();
        } finally {
            //關閉資源
            JDBCUtils.close(null, preparedStatement, connection);
        }
    }
}
  1. 沒有使用事務（noTransaction）的運行結果：可以看到因為默認為直接提交事務，在出現異常後沒有執行異常後面的語句就進入了catch語句，造成數據錯誤
image-20221015171439073 image-20221015171458181
  1. 使用了事務（useTransaction）之後：可以看到由於在catch語句中進行了回滾操作，在捕獲到異常之後直接進行回滾，保證數據的一致性
image-20221015171843189 image-20221015172030550

9.批處理

  • 基本介紹
  1. 當需要成批插入或者更新記錄時，可以採用Java的批量更新機制，這一機制允許多條語句一次性提交給資料庫批量處理。通常情況下比單獨提交處理更有效率
  2. JDBC的批量處理語句包括下面方法：
    • addBatch()：添加需要批量處理的SQL語句或參數
    • executeBatch()：執行批量處理語句
    • clearBatch()：清空批處理包的語句
  3. JDBC連接MySQL時，如果要使用批處理功能，請在url中加參數?rewriteBatchedStatements=true
  4. 批處理往往和PreparedStatement一起搭配使用，可以既減少編譯次數，又減少運行次數，效率大大提高

9.1批處理應用

例子

  1. 演示向admin2表中添加5000條數據，看看使用批處理耗時多久
  2. 注意批處理需要修改配置文件的數據：url=jdbc:mysql://localhost:3306/資料庫?rewriteBatchedStatements=true
user=root
password=123456
url=jdbc:mysql://localhost:3306/hsp_db02?rewriteBatchedStatements=true
driver=com.mysql.jdbc.Driver

首先創建測試表admin2

CREATE TABLE admin2(
	id INT PRIMARY KEY AUTO_INCREMENT,
	username VARCHAR(32) NOT NULL,
	PASSWORD VARCHAR(32) NOT NULL );
SELECT COUNT(*) FROM admin2;

測試程式：

package li.jdbc.batch_;

import li.jdbc.utils.JDBCUtils;
import org.junit.Test;

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

/**
 * 演示java的批處理
 */
public class Batch_ {

    //傳統方法，添加5000條數據到admin2
    @Test
    public void noBatch() throws Exception {
        //獲取連接
        Connection connection = JDBCUtils.getConnection();
        //sql
        String sql = "insert into admin2 values (null,?,?)";
        PreparedStatement preparedStatement = connection.prepareStatement(sql);
        System.out.println("開始執行");
        long start = System.currentTimeMillis();
        for (int i = 0; i < 5000; i++) {
            preparedStatement.setString(1, "jack" + i);
            preparedStatement.setString(2, "666");
            preparedStatement.executeUpdate();
        }
        long end = System.currentTimeMillis();
        System.out.println("傳統的方式耗時：" + (end - start));
        //關閉連接
        JDBCUtils.close(null, preparedStatement, connection);
    }

    
    //使用批量方式添加數據--注意在配置文件添加參數?rewriteBatchedStatements=true
    @Test
    public void batch() throws Exception {
        //獲取連接
        Connection connection = JDBCUtils.getConnection();
        //sql
        String sql = "insert into admin2 values (null,?,?)";
        PreparedStatement preparedStatement = connection.prepareStatement(sql);
        System.out.println("開始執行");
        long start = System.currentTimeMillis();
        for (int i = 0; i < 5000; i++) {
            preparedStatement.setString(1, "jack" + i);
            preparedStatement.setString(2, "666");
            //將SQL語句加入到批處理包中
            preparedStatement.addBatch();
            //當有1000條SQL時，再批量執行
            if ((i + 1) % 1000 == 0) {//每滿1000條時，就批量執行
                preparedStatement.executeBatch();
                //執行完就清空批處理包
                preparedStatement.clearBatch();
            }
        }
        long end = System.currentTimeMillis();
        System.out.println("批量方式耗時：" + (end - start));
        //關閉連接
        JDBCUtils.close(null, preparedStatement, connection);
    }
}
image-20221015175848847 image-20221015181744073 image-20221015182234229

9.2批處理源碼分析

在上述程式碼中，在preparedStatement.addBatch();語句旁打上斷點，點擊debug，點擊step into

image-20221015182600824

可以看到游標跳轉到了如下方法：

 public void addBatch() throws SQLException {
        if (this.batchedArgs == null) {
            this.batchedArgs = new ArrayList();
        }

        this.batchedArgs.add(new PreparedStatement.BatchParams(this.parameterValues, this.parameterStreams, this.isStream, this.streamLengths, this.isNull));
    }

第一次執行該方法時，會創建Arraylist類型的對象集合elementDate=>Object[]，elementDate=>Object[]用來存放我們預處理的SQL語句。當elementDate滿後，就按照1.5倍擴容

當添加到指定的值後，就會執行executeBatch();

批處理會減少我們發送SQL語句的網路開銷，並且減少編譯次數，因此效率提高了

1.5倍擴容：

image-20221015183921250 image-20221015183927732

9.3.事務和批處理的區別

  • 事務：
    事務底層是在資料庫方存儲SQL，沒有提交事務的數據放在資料庫的臨時表空間。
    最後一次提交是把臨時表空間的數據提交到資料庫伺服器執行
    事務消耗的是資料庫伺服器記憶體

  • 批處理：

    批處理底層是在客戶端存儲SQL
    最後一次執行批處理是把客戶端存儲的數據發送到資料庫伺服器執行。
    批處理消耗的是客戶端的記憶體

Tags:

VirMach 便宜 VPS