本文主要是介绍Java中的mysql事务处理,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
一、事务是一组要么同时执行成功,要么同时执行失败的sql语句。是数据库操作的一个执行单元。
2、事物的四大特点:
(1)atomicity(原子性)表示一个事务内的所有操作是一个整体,要么全部成功,要么全部失败。
(2)consistency(一致性)表示一个事物内有一个操作失败时,所有更改过的数据都必须回滚到修改前的状态。
(3)isolation(隔离性)事务查看数据时数据所处的状态,要么是另一并发事务修改它之前的状态,要么是另一事务修改它之后的状态,事务不会查看中间状态的数据。
(4)durability(持久性)持久性事务完成之后,他对于系统的影响是永久性的。
3、实例(以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;
-
-
-
-
-
-
- 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");
-
- <span style="color:#ff0000;">conn.setAutoCommit(false);
-
- 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("插入一个用户李四");
-
- <span style="color:#ff0000;">conn.commit();
- </span> } catch (ClassNotFoundException e) {
- e.printStackTrace();
- try {
- <span style="color:#ff0000;">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语句中去掉一个占位符:
- ps2 = conn.prepareStatement("insert into t_user (username,pwd) values (?)");
运行结果:
插入一个用户张三
(等待三秒后)
抛出错误了。。。。。。。。
然后查看一下数据库,发现数据库中两条数据都没能添加成功
这篇关于Java中的mysql事务处理的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!