JDBC编程之事务处理

 1 package com.test.conn;
 2 
 3 import java.sql.Connection;
 4 import java.sql.DriverManager;
 5 
 6 
 7 
 8 public class Conn {
 9 
10     public Connection getCon(){
11         try{
12             Class.forName("com.mysql.jdbc.Driver");
13             String url = "jdbc:mysql://localhost/mytest?useUnicode = true&characterEncoding=utf-8";
14             String user="root";
15             String password="";
16             Connection conn =  DriverManager.getConnection(url,user,password);
17             System.out.println(conn.getMetaData().getURL());
18             return conn;
19         }
20         catch(Exception e){
21             e.printStackTrace();
22             return null;
23         }
24     }
25 }

 1 package com.test.service;
 2 
 3 import java.sql.Connection;
 4 import java.sql.PreparedStatement;
 5 import java.sql.ResultSet;
 6 import java.sql.SQLException;
 7 
 8 public class Service_ForData {
 9     
10     private static Connection conn ;
11     private static PreparedStatement pstmt;
12     
13     public static void main(String[] args) {
14         conn = new com.test.conn.Conn().getCon();
15         
16         try {
17             conn.setAutoCommit(false);
18             addPerson(conn);
19             addAddress(conn);
20             conn.commit();
21         } catch (Exception e) {
22             System.out.println("捕获到异常");
23             e.printStackTrace();
24             try {
25                 conn.rollback();
26                 System.out.println("事务回滚成功");
27             } catch (SQLException e1) {
28                 
29                 e1.printStackTrace();
30             }
31             
32         }
33         
34     }
35     
36     public static void addPerson(Connection conn) throws Exception{
37         
38 
39             pstmt = conn.prepareStatement("insert into person (id,name,password) values(?,?,?)");
40             pstmt.setInt(1,10);
41             pstmt.setString(2,"tom");
42             pstmt.setString(3, "123456");
43             pstmt.executeUpdate();
44             
45         
46     }
47     
48     public static void addAddress(Connection conn) throws Exception{
49           pstmt = conn.prepareStatement("insert into address (id,address,userid) values(?,?,?)");
50           pstmt.setInt(1, 1);
51           pstmt.setString(2, "obsnsjka");
52           pstmt.setInt(3, 10);
53           pstmt.executeUpdate();
54     }
55     
56 
57 }