JDBC学习笔记

 1 package jdbc;
 2 import java.sql.Connection;
 3 import java.sql.DriverManager;
 4 import java.sql.SQLException;
 5 import java.sql.Statement;
 6 public class TransactionTest {
 7     public static Connection getConnection() {
 8         Connection conn = null;
 9         try {
10             Class.forName("com.mysql.jdbc.Driver");
11             conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/jsp_db", "root", "851111");
12         } catch (Exception e) {
13             e.printStackTrace();
14         }
15         return conn;
16     }
17     //添加用户表
18     public static void insertUserData(Connection conn) throws SQLException {
19         String sql = "INSERT INTO tbl_user(id,name,password,email)"
20                 + "VALUES(10,‘shakyamuni‘,‘123456‘,‘shakyamuni@163.com‘)";
21         Statement st = conn.createStatement();
22         int count = st.executeUpdate(sql);
23         System.out.println("向用户表插入了" + count + "条记录");
24     }
25     
26     //添加地址表
27     public static void insertAddressData(Connection conn) throws SQLException {
28         String sql = "INSERT INTO tbl_address(id,city,country,user_id)" + "VALUES(1,‘gudu‘,‘tiandu‘,‘10‘)";
29         Statement st = conn.createStatement();
30         int count = st.executeUpdate(sql);
31         System.out.println("向地址表插入了" + count + "条记录");
32     }
33     
34     //程序主方法
35     public static void main(String[] args) {
36         Connection conn =null;
37         try {
38             conn=getConnection();
39             conn.setAutoCommit(false);//禁止事务自动提交
40             insertUserData(conn);
41             insertAddressData(conn);
42             
43             conn.commit(); //提交事务
44         } catch (SQLException e) {
45             System.out.println("==捕获到SQL异常==");
46             e.printStackTrace();
47             
48             try {
49                 conn.rollback(); //事务回滚
50                 System.out.println("事务回滚成功");
51             } catch (Exception e2) {
52                 e2.printStackTrace();
53             }
54         }finally {//资源清理相关代码
55             try {
56                 if(conn!=null){
57                     conn.close();
58                 }
59             } catch (Exception e3) {
60                 e3.printStackTrace();
61             }
62         }
63     }
64 }

 1 package util;
 2 import java.io.InputStream;
 3 import java.sql.Connection;
 4 import java.sql.DriverManager;
 5 import java.util.Properties;
 6 public class ConnectionFactory {
 7     
 8     private static String driver;
 9     private static String dburl;
10     private static String user;
11     private static String password; 
12     
13     private static final ConnectionFactory factory =new ConnectionFactory();
14     
15     private Connection conn;
16     
17 //配置信息的读取代码
18     static {
19         Properties prop =new Properties();//定义类，处理键值对
20         try {
21             //获取配置文件【dbconfig.properties】
22 //获取属性文件中的内容，首先获取类加载器，然后读取属性文件中的内容，从输入流中读取键值对列表
23             InputStream in =ConnectionFactory.class.getClassLoader().getResourceAsStream("dbconfig.properties");
24             prop.load(in);
25         } catch (Exception e) {
26             System.out.println("===配置文件读取错误===");
27         }
28         driver =prop.getProperty("driver");
29         dburl =prop.getProperty("dburl");
30         user =prop.getProperty("user");
31         password =prop.getProperty("password");
32     }
33     
34 //默认的构造函数
35     private ConnectionFactory(){
36         
37     }
38     
39     public static ConnectionFactory getInstance(){
40         return factory;
41     }
42     
43 //获取数据库链接的方法
44     public Connection makeConnection(){
45         try {
46             Class.forName(driver);
47             conn =DriverManager.getConnection(dburl,user,password);
48         } catch (Exception e) {
49             e.printStackTrace();
50         }
51         return conn;
52     }
53 }