2. 程式人生 > >初學JDBC(八)-JDBC的事務處理

初學JDBC(八)-JDBC的事務處理

阿新 • • 發佈：2019-01-30

       上一篇部落格講了CallableStatement介面呼叫儲存過程，這一篇部落格我來說說JDBC的事務處理，這在以後的專案開發中也很重要，只有充分地考慮好JDBC的事務處理，才能在專案開發中遇到前臺與後臺異常時，JDBC的事務處理可以很好地去彌補這一措施，在銀行，支付寶，金融，微信紅包等等中尤其顯得重要，不然的話如果我們給別人轉錢時發生異常，錢從我們的卡里扣出來了，但是對方卻沒有收到，豈不是尷尬了，怎麼樣？這個例子，一提到錢，眼睛就雪亮雪亮的偷笑，是不是對JDBC事務處理產生了好奇心羨慕，現在我就來說說JDBC的事務處理。

        事務處理：英文名字:Transaction Processing；用於正確有效的記錄自己感性的資料處理記錄。事務(由幾個任務組成)是一個最小的工作單元，無論成功與否都要作為一個整體進行即要麼全部執行要麼全部都不執行，不存在執行了一部分另一部分沒有執行的情況發生。從而得出事務本身具有ACID的屬性。ACID就是原子性(Atomicity

)、一致性(Consistency)、隔離性(Isolation)、永續性(Durability)。

        原子性( Atomicity):是事務的最小單元，是不可在分割的單元，相當於一個個小的資料庫操作，這些操作必須同時成功才為成功，只要有一個失敗，則一切的操作都將失敗，這就是原子性。

       一致性(Consistency):事務在系統完整性中實施一致性，通過保證系統的任何事務最後都處於有效狀態來實現。如果事務操作成功，那麼系統的所有變化將正確的應用於系統中，系統處於有效狀態。如果事務操作中出現錯誤，那麼系統中的所有事務將自動的發生回滾，返回到操作前的狀態來保持系統的一致性。

       隔離性(Isolation):在隔離的狀態執行事務，使它們覺得好像是系統在某一個給定的時間段內執行唯一的操作，如果有兩個事務，執行在相同的時間段內，執行著相同的功能，事務的隔離性將確保每一事務在系統中認為只有該事務在使用這個系統。

       永續性(Durability):事務完成之後，它對於系統的影響將是永久的。即使該修改會產生致命的錯誤也會一直保持下去，直到有人修改了為止。

       這裡我們來說一說mysql資料庫中的事物處理：它是由一個或者多個SQL語句序列結合在一起形成所形成的邏輯處理單元。事物處理中的每一條語句都是完成資料庫整個操作任務的一部分，所有的SQL語句結合在一起執行完畢，才能達到完成指定的目的。DBMS在對事務處理中的語句進行處理時，是按照一個約定成俗的規定進行處理的：事務處理中的所有語句都將被作為一個原子性的工作單位，所有語句要麼成功的一起執行，要麼一個也不執行。有了這種規定，在以後事務處理中發生異常就按照這種規定進行下去，保證了資料庫中的資料不會有髒資料的發生。不會產生巨大的危害，減輕了DBMS人員操作負擔。

       mysql對事務處理的支援的命令：

      1：begin:啟動事務相當於執行Start Transaction.

      2：Start Transaction:啟動事務.

      3：set autocommit=0/1:為0代表取消自動提交處理，開啟事務處理；為1代表開啟自動提交處理，關閉事務處理，系統預設情況為1.

      4：commit:提交事務.

      5：rollback:回滾全部事務.

      6：savepoint 事務儲存點的名稱:設定事務儲存點.

      7：rollback to savepoint  儲存點名稱:回滾操作到設定的儲存點。

     講了這個多理論性的知識，再上一個程式碼示例來鞏固一下知識，(無程式碼，不程式嘛大笑)  既然老提及錢，那我們這個例子就舉個和錢有關的例子吧。A借B10塊錢，A還B10塊錢。

    建立表：

CREATE TABLE t_money(
	id INT PRIMARY KEY AUTO_INCREMENT,
	userName VARCHAR(20),
	money INT
);

