位置：首頁 > Java技術 > JDBC教學 > JDBC快速入門教學

JDBC快速入門教學

 上一篇

JDBC是什麼?

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

JDBC庫中所包含的API任務通常與數據庫使用：

  • 連接到數據庫

  • 創建SQL或MySQL語句

  • 在數據庫中執行SQL或MySQL查詢

  • 查看和修改記錄

 

先決條件:

學習JDBC，需要在以下兩個主題有一定的了解：

  1. JAVA核心編程

  2. SQL或MySQL數據庫

JDBC - 環境設置:

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

  1. 核心JAVA安裝

  2. SQL 或 MySQL數據庫安裝

除上述者外，需要建立一個數據庫，為本程測試項目使用。假設這是EMP，在同一個數據庫上創建表Employees。

創建JDBC應用程序:

參與建立一個JDBC應用程序，本教學中按六個步驟進行：

導入包:

這需要你有軟件包包含了數據庫編程所需的JDBC類。大多數情況下，使用import java.sql.* 就足夠了，如下所示：

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

注冊JDBC驅動程序：

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

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

打開一個連接：

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

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

執行一個查詢：

這需要使用一個對象類型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);

從結果集中提取數據：

這一步是必需的情況下，從數據庫中獲取數據。可以使用適當的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);
}

清理環境：

應該明確地關閉所有的數據庫資源，對依賴於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/EMP";

   //  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.gitbook.net

現在讓我們來編譯上麵的例子如下：

C:\>javac FirstExample.java
C:\>

當你運行FirstExample的，它會產生以下結果：

C:\>java 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
C:\>

SQLException方法：

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

方法 描述
getErrorCode() 獲取與異常關聯的錯誤號。
getMessage() 獲取的JDBC驅動程序的錯誤處理錯誤消息的驅動程序，或獲取Oracle錯誤號和消息的數據庫錯誤。
getSQLState() 獲取XOPEN SQLSTATE字符串。對於JDBC驅動程序錯誤，冇有有用的信息，從該方法返回。對於一個數據庫錯誤，五位的XOPEN SQLSTATE代碼返回。這種方法可以返回null。
getNextException() 獲取異常鏈中的下一個Exception對象。
printStackTrace() 打印當前的異常，或可拋出，並回溯到標準錯誤流。
printStackTrace(PrintStream s) 打印此拋出對象及其回溯到指定的打印流。
printStackTrace(PrintWriter w) 打印此拋出對象及其回溯您指定打印作家。

通過利用從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()方法。

SQL JDBC/Java setXXX updateXXX
VARCHAR java.lang.String setString updateString
CHAR java.lang.String setString updateString
LONGVARCHAR java.lang.String setString updateString
BIT boolean setBoolean updateBoolean
NUMERIC java.math.BigDecimal setBigDecimal updateBigDecimal
TINYINT byte setByte updateByte
SMALLINT short setShort updateShort
INTEGER int setInt updateInt
BIGINT long setLong updateLong
REAL float setFloat updateFloat
FLOAT float setFloat updateFloat
DOUBLE double setDouble updateDouble
VARBINARY byte[ ] setBytes updateBytes
BINARY byte[ ] setBytes updateBytes
DATE java.sql.Date setDate updateDate
TIME java.sql.Time setTime updateTime
TIMESTAMP java.sql.Timestamp setTimestamp updateTimestamp
CLOB java.sql.Clob setClob updateClob
BLOB java.sql.Blob setBlob updateBlob
ARRAY java.sql.Array setARRAY updateARRAY
REF java.sql.Ref SetRef updateRef
STRUCT java.sql.Struct SetStruct updateStruct

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

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

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

SQL JDBC/Java setXXX getXXX
VARCHAR java.lang.String setString getString
CHAR java.lang.String setString getString
LONGVARCHAR java.lang.String setString getString
BIT boolean setBoolean getBoolean
NUMERIC java.math.BigDecimal setBigDecimal getBigDecimal
TINYINT byte setByte getByte
SMALLINT short setShort getShort
INTEGER int setInt getInt
BIGINT long setLong getLong
REAL float setFloat getFloat
FLOAT float setFloat getFloat
DOUBLE double setDouble getDouble
VARBINARY byte[ ] setBytes getBytes
BINARY byte[ ] setBytes getBytes
DATE java.sql.Date setDate getDate
TIME java.sql.Time setTime getTime
TIMESTAMP java.sql.Timestamp setTimestamp getTimestamp
CLOB java.sql.Clob setClob getClob
BLOB java.sql.Blob setBlob getBlob
ARRAY java.sql.Array setARRAY getARRAY
REF java.sql.Ref SetRef getRef
STRUCT java.sql.Struct SetStruct getStruct

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()方法需要一個額外的參數，文件大小，除了參數占位符。此參數通知應發送多少數據的數據庫，使用流的驅動程序。

對於一個詳細的關於所有這些概念，需要去通過學習完整的教學。



 上一篇
極客書 © 2015-2020 . Email:   關於我們