2. 程式人生 > >JDBC應用程式連線資料庫--事務處理

JDBC應用程式連線資料庫--事務處理

阿新 • • 發佈：2019-02-09

JDBC應用程式連線資料庫–事務處理

事務概念

事務是指一組最小邏輯操作單元，裡面有多個操作組成，組成事務的每一部分必須要同時提交成功，如果有一個操作失敗，整個操作就需要回滾，事務要保證ACID特性。這在資料庫中已經涉及到，不在程式設計中再次強調。我們的任務是使用Java應用程式去模擬操作資料庫中的事務處理，本文將詳述該問題。

問題引出

首先解決這個問題的所有的API均在java.sql.Connection中，要注意對這個核心API的學習。

  • 情景建立，模擬轉賬過程，張三給李四轉賬1000元，那麼要求張三的錢要減1000，而李四的錢要加1000，其SQL語句為：
CREATE
 
 TABLE account(
id INT PRIMARY KEY AUTO_INCREMENT,
accountName VARCHAR(20), 
money DOUBLE
);

UPDATE account SET money=money-1000 WHERE accountName="zs";

UPDATE account SET money=money+1000 WHERE accountName="ls";

實現該過程的Java程式如下：

package com.jpzhutech.transaction;

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

import org.junit.Test;
import org.junit.runners.ParentRunner;

public class transaction {

    @SuppressWarnings("resource")
    @Test
    public void test(){
        String sql_zs = "UPDATE account SET money=money-1000 WHERE accountName=?";
        String sql_ls = "UPDATE account SET money=money+1000 WHERE accountName=?"
 
;
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        try {
            Class.forName("com.mysql.jdbc.Driver");

            try {
                    String url = "jdbc:mysql://192.168.101.44/amon";
                    String user = "root";
                    String password = "560128";

                    connection = DriverManager.getConnection(url, user, password);
                    //System.out.println(connection);
                    // 執行sql_zs


                    //實際上當不寫時相當於下面的這行程式碼自動執行
                    //connection.setAutoCommit(true);

                    preparedStatement = connection.prepareStatement(sql_zs);
                    preparedStatement.setString(1, "zs");
                    int count_zs = preparedStatement.executeUpdate();
                    System.out.println("影響了"+count_zs+"行");

                    // 執行sql_ls
                    preparedStatement = connection.prepareStatement(sql_ls);
                    preparedStatement.setString(1, "ls");
                    int count_ls = preparedStatement.executeUpdate();
                    System.out.println("影響了"+count_ls+"行");

            } catch (SQLException e) {
                throw new RuntimeException(e);
            }
        } catch (ClassNotFoundException e) {
            throw new RuntimeException(e);
        } finally {
            try {
                preparedStatement.close();
                connection.close();
            } catch (SQLException e) {
                throw new RuntimeException(e);
            }
        }
    }
}

分析這段程式碼我們知道，如果在我的程式碼中有一個部分寫錯，比如ls的SQL語句寫錯沒有正確的執行，那麼會發生的情況是張三的錢少了1000元，但是李四的錢並沒有增加，看下面的程式碼：

package com.jpzhutech.transaction;

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

import org.junit.Test;
import org.junit.runners.ParentRunner;

public class transaction {

    @SuppressWarnings("resource")
    @Test
    public void test(){
        String sql_zs = "UPDATE account SET money=money-1000 WHERE accountName=?";
        //明顯我們可以看出李四的這段更新程式碼存在很大的問題，並不會被執行，但是張三的程式碼會被執行，結果只能是張三的錢繼續少1000元，而李四的錢並沒有增加
        String sql_ls = "UPDATE1 account SET money=money+1000 WHERE accountName=?";
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        try {
            Class.forName("com.mysql.jdbc.Driver");

            try {
                    String url = "jdbc:mysql://192.168.101.44/amon";
                    String user = "root";
                    String password = "560128";

                    connection = DriverManager.getConnection(url, user, password);
                    //System.out.println(connection);
                    // 執行sql_zs


                    //實際上當不寫時相當於下面的這行程式碼自動執行
                    //connection.setAutoCommit(true);

                    preparedStatement = connection.prepareStatement(sql_zs);
                    preparedStatement.setString(1, "zs");
                    int count_zs = preparedStatement.executeUpdate();
                    System.out.println("影響了"+count_zs+"行");

                    // 執行sql_ls
                    preparedStatement = connection.prepareStatement(sql_ls);
                    preparedStatement.setString(1, "ls");
                    int count_ls = preparedStatement.executeUpdate();
                    System.out.println("影響了"+count_ls+"行");

            } catch (SQLException e) {
                throw new RuntimeException(e);
            }
        } catch (ClassNotFoundException e) {
            throw new RuntimeException(e);
        } finally {
            try {
                preparedStatement.close();
                connection.close();
            } catch (SQLException e) {
                throw new RuntimeException(e);
            }
        }
    }
}