JDBC轉賬(借錢還錢)程式碼: 
package com.panli.dbutil;
/**
 * 連線資料庫
 */
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class DbUtil {
	//資料庫驅動名字
	private static String jdbcName = "com.mysql.jdbc.Driver";
	//資料庫協議地址
	private static String dbUrl = "jdbc:mysql://localhost:3306/db_user";
	//資料庫使用者名稱
	private static String dbUser = "root";
	//資料庫密碼
	private static String dbPassword = "123456";
	
	
	/**
	 * 獲取連線
	 * @return
	 * @throws Exception
	 */
	public static Connection getCon() throws Exception{
		Class.forName(jdbcName);
		Connection conn = DriverManager.getConnection(dbUrl, dbUser, dbPassword);
		return conn;
	}
	
	/**
	 * 關閉連線
	 * @param stmt
	 * @param conn
	 * @throws Exception
	 */
	public static void close(Statement stmt,Connection conn) throws Exception{
		if(stmt!=null){
			stmt.close();
			if(conn!=null){
				conn.close();
			}
		}
	}
	
	/**
	 * 關閉連線
	 * @param cstmt
	 * @param conn
	 * @throws Exception
	 */
	public static void close(CallableStatement cstmt, Connection conn) throws Exception{
		if(cstmt!=null){
			cstmt.close();
			if(conn!=null){
				conn.close();
			}
		}
	}
	
	
	/**
	 * 關閉連線
	 * @param pstmt
	 * @param conn
	 * @throws SQLException
	 */
	public static void close(PreparedStatement pstmt, Connection conn) throws SQLException{
		if(pstmt!=null){
			pstmt.close();
			if(conn!=null){
				conn.close();
			}
		}
	}
	
	
	/**
	 * 過載關閉方法
	 * @param pstmt
	 * @param conn
	 * @throws Exception
	 */
	public void close(ResultSet rs,PreparedStatement pstmt, Connection conn) throws Exception{
		if(rs!=null){
			rs.close();
			if(pstmt!=null){
				pstmt.close();
				if(conn!=null){
					conn.close();
				}
				
			}
		}
		
	}
}

package com.panli.model;

public class Money {
	
	private int id;
	private String userName;
	private int money;
	
	/**
	 * 預設的構造方法
	 */
	public Money() {
		super();
		// TODO Auto-generated constructor stub
	}
	
	/**
	 * 2個引數的構造方法
	 * @param id
	 * @param money
	 */
	public Money(int id, int money) {
		super();
		this.id = id;
		this.money = money;
	}


	/**
	 * 3個引數的構造方法
	 * @param id
	 * @param userName
	 * @param money
	 */
	public Money(int id, String userName, int money) {
		super();
		this.id = id;
		this.userName = userName;
		this.money = money;
	}
	public int getId() {
		return id;
	}
	public void setId(int id) {
		this.id = id;
	}
	public String getUserName() {
		return userName;
	}
	public void setUserName(String userName) {
		this.userName = userName;
	}
	public int getMoney() {
		return money;
	}
	public void setMoney(int money) {
		this.money = money;
	}
	
	
}

package com.panli.dao;
/**
 * 借錢與收錢為一個事務處理事件單元的JDBC程式碼
 */
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Savepoint;

import com.panli.dbutil.DbUtil;
import com.panli.model.Money;

public class UserMoneyOutInDao {
	private static DbUtil dbUtil = new DbUtil();
	
	/**
	 * 借出錢給他人方
	 * @param money
	 * @return
	 * @throws Exception
	 */
	private static int OutMoney(Money money)throws Exception{
		Connection conn = dbUtil.getCon();
		String sql = "update t_money set money=money-? where id = ? ";
		PreparedStatement pstmt = conn.prepareStatement(sql);
		pstmt.setInt(1, money.getMoney());
		pstmt.setInt(2, money.getId());
		int result = pstmt.executeUpdate();
		dbUtil.close(pstmt, conn);
		return result;
	}
	
