Java知識(shí)點(diǎn)總結(jié)（JDBC-封裝JDBC）

null1145 發(fā)布于2019-08-16 12:39 / 860人閱讀

摘要：知識(shí)點(diǎn)總結(jié)封裝知識(shí)點(diǎn)總結(jié)封裝目錄下新建一個(gè)文件，用于封裝數(shù)據(jù)庫(kù)連接信息把獲取數(shù)據(jù)庫(kù)連接對(duì)象和關(guān)閉連接的操作封裝到這個(gè)類中讀取和處理資源文件的信息只需要加載一次，所以寫成靜態(tài)代碼塊。

Java知識(shí)點(diǎn)總結(jié)（JDBC-封裝JDBC）

@(Java知識(shí)點(diǎn)總結(jié))[Java, JDBC]

封裝JDBC

src目錄下新建一個(gè)db.properties文件，用于封裝數(shù)據(jù)庫(kù)連接信息

把獲取數(shù)據(jù)庫(kù)連接對(duì)象和關(guān)閉連接的操作封裝到 DBUtil 這個(gè)類中

import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
 
public class DBUtil {
  static Properties pros; //讀取和處理資源文件的信息
  
  static{ // 只需要加載一次，所以寫成靜態(tài)代碼塊。執(zhí)行本類時(shí)，加載
    pros = new Properties();
    try {
     pros.load(Thread.currentThread().getContextClassLoader()
         .getResourceAsStream("db.properties"));
    } catch (IOException e) {
     e.printStackTrace();
    }
  }
 
  public static Connection getConn(){
    Connection conn = null;
    try {
     Class. forName(pros.getProperty("mysqlDriver"));
     conn = DriverManager.getConnection(pros.getProperty("mysqlUrl"),
         pros.getProperty( "mysqlUser"), pros.getProperty("mysqlPassword"));
    } catch (ClassNotFoundException | SQLException e) {
     e.printStackTrace();
    }
    return conn;
  }
  
  // 不建議把conn寫為靜態(tài)的全局變量，然后在方法中關(guān)閉
  public static void close(Connection conn){
    try {
     conn.close();
    } catch (SQLException e) {
     e.printStackTrace();
    }
  }
  
  public static void close(Statement stmt) {
    try {
     stmt.close();
    } catch (SQLException e) {
     e.printStackTrace();
    }
  }
  
  public static void close(PreparedStatement pstmt) {
    if (pstmt != null) {
     try {
       pstmt.close();
     } catch (SQLException e) {
       e.printStackTrace();
     }
    }
  }
  
  public void close(ResultSet rs) {
    try {
     rs.close();
    } catch (SQLException e) {
     e.printStackTrace();
    }
  }
  
  public static void commit(Connection conn) {
    if (conn != null) {
     try {
       conn.commit();
     } catch (SQLException e) {
       e.printStackTrace();
     }
    }
  }
  
  public static void rollback(Connection conn) {
    if (conn != null) {
     try {
       conn.rollback();
     } catch (SQLException e) {
       e.printStackTrace();
     }
    }
  }
  
  public static void setAutoCommit(Connection conn, boolean autoCommit) {
    if (conn != null) {
     try {
       conn.setAutoCommit(autoCommit);
     } catch (SQLException e) {
       e.printStackTrace();
     }
    }
  }
  
  
  //連接測(cè)試
  public static void main(String[] args) {
    if (DBUtil.getConn()!=null) {
     System.out.println("連接成功！");
     
    }
  }
}