從上面的兩段程式碼的對比我們可以知道，在我們寫SQL語句或者在其它的情況下可能會發生某個應該同時執行的語句並沒有做到我們想要的效果，那麼此時就會發生錯誤，程式設計師應該避免這種情況的發生，怎麼避免呢？在資料庫中使用事務的ACID特效能夠解決這種問題，下面將詳細的說明該怎麼解決。

解決方案

使用事務的ACID特效能夠避免此種情況的發生，但是用Java應用程式該怎麼做到呢？是否Java提供了這種機制呢？答案是肯定的，Java確實提供了這種機制，在Connection介面中有幾個方法能夠實現該種功能。

用到的API

Connection中存在下面幾個與事務相關的方法，分別是：

  • void commit()

  • void rollback()

  • void rollback(Savepoint savepoint)

  • void setAutoCommit(boolean autoCommit)

  • Savepoint setSavepoint(String name)

API使用方法
package com.jpzhutech.transaction;

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

import org.junit.Test;
import org.junit.runners.ParentRunner;

public class transaction {

    @Test
    public void test1(){
        String sql_zs = "UPDATE account SET money=money-1000 WHERE accountName=?";
        String sql_ls = "UPDATE account SET money=money+1000 WHERE accountName=?";
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        try {
            Class.forName("com.mysql.jdbc.Driver");

            try {
                    String url = "jdbc:mysql://192.168.101.44/amon";
                    String user = "root";
                    String password = "560128";

                    connection = DriverManager.getConnection(url, user, password);
                    //System.out.println(connection);
                    // 執行sql_zs


                    //實際上當不寫時相當於下面的這行程式碼自動執行
                    //connection.setAutoCommit(true);

                    //一 設定事務手動提交，也就是將自動提交關閉
                    connection.setAutoCommit(false);

                    preparedStatement = connection.prepareStatement(sql_zs);
                    preparedStatement.setString(1, "zs");
                    int count_zs = preparedStatement.executeUpdate();
                    System.out.println("影響了"+count_zs+"行");

                    // 執行sql_ls
                    preparedStatement = connection.prepareStatement(sql_ls);
                    preparedStatement.setString(1, "ls");
                    int count_ls = preparedStatement.executeUpdate();
                    System.out.println("影響了"+count_ls+"行");

            } catch (SQLException e) {
                try {
                    //二 出現異常我希望回滾
                    connection.rollback();
                } catch (SQLException e1) {
                    throw new RuntimeException(e);
                }
                throw new RuntimeException(e);
            }
        } catch (ClassNotFoundException e) {
            throw new RuntimeException(e);
        } finally {

            //三 如果所有的操作執行成功
            try {
                connection.commit();
            } catch (SQLException e1) {

            }
            try {
                preparedStatement.close();
                connection.close();
            } catch (SQLException e) {
                throw new RuntimeException(e);
            }
        }
    }


