JDBC快速入門教學

JDBC是什麼?

JDBC API是一個Java API，可以訪問任何類型表列數據，特別是存儲在關係資料庫中的數據。JDBC代表Java資料庫連接。

JDBC庫中所包含的API通常與資料庫使用於：

• 連接到資料庫
• 創建SQL或MySQL語句
• 在資料庫中執行SQL或MySQL查詢
• 查看和修改資料庫中的數據記錄

使用JDBC前提條件

在學習JDBC之前，需要對以下兩個編程知識有一定的瞭解：

• JAVA核心編程
• SQL語句或一種資料庫系統(如：MySQL,Oracle資料庫)

JDBC環境設置

請確認您已完成以下設置：

• JAVA(JDK)安裝
• 資料庫系統的安裝(如：MySQL的安裝)

除上述者外環境配置外，還需要建立一個資料庫，為本程專案作為測試使用。假設創建一個資料庫：test，在這個資料庫上創建一張表：employees。

創建JDBC應用程式

建立一個JDBC應用程式，本教學中以Java連接MySQL為一個示例，分六個步驟進行：

1. 導入包

在程式中包含資料庫編程所需的JDBC類。大多數情況下，使用 import java.sql.* 就足夠了，如下所示：

//STEP 1. Import required packages
import java.sql.*;

2. 註冊JDBC驅動程式

需要初始化驅動程式，這樣就可以打開與資料庫的通信。以下是代碼片段實現這一目標：

//STEP 2: Register JDBC driver
Class.forName("com.mysql.jdbc.Driver");

3. 打開一個連接

使用DriverManager.getConnection()方法來創建一個Connection對象，它代表一個資料庫的物理連接，如下所示：

//STEP 3: Open a connection
//  Database credentials
static final String USER = "root";
static final String PASS = "pwd123456";
System.out.println("Connecting to database...");
conn = DriverManager.getConnection(DB_URL,USER,PASS);

4. 執行一個查詢

需要使用一個類型為Statement或PreparedStatement的對象，並提交一個SQL語句到資料庫執行查詢。如下：

//STEP 4: Execute a query
System.out.println("Creating statement...");
stmt = conn.createStatement();
String sql;
sql = "SELECT id, first, last, age FROM Employees";
ResultSet rs = stmt.executeQuery(sql);

如果要執行一個SQL語句：UPDATE，INSERT或DELETE語句，那麼需要下麵的代碼片段：

//STEP 4: Execute a query
System.out.println("Creating statement...");
stmt = conn.createStatement();
String sql;
sql = "DELETE FROM Employees";
ResultSet rs = stmt.executeUpdate(sql);

5. 從結果集中提取數據

這一步中演示如何從資料庫中獲取查詢結果的數據。可以使用適當的ResultSet.getXXX()方法來檢索的數據結果如下：

//STEP 5: Extract data from result set
while(rs.next()){
    //Retrieve by column name
    int id  = rs.getInt("id");
    int age = rs.getInt("age");
    String first = rs.getString("first");
    String last = rs.getString("last");

    //Display values
    System.out.print("ID: " + id);
    System.out.print(", Age: " + age);
    System.out.print(", First: " + first);
    System.out.println(", Last: " + last);
}

6. 清理環境資源

在使用JDBC與數據交互運算元據庫中的數據後，應該明確地關閉所有的資料庫資源以減少資源的浪費，對依賴於JVM的垃圾收集如下：

//STEP 6: Clean-up environment
rs.close();
stmt.close();
conn.close();

第一個JDBC 程式實例

基於上面的步驟，我們可以綜合示例代碼，您可以使用以下代碼作為範本來編寫JDBC代碼。

注意：此示例代碼基於環境和數據庫環境設置完成的前提下使用。

//STEP 1. Import required packages
import java.sql.*;

public class FirstExample {
   // JDBC driver name and database URL
   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
   static final String DB_URL = "jdbc:mysql://localhost/test";

   //  Database credentials -- 資料庫名和密碼自己修改

   static final String USER = "username";
   static final String PASS = "password";

   public static void main(String[] args) {
   Connection conn = null;
   Statement stmt = null;
   try{
      //STEP 2: Register JDBC driver
      Class.forName("com.mysql.jdbc.Driver");

      //STEP 3: Open a connection
      System.out.println("Connecting to database...");
      conn = DriverManager.getConnection(DB_URL,USER,PASS);

      //STEP 4: Execute a query
      System.out.println("Creating statement...");
      stmt = conn.createStatement();
      String sql;
      sql = "SELECT id, first, last, age FROM Employees";
      ResultSet rs = stmt.executeQuery(sql);

      //STEP 5: Extract data from result set
      while(rs.next()){
         //Retrieve by column name
         int id  = rs.getInt("id");
         int age = rs.getInt("age");
         String first = rs.getString("first");
         String last = rs.getString("last");

         //Display values
         System.out.print("ID: " + id);
         System.out.print(", Age: " + age);
         System.out.print(", First: " + first);
         System.out.println(", Last: " + last);
      }
      //STEP 6: Clean-up environment
      rs.close();
      stmt.close();
      conn.close();
   }catch(SQLException se){
      //Handle errors for JDBC
      se.printStackTrace();
   }catch(Exception e){
      //Handle errors for Class.forName
      e.printStackTrace();
   }finally{
      //finally block used to close resources
      try{
         if(stmt!=null)
            stmt.close();
      }catch(SQLException se2){
      }// nothing we can do
      try{
         if(conn!=null)
            conn.close();
      }catch(SQLException se){
         se.printStackTrace();
      }//end finally try
   }//end try
   System.out.println("Goodbye!");
}//end main
}//end FirstExample - by www.xuhuhu.com

