首页 > 开发 > Java > 正文

Java实现的mysql事务处理操作示例

2024-07-14 08:42:12
字体:
来源:转载
供稿:网友

本文实例讲述了Java实现的mysql事务处理操作。分享给大家供大家参考,具体如下:

1、事务是一组要么同时执行成功,要么同时执行失败的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");      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语句中去掉一个占位符:

ps2 = conn.prepareStatement("insert into t_user (username,pwd) values (?)");

运行结果:

插入一个用户张三
(等待三秒后)
抛出错误了。。。。。。。。

然后查看一下数据库,发现数据库中两条数据都没能添加成功

希望本文所述对大家java程序设计有所帮助。


注:相关教程知识阅读请移步到JAVA教程频道。
发表评论 共有条评论
用户名: 密码:
验证码: 匿名发表