本文实例讲述了java实现的mysql事务处理操作。分享给大家供大家参考，具体如下：
1、事务是一组要么同时执行成功，要么同时执行失败的sql语句。是数据库操作的一个执行单元。
2、事物的四大特点：
（1）atomicity（原子性）表示一个事务内的所有操作是一个整体，要么全部成功，要么全部失败。
（2）consistency（一致性）表示一个事物内有一个操作失败时，所有更改过的数据都必须回滚到修改前的状态。
（3）isolation（隔离性)事务查看数据时数据所处的状态，要么是另一并发事务修改它之前的状态，要么是另一事务修改它之后的状态，事务不会查看中间状态的数据。
（4）durability（持久性）持久性事务完成之后，他对于系统的影响是永久性的。
3、实例（以sql语句中的insert语句为例）
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
|
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;/** * 事务的基本用法 * */public class test { public static void main(string[] args) { connection conn = null; preparedstatement ps1 = null; preparedstatement ps2 = null; try { //加载驱动类 class.forname("com.mysql.jdbc.driver"); conn = drivermanager.getconnection("jdbc:mysql://localhost:3306/testjdbc","root","123456"); conn.setautocommit(false); //jdbc中默认是true，自动提交事务 ps1 = conn.preparestatement("insert into t_user (username,pwd) values (?,?)");//?是占位符 ps1.setobject(1, "张三"); ps1.setobject(2, "666666"); ps1.execute(); system.out.println("插入一个用户张三"); 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("插入一个用户李四"); conn.commit();//提交事务 } catch (classnotfoundexception e) { e.printstacktrace(); try { conn.rollback();//某一条数据添加失败时，回滚 } 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(); } } }} |
这段代码是正确的结果。运行结果：
插入一个用户张三
（等待三秒后）
插入一个用户李四
查看数据库，插入了两条数据。
接下来把数据库中刚刚插入的两条数据删掉，然后把第二条sql语句改一下，让他出错，在第二条sql语句中去掉一个占位符：
|
1
|
ps2 = conn.preparestatement("insert into t_user (username,pwd) values (?)"); |
运行结果：
插入一个用户张三
（等待三秒后）
抛出错误了。。。。。。。。
然后查看一下数据库，发现数据库中两条数据都没能添加成功
希望本文所述对大家java程序设计有所帮助。
原文链接：https://blog.csdn.net/u013063153/article/details/53671884
