本文實(shí)例講述了Java實(shí)現(xiàn)的mysql事務(wù)處理操作。分享給大家供大家參考,具體如下:
1、事務(wù)是一組要么同時(shí)執(zhí)行成功,要么同時(shí)執(zhí)行失敗的sql語句。是數(shù)據(jù)庫操作的一個(gè)執(zhí)行單元。
2、事物的四大特點(diǎn):
(1)atomicity(原子性)表示一個(gè)事務(wù)內(nèi)的所有操作是一個(gè)整體,要么全部成功,要么全部失敗。
(2)consistency(一致性)表示一個(gè)事物內(nèi)有一個(gè)操作失敗時(shí),所有更改過的數(shù)據(jù)都必須回滾到修改前的狀態(tài)。
(3)isolation(隔離性)事務(wù)查看數(shù)據(jù)時(shí)數(shù)據(jù)所處的狀態(tài),要么是另一并發(fā)事務(wù)修改它之前的狀態(tài),要么是另一事務(wù)修改它之后的狀態(tài),事務(wù)不會(huì)查看中間狀態(tài)的數(shù)據(jù)。
(4)durability(持久性)持久性事務(wù)完成之后,他對(duì)于系統(tǒng)的影響是永久性的。
3、實(shí)例(以sql語句中的insert語句為例)
package com.test.jdbc;import java.sql.Connection;import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;/** * 事務(wù)的基本用法 * */public class Test { public static void main(String[] args) { Connection conn = null; PreparedStatement ps1 = null; PreparedStatement ps2 = null; try { //加載驅(qū)動(dòng)類 Class.forName("com.mysql.jdbc.Driver"); conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/testjdbc","root","123456"); conn.setAutoCommit(false); //JDBC中默認(rèn)是true,自動(dòng)提交事務(wù) ps1 = conn.prepareStatement("insert into t_user (username,pwd) values (?,?)");//?是占位符 ps1.setObject(1, "張三"); ps1.setObject(2, "666666"); ps1.execute(); System.out.println("插入一個(gè)用戶張三"); try { Thread.sleep(3000); } catch (InterruptedException e) { e.printStackTrace(); } ps2 = conn.prepareStatement("insert into t_user (username,pwd) values (?,?)"); ps2.setObject(1, "李四"); ps2.setObject(2, "123456"); ps2.execute(); System.out.println("插入一個(gè)用戶李四"); conn.commit();//提交事務(wù) } catch (ClassNotFoundException e) { e.printStackTrace(); try { conn.rollback();//某一條數(shù)據(jù)添加失敗時(shí),回滾 } catch (SQLException e1) { e1.printStackTrace(); } } catch (SQLException e) { e.printStackTrace(); }finally{ try { if(ps1!=null){ ps1.close(); } } catch (SQLException e) { e.printStackTrace(); } try { if(conn!=null){ conn.close(); } } catch (SQLException e) { e.printStackTrace(); } } }}
這段代碼是正確的結(jié)果。運(yùn)行結(jié)果:
插入一個(gè)用戶張三
(等待三秒后)
插入一個(gè)用戶李四
查看數(shù)據(jù)庫,插入了兩條數(shù)據(jù)。
接下來把數(shù)據(jù)庫中剛剛插入的兩條數(shù)據(jù)刪掉,然后把第二條sql語句改一下,讓他出錯(cuò),在第二條sql語句中去掉一個(gè)占位符:
ps2 = conn.prepareStatement("insert into t_user (username,pwd) values (?)");
運(yùn)行結(jié)果:
插入一個(gè)用戶張三
(等待三秒后)
拋出錯(cuò)誤了。。。。。。。。
然后查看一下數(shù)據(jù)庫,發(fā)現(xiàn)數(shù)據(jù)庫中兩條數(shù)據(jù)都沒能添加成功
希望本文所述對(duì)大家java程序設(shè)計(jì)有所幫助。
新聞熱點(diǎn)
疑難解答
圖片精選