day47-JDBC和連接池03

来源:https://www.cnblogs.com/liyuelian/archive/2022/10/15/16794814.html
-Advertisement-
Play Games

JDBC和連接池03 8.事務 8.1事務介紹 基本介紹 JDBC程式中當一個Connection對象創建時，預設情況下是自動提交事務：每次執行一個SQL語句時，如果執行成功，就會向資料庫自動提交，而不能回滾。 JDBC程式中為了讓多個SQL語句作為一個整體執行，需要使用事務 調用Connectio ...


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
    最後一次執行批處理是把客戶端存儲的數據發送到資料庫伺服器執行。
    批處理消耗的是客戶端的記憶體


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • DOS視窗命令和單表簡單查詢
    相關術語： DB ：資料庫：在硬碟上以文件的方式存在DBMS：資料庫管理系統：例如mysql，oracle，sqlserver…SQL：一門適用於所有DBMS，對DB進行操作的標準規劃語言，DQL：資料庫查詢語句 select,DML：資料庫管理語句，修改表中數據update,insert,dele ...
  • 前端枚舉enum的應用(Element)封裝
    什麼是枚舉Enum 枚舉 Enum是在眾多語言中都有的一種數據類型，JavaScript中還沒有（TypeScript有）。用來表示一些特定類別的常量數據，如性別、學歷、方向、賬戶狀態等，項目開發中是很常用的。 | Text文字（界面顯示） | key編碼（編碼、存儲使用） | 數字value值（存 ...
  • 記錄--關於 HTML5 LocalStorage 的 5 個不為人知的事實
    這裡給大家分享我在網上總結出來的一些知識，希望對大家有所幫助 LocalStorage 是HTML5中一個方便使用的 API，它為 Web 開發人員 提供了一個易於使用的5MB的存儲空間。使用 LocalStorage API 真的再簡單不過了。不信看下： //Save a value to loc ...
  • HTTPS實現原理分析
    概述 在上一節中介紹了兩種加密方法 對稱加密 非對稱加密 其中對稱加密性能高，但是有泄露密鑰的風險，而非對稱加密相反，加密性能較差，但是密鑰不易泄露，那麼能不能把他們進行一下結合呢？ HTTPS採用混合加密 HTTPS經由HTTP進行通信，但利用SSL/TLS來加密數據包,而SSL/TLS的加密方式 ...
  • 驅動開發：內核枚舉DpcTimer定時器
    在筆者上一篇文章`《驅動開發：內核枚舉IoTimer定時器》`中我們通過`IoInitializeTimer`這個API函數為跳板，向下掃描特征碼獲取到了`IopTimerQueueHead`也就是IO定時器的隊列頭，本章學習的枚舉DPC定時器依然使用特征碼掃描，唯一不同的是在新版系統中DPC是被異... ...
  • 結合springboot條件註入@ConditionalOnProperty以及@ConfigurationProperties來重構優化代碼
    @ConditionalOnProperty實現按需註入bean 簡訊工具類 SmsUtil zhenghe-common是一個基礎包。 SmsUtil坐落在zhenghe-common里。先看看Smsutil的面目。 package com.emax.zhenghe.common.util; im ...
  • Spring的同一個服務為什麼會載入多次？
    問題現象 最近在本地調試公司的一個Web項目時，無意中發現日誌中出現了兩次同一個服務的init記錄，項目都是基於Spring來搭建的，按理說服務都是單例的，應該只有一次服務載入日誌才對，本著對工作認真負責（閑來無事）的態度，必然要一探究竟。 問題分析 為什麼同一個 Bean 會被容器初始化兩次？ 首 ...
  • 序列化組件
    序列化組件的三大功能 序列化,序列化器會把模型對象轉換成字典,經過response以後變成json字元串 反序列化,把客戶端發送過來的數據,經過request以後變成字典,序列化器可以把字典轉成模型 反序列化時同時會完成數據校驗功能 序列化器Serializer使用方法 查詢單個數據語法： 1.在s ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類