    @SuppressWarnings("resource")
    @Test
    public void test2(){
        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 = "UPDATE account SET money=money+500 WHERE accountName=?";

        Connection connection = null;
        PreparedStatement preparedStatement = null;
        Savepoint savepoint = null;
        try {
            Class.forName("com.mysql.jdbc.Driver");

            try {
                    String url = "jdbc:mysql://192.168.101.44/amon";
                    String user = "root";
                    String password = "560128";

                    connection = DriverManager.getConnection(url, user, password);
                    //System.out.println(connection);
                    // 執行sql_zs


                    //實際上當不寫時相當於下面的這行程式碼自動執行
                    //connection.setAutoCommit(true);

                    //一 設定事務手動提交，也就是將自動提交關閉
                    connection.setAutoCommit(false);


                    //第一次操作（此次操作是正確的）
                    preparedStatement = connection.prepareStatement(sql_zs1);
                    preparedStatement.setString(1, "zs");
                    preparedStatement.executeUpdate();


                    // 執行sql_ls
                    preparedStatement = connection.prepareStatement(sql_ls1);
                    preparedStatement.setString(1, "ls");
                    preparedStatement.executeUpdate();


                    //設定回滾位置
                    savepoint = connection.setSavepoint("transaction");

                    //第二次操作（此次操作是錯誤的）
                    preparedStatement = connection.prepareStatement(sql_zs2);
                    preparedStatement.setString(1, "zs");
                    preparedStatement.executeUpdate();

                    // 執行sql_ls
                    preparedStatement = connection.prepareStatement(sql_ls2);
                    preparedStatement.setString(1, "ls");
                    preparedStatement.executeUpdate();

            } catch (SQLException e) {
                try {
                    //二 出現異常我希望回滾
                    connection.rollback(savepoint);
                } catch (SQLException e1) {
                    throw new RuntimeException(e);
                }
                throw new RuntimeException(e);
            }
        } catch (ClassNotFoundException e) {
            throw new RuntimeException(e);
        } finally {

            //三 如果所有的操作執行成功
            try {
                connection.commit();
            } catch (SQLException e1) {

            }
            try {
                preparedStatement.close();
                connection.close();
            } catch (SQLException e) {
                throw new RuntimeException(e);
            }
        }
    }
}

總結

究竟什麼時候會用到事務程式設計，依具體情況而定，請讀者自己衡量，為了不失完整性我將此部分也全部進行了講解，後續部分會主鍵增加關於JDBC優化的知識。

相關推薦

JDBC應用程式連線資料庫--事務處理

JDBC應用程式連線資料庫–事務處理 事務概念 事務是指一組最小邏輯操作單元，裡面有多個操作組成，組成事務的每一部分必須要同時提交成功，如果有一個操作失敗，整個操作就需要回滾，事務要保證ACID特性。這在資料庫中已經涉及到，不在程式設計

應用程式連線HGDB資料庫

1、資料庫連線驅動 驅動：com.highgo.jdbc.Driver URL:  jdbc:highgo://ip:埠號/資料庫名       jdbc:highgo://localhost:5866/highgo"（示例） 使用者名稱：high

六、JDBC--獲取自動生成的主鍵值&處理Blob&資料庫事務處理

【孤立的技術是沒有價值的】，我們這裡只是為了瞭解具體的實現步驟：我們在插入資料的時候，經常會需要獲取我們插入的這一行資料對應的主鍵值。 具體的程式碼實現： /** * 獲取資料庫自動生成的主鍵 */ @Test public void testGetKey

Oracle使用JDBC連線資料庫異常處理

在使用eclipse編譯器,編寫java的jdbc連線Oracle資料庫的時候經常會出現連線異常的情況,出現錯誤為 ORA-12505, TNS:listener does not currently know of SID given in connect descrip

資料庫-事務處理的概念和理論簡介

在看這一部分內容之前，我對資料庫一些基礎概念和基礎操作的認識十分淺薄，也沒有一些資料庫管理的經驗，因此當學這一部分的時候遇到了賊多理解上的誤區和困難。難受呀，基礎差真的不行。。。但是我已經沒有時間先從頭仔細學習資料庫基礎再學這一部分了，因此只能在泥濘中前行。即使在本文結束之前，好多概念我

JDBC操作步驟----連線資料庫

  JDBC的概念：           JDBC（Java DataBase Connectivity，java資料庫連線），由一組Java語言編寫的類和介面組成，用於執行SQL語句的Java API，可以為多種關係資料庫提

JDBC不同電腦連線資料庫

※ mac檢視本機ip 終端輸入ifconfig 網段：192.168.0.102 注意：Linux系統可以固定ip，不聯網可以固定ip，但連不上其他網路了就,同一個網路不管在哪ip是一樣的。 ※ win檢視本機ip cmd輸入ipconfig

JDBC之如何連線資料庫原始碼剖析

