JDBC编程之事务处理

package com.siwuxie095.jdbc;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.Statement;

//实际上将数据库信息硬编码到java代码中，不可取

public class TransactionTest {

public static Connection getConnection() {

Connection conn=null;

try {

Class.forName("com.mysql.jdbc.Driver");

conn=DriverManager.getConnection("jdbc:mysql://localhost:3306/sims_db","root","8888");

} catch (Exception e) {

e.printStackTrace();

System.err.println("加载数据库失败...");

}

return conn;

}

public static void insertStuPassword() {

Connection conn=getConnection();

try {

String sql="insert into stu_password(stu_id,stu_pwd)"+

"values('005','005')";

Statement st=conn.createStatement();

int count=st.executeUpdate(sql);

System.out.println("向stu_password表中插入了 "+count+" 条记录");

} catch (Exception e) {

e.printStackTrace();

}

}

public static void insertStuInfo() {

Connection conn=getConnection();

try {

/**

* stu_id是主键，出现异常：

* 即stu_password和stu_info两张表不一致，本来小黄的stu_id是005

* 其中 insertStuPassword() 中已经插入了小黄的stu_id 和 stu_pwd

* 而 insertStuInfo()，却因为输错了已经存在的 stu_id：004 而无法插入

* （即 一个插进去了，一个没有插进去，导致数据不一致）

*/

String sql="insert into stu_info(stuid,stu_name,stu_sex,stu_scademic,stu_major)"+

"values('004','小黄','男','工程学院','土木工程')";

Statement st=conn.createStatement();

int count=st.executeUpdate(sql);

System.out.println("向stu_info表中插入了 "+count+" 条记录");

} catch (Exception e) {

e.printStackTrace();

}

}

public static void main(String[] args) {

insertStuPassword();

insertStuInfo();

}

}

package com.siwuxie095.jdbc;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.SQLException;

import java.sql.Statement;

//实际上将数据库信息硬编码到java代码中，不可取

public class TransactionTestX {

public static Connection getConnection() {

Connection conn=null;

try {

Class.forName("com.mysql.jdbc.Driver");

conn=DriverManager.getConnection("jdbc:mysql://localhost:3306/sims_db","root","8888");

} catch (Exception e) {

e.printStackTrace();

System.err.println("加载数据库失败...");

}

return conn;

}

//将SQLException抛给上层调用方法进行处理

public static void insertStuPassword(Connection conn) throws SQLException {

String sql = "insert into stu_password(stu_id,stu_pwd)" + "values('005','005')";

Statement st = conn.createStatement();

int count = st.executeUpdate(sql);

System.out.println("向stu_password表中插入了 " + count + " 条记录");

}

public static void insertStuInfo(Connection conn) throws SQLException {

/**

* stu_id是主键，出现异常：

* 即stu_password和stu_info两张表不一致，本来小黄的stu_id是005

* 其中 insertStuPassword() 中已经插入了小黄的stu_id 和 stu_pwd

* 而 insertStuInfo()，却因为输错了已经存在的 stu_id：004 而无法插入

* （即 一个插进去了，一个没有插进去，此时，可使事务回滚，使之都不插入，保持一致性）

*/

String sql = "insert into stu_info(stu_id,stu_name,stu_sex,stu_academic,stu_major)"

+ "values('004','小黄','男','工程学院','土木工程')";

Statement st = conn.createStatement();

int count = st.executeUpdate(sql);

System.out.println("向stu_info表中插入了 " + count + " 条记录");

}

//在main方法中进行事务回滚

public static void main(String[] args) {

Connection conn=null;

try {

conn=getConnection();

conn.setAutoCommit(false);//禁止事务自动提交

insertStuPassword(conn);

insertStuInfo(conn);

conn.commit();//提交事务

} catch (SQLException e) {

System.out.println("=======捕获到 SQL 异常=======");

e.printStackTrace();

try {

conn.rollback();//回滚事务

System.out.println("=======事务回滚成功======");

} catch (Exception e2) {

e2.printStackTrace();

}

}finally {

try {

if (conn!=null) {

conn.close();

}

} catch (Exception e3) {

e3.printStackTrace();

}

}

}

}