JDBC--编程之事务处理--回滚的简单实例

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

public class JdbcThings {
//获取数据库连接的方法
public static Connection getConnection(){

Connection con=null;
try {
Class.forName("com.mysql.jdbc.Driver");
con=DriverManager.getConnection("jdbc:mysql://localhost:3306/new_Prictice","root","");

} catch (Exception e) {

}
return con;
}

//想数据库中添加记录的方法
public void insertUser_t(Connection con) throws SQLException{

String sql ="insert into user_t  (id,name,password,email) values "
+ "('10','liuye','123456','123456@163.com') ";
Statement st=con.createStatement();
int count =st.executeUpdate(sql);
System.out.println("想数据库中添加了"+count+"条记录");
}
public void insertUser_adress(Connection con) throws SQLException{

String  sql ="insert into user_adress  (id,city,country,user_id)  values "
+ " ('1','huashengdun','meiguo','1')";
Statement  st= con.createStatement();
int count =st.executeUpdate(sql);
System.out.println("想数据库中添加了"+count+"条记录");
}

public static void main(String[] args) {
JdbcThings jt= new  JdbcThings();
Connection con=null;

try {

con=getConnection();
con.setAutoCommit(false);

jt.insertUser_t(con);
jt.insertUser_adress(con);

con.commit();

} catch (SQLException e) {
System.out.println("捕获到----sql异常------");
e.printStackTrace();

try {
//进行实物回滚
con.rollback();
System.out.println("事务回滚成功");

} catch (Exception e2) {
e2.printStackTrace();
}
}
//最后关闭连接
finally{
try {

con.close();

} catch (Exception e3) {

e3.printStackTrace();

}
}

}

}