如果使用IDE，可將上面代碼可放在IDE(如：Eclipse/Netbeans)中加入mysql-connector-java-5.1.37-bin.jar 庫並執行。

如果手動編譯，需要把上面代碼存放到 F:\worksp\jdbc\FirstExample.java 檔中，並創建一個目錄：F:\worksp\jdbc\libs，把下載的mysql-connector-java-5.1.40-bin.jar庫(下載地址：http://downloads.mysql.com/archives/c-j/)放入到 F:\worksp\jdbc\libs 目錄中。

使用命令行編譯Java程式並加載指定目錄中的Jar包(mysql-connector-java-5.1.40-bin.jar)，現在編譯上面的例子如下：

F:\worksp\jdbc> javac -Djava.ext.dirs=F:\worksp\jdbc\libs FirstExample.java
F:\worksp\jdbc>

當運行FirstExample後，它會產生類似以下結果：

F:\worksp\jdbc> java -Djava.ext.dirs=F:\worksp\jdbc\libs FirstExample
Connecting to database...
Creating statement...
ID: 100, Age: 18, First: Zara, Last: Ali
ID: 101, Age: 25, First: Mahnaz, Last: Fatma
ID: 102, Age: 30, First: Zaid, Last: Khan
ID: 103, Age: 28, First: Sumit, Last: Mittal
F:\worksp\jdbc>

SQLException中的方法

一個SQLException類既可以發生在驅動程式和數據庫中。當這樣的異常時，SQLException類型的對象將被傳遞到catch子句。
通過SQLException對象有以下幾種方法可用於獲取更多的關於異常的資訊：

通過利用從Exception對象提供的資訊，可以捕獲一個異常，並適當地繼續運行程式。這是一個try塊中的一般形式：

try {
   // Your risky code goes between these curly braces!!!
}
catch(Exception ex) {
   // Your exception handling code goes between these
   // curly braces, similar to the exception clause
   // in a PL/SQL block.
}
finally {
   // Your must-always-be-executed code goes between these
   // curly braces. Like closing database connection.
}

JDBC數據類型

下表列出了默認的JDBC數據類型與Java數據類型轉換，當使用PreparedStatement或CallableStatement對象時可調用setXXX()方法或ResultSet.updateXXX()方法。

在JDBC3.0中增強支持BLOB，CLOB，ARRAY，REF等數據類型。ResultSet對象可調用UPDATEBLOB()，updateCLOB()，updateArray()和updateRef()方法，使您可以在資料庫伺服器上直接操作相應的數據。

對於setXXX()和updateXXX()方法，可以轉換成特定的Java類型到特定的JDBC數據類型。而使用setObject()和updateObject()方法，幾乎所有的Java類型映射到JDBC數據類型。

ResultSet對象提供相應的getXXX()方法為每個數據類型來檢索列值。每一種類型方法，可以使用與列名或由列的序號位置來獲取列的數據。

JDBC批量處理

批處理允許執行一個批處理組相關的SQL語句，並將其一次提交到資料庫中執行。當幾個SQL語句一次發送到資料庫中時，可以減少通信開銷，從而提高性能。

• JDBC驅動程式不支持此功能。您應該使用DatabaseMetaData.supportsBatchUpdates()方法來確定目標資料庫支持批量更新處理。如果JDBC驅動程式支持此功能，則該方法返回true。

• addBatch()方法是PreparedStatement和CallableStatementis類中用於添加單個語句的批處理的聲明。 executeBatch()將開始將所有語句組合到一起並執行。

• executeBatch()將返回一個整數數組，每個數組元素的表示為相應的更新語句的更新計數。

• 添加語句進行批處理時，可以使用clearBatch()方法刪除它們。此方法將刪除addBatch()方法添加的所有語句。但是不能有選擇性地選擇某個語句來刪除。

JDBC數據流

PreparedStatement對象有能力使用提供參數數據的輸入和輸出流。這使您可以將整個檔到資料庫中，可容納較大的值，如CLOB和BLOB數據類型的列。

有下列方法可用於流數據：

1. setAsciiStream(): 此方法用於提供大的ASCII數據值。
2. setCharacterStream(): 此方法用於提供大的UNICODE數據值。
3. setBinaryStream(): 使用此方法用於提供大的二進位數據值。

setXXXStream()方法需要一個額外的參數，檔大小(除了參數占位符)。此參數通知應發送多少數據到資料庫來使用流的驅動程式。

對於一個詳細的關於所有這些概念，這裏只是一個簡單的入門教學，還需要讀者去學習完整的教程，有關JDBC的後續教程，可以從左側文章中瞭解和學習。