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

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

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

1、事务是一组要么同时执行成功，要么同时执行失败的sql语句。是数据库操作的一个执行单元。

2、事物的四大特点：

（1）atomicity（原子性）表示一个事务内的所有操作是一个整体，要么全部成功，要么全部失败。

（2）consistency（一致性）表示一个事物内有一个操作失败时，所有更改过的数据都必须回滚到修改前的状态。

（3）isolation（隔离性)事务查看数据时数据所处的状态，要么是另一并发事务修改它之前的状态，要么是另一事务修改它之后的状态，事务不会查看中间状态的数据。

（4）durability（持久性）持久性事务完成rcYfmKUzy之后，他对于系统的影响是永久性的。

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 = conrcYfmKUzyn.prepareStatement("insert into t_user (username,pwd) values (?,?)");

ps2.setObject(1, "李四");

ps2.setObject(2, "123456");

ps2.execute();

System.out.println("插入一个用户李四"rcYfmKUzy);

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+MySQL数据库程序设计总结》、《Java数据结构与算法教程》、《Java文件与目录操作技巧汇总》、《Java操作DOM节点技巧总结》和《Java缓存操作技巧汇总》

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

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。