通過DriverManager在CopyOnWriterArrayList類中進行註冊,儲存相應的資訊,載入類完畢後 當我們需要獲取連線時,使用DriverManager中的getConnection方法,通常我們傳遞相應的三個引數url,username,還有password.但是無論用那種的getCon

MySQL資料庫事務處理

事務處理用於有效記錄某機構感興趣的業務活動（稱為事務）的資料處理（例如銷售、供貨的定購或貨幣傳輸）。通常，聯機事務處理 (OLTP) 系統執行大量的相對較小的事務。——百度百科 事務處理是將多個操作或者命令一起執行，所有命令全部成功執行才意味著該事務的成功，任何一個命令失敗

Tomcat中用JNDI方式載入JDBC DataSource以連線資料庫

概括一下，大致分為四步：安裝驅動，填充context.xml，填充web.xml，編寫程式取得連線。通過一個小DEMO對這種配置方式有了一點了解，以tomcat6.0連線mysql5.0.8資料庫為例。 安裝驅動 下載與所要連線的資料庫版本對應的JDBC驅動程式，加入

SpringBoot----SQL資料庫事務處理

一、事務有四個特性：ACID 原子性（Atomicity）：事務是一個原子操作，由一系列動作組成。事務的原子性確保動作要麼全部完成， 要麼完全不起作用。 一致性（Consistency）：一旦事務完成（不管成功還是失敗），系統必須確保它所建模的業務處於一致的狀 態，而不會是

JDBC工具類連線資料庫測試

測試程式碼 import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import com.jdbcutils.JDBCUtils; public class J

struts2簡單登入註冊程式(連線資料庫)

我用的是：struts2.3，tomcat7.0，oracle，編譯器intellij idea。 首先，開啟idea，找到file->new->project 根據圖中所指進行選擇，點選create找到struts下的lib路徑，找到以下核心jar包 接下來一路

64位Windows系統下32位應用程式連線MySql

1.首先得安裝“Connector/ODBC”，就是Mysql的ODBC驅動，這個是與應用程式相關的，而不是與作業系統相關的，也就是說，不管你的系統是x64還是x86，只要你的應用程式是x86的那麼，“Connector/ODBC”就要安裝x86的，才能正常，下面的是下載

重啟 IIS7 應用程式池的批處理

https://www.cnblogs.com/webenh/p/6018483.html 批處理很簡單：c:\windows\system32\inetsrv\AppCmd.exe stop apppool /apppool.name:"ASP.NET v4.0"c:\windows\system32\i

JDBC —— 簡單的連線資料庫和封裝

連線資料庫，並讀取表裡的內容 eclipse連線資料庫的一般過程是： 1，載入JDBC驅動（jar驅動包自己去下，這裡有匯入jar到eclipse的方法Eclipse下匯入外部jar包的3種方式） 2，建立資料庫連線（Connection介面） 3，建立

JDBC應用程式常見介面API和基本操作步驟

一、常用JDBC API在java.sql包中包含體現JDBC基本功能的若干介面和類：1.Driver 介面：代表驅動程式2.DriverManager 類：驅動程式管理員3.Connection 介面：代表資料庫連線4.Statement 、PreparedStatemen

正確的使用@Transactional進行資料庫事務處理

在spring工程中 中使用@Transactional實現事務，經常會出現事務失效的現象，是因為用@Transactional實現事務有特殊的要求： 1、只能是bean物件的public介面使用@Transactional 2、只能通過bean物件使用@T

Spring框架淺析 -- 資料庫事務處理

概述 在Spring框架淺析 -- 概述中，我們介紹過，Spring對於資料庫操作及事務處理的支援，是Spring功能中較為重要的一環。那麼資料庫事務是什麼？為什麼要Spring需要對資料庫操作及事務處理進行支援？Spring都提供了哪些方式對資料庫事務處理進行支援？這些方

為您的Java應用程式新增退出事件處理

一個完整的Java應用程式，通常至少要有一個應用程式的結束點。對於一般程式來說，系統開發者根據需要和個人的偏好，會在程式結束位置，通過新增System.exit(0)，或System.out(-1)，來結束程式，或不加這些指令，讓程式自然執行到結束。 如：下列典型程式碼 p