	/**
	 * 借到錢的一方
	 * @param money
	 * @return
	 * @throws Exception
	 */
	private static int InMoney(Money money)throws Exception{
		Connection conn = dbUtil.getCon();
		String sql = "update t_money set money=money+? where id = ? ";
		PreparedStatement pstmt = conn.prepareStatement(sql);
		pstmt.setInt(1, money.getMoney());
		pstmt.setInt(2, money.getId());
		int result = pstmt.executeUpdate();
		dbUtil.close(pstmt, conn);
		return result;
	}
	
	
	public static void main(String[] args) {
		int moneys = 10;
		Money Age = new Money(1, moneys);
		Money Bge = new Money(2, moneys);
		Connection conn1 = null;
		Savepoint  sp = null;
		try {
			conn1 = dbUtil.getCon();
			//取消自動提交事務
			conn1.setAutoCommit(false);
			//設定事務儲存點,如果發生錯誤則回滾到此處
			sp = conn1.setSavepoint();
			//Age借出錢給Bge
			OutMoney(Age);
			System.out.println("Age借錢成功!");
			//Bge收到錢
			InMoney(Bge);
			System.out.println("Bge收到錢成功!");
		} catch (Exception e) {
			// TODO Auto-generated catch block
			try {
				//如果遇到錯誤就回滾
				conn1.rollback(sp);
			} catch (SQLException e1) {
				// TODO Auto-generated catch block
				e1.printStackTrace();
			}
			System.out.println("Age借錢失敗!");
			System.out.println("Bge收到錢失敗!");
			e.printStackTrace();
		}finally{
			try {
				//如果事務操作成功，提交事務
				conn1.commit();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			try {
				//關閉連線
				conn1.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		
		System.out.println("錢財交易成功!");
	}
}

相關推薦

初學JDBC(八)-JDBC的事務處理

       上一篇部落格講了CallableStatement介面呼叫儲存過程，這一篇部落格我來說說JDBC的事務處理，這在以後的專案開發中也很重要，只有充分地考慮好JDBC的事務處理，才能在專案開發中遇到前臺與後臺異常時，JDBC的事務處理可以很好地去彌補這一措施，在銀

JDBC（6）事務處理&批量處理

finally sys comm ted 結束時間 lose 對比 ack try 事務處理就是當執行多個SQL指令，因某個指令有誤，則取消執行所有的命令 它的作用是保證各項的完整性和一致性 JDBC的數據操作時 commit()：提交事務 rollback():回退事

JDBC 中如何進行事務處理，事務的 ACID 是指什麼

JDBC 中如何進行事務處理? 答:Connection 提供了事務處理的方法，通過呼叫setAutoCommit(false)可以設定手動提交事務;當事務完成 後用 commit()顯式提交事務;如果在事務處理過程中發生異常則通過 rollback() 進行事務回滾。除此之外，較新 的 J

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

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

Spring學習5-Spring整合JDBC及其事務處理（註解方式）

  2、步驟二：使用JdbcTemplate類操作資料庫:     Spring把JDBC中重複的操作建立成了一個模板類：org.springframework.jdbc.core.JdbcTemplate。   A：要使用JdbcTemplate,需要為每一個DAO配置一個JdbcTemplate例項：  

JDBC的事務處理

package cn.my.demo1; import java.io.IOException; import java.sql.Connection; import java.sql.SQLExce

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

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

JDBC學習（六、事務處理操作）

案例:銀行轉賬:從張無忌賬戶上給趙敏轉1000塊。準備:account(賬戶表):---------------------------------------------------------------id            name(賬號,唯一)         

使用ThreadLocal實現對JDBC的事務處理

一、準備工作 在應用ThreadLocal對JDBC的事務處理前，可以先在專案中匯入資料庫連線池的jar包，然後建立c3p0-config.xml並配置。 二、建立使用ThreadLocal的事務處理工具類 public class JDBCUtils

Datastage JDBC Connector 中文亂碼處理

default 中文亂碼 在Datastage中，通常處理中文字符編碼的時候是通過設置工程、JOB、stage三個級別的NLS但JDBC Connector stage這個組件並沒有NLS選項，而是通過 stage裏面的“Properties”選項卡裏面的“Session”-->“Charact

jdbc如何操作事務

sina got gin 操作 mct 如何 cdt doc cgo 捍znZAT9lt彰http://tushu.docin.com/sina_6270782798 F39褂壓7職ND雀瞪http://tushu.docin.com/sina_6345237130 6

Spring入門（三）— AOP註解、jdbc模板、事務

list() 規範 行數 get attribute 樂觀鎖 過濾 callback 賬號 一、AOP註解開發 導入jar包 aop聯盟包、 aspectJ實現包 、 spring-aop-xxx.jar 、 spring-aspect-xxx.jar 導入約束 a

JDBC例子4_事務管理

事務管理 1 事務概述  事務指的是邏輯上的一組操作(多條sql語句),組成這組操作的各個單元要麼全都成功,要麼全都失敗.  事務作用：保證在一個事務中多次操作要麼全都成功,要麼全都失敗. 例如轉賬： update account set money=money-100 wh

JDBC例子2_預處理物件

3.1 SQL注入問題 SQL注入：使用者輸入的內容作為了SQL語句語法的一部分，改變了原有SQL真正的意義。 假設有登入案例SQL語句如下: SELECT * FROM 使用者表 WHERE NAME = 使用者輸入的使用者名稱 AND PASSWORD = 使用者輸的密碼; 此

Spring--04（Spring的JDBC操作和事務操作）

1.Spring 的 JDBC 的模板      Spring 提供了很多持久層技術的模板類簡化程式設計：                      

JDBC介面———PreparedStatement預處理

PreparedStatement * 它是Statement介面的子介面； * 強大之處： - 防SQL攻擊； - 提高程式碼的可讀性、可維護性； - 提高效率！ * 學習PreparedStateme

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

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

Spring結合jdbc以及mybatis事務控制

事務屬性包含的五個方面分別是什麼 1、事務傳播行為 規定了如果有新的事務應該被啟動還是被掛起，或者方法是否需要在事務中執行。 TransactionDefinition.PROPAGATION_REQUIRED如果當前存在事務，則加入該事務，如果當前沒有事務，則

JDBC高階開發事務

1.事務的引入 1.1 轉賬業務 案例分析：之前給大家介紹過三層開發，相信大家對三層有了基本的瞭解，接下來我們就使用三層的開發模式來完成轉賬的案例1 首先在這裡，我們web層就直接通過main方法，直接填充資料，呼叫service層的業務邏輯。2 而service業務邏輯層主要完成轉賬的

JDBC高階開發事務總結

1.事務作用 事務作用：保證在一個事務中多次操作要麼全都成功,要麼全都失敗. 事務的宣告週期:開啟事務-提交事務/回滾 1.1 mysql事務操作 mysql中可以有兩種方式進行事務的管理 自動提交:mysql預設自動提交,及執行一條sql語句提交一次事務 手動提交: