JDBC快速入門教程

JDBC是什麼?

JDBC API是一個Java API,能夠訪問任何類型表列數據,特別是存儲在關係數據庫中的數據。JDBC表明Java數據庫鏈接。java

JDBC庫中所包含的API一般與數據庫使用於:mysql

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

使用JDBC前提條件

在學習JDBC以前,須要對如下兩個編程知識有必定的瞭解:sql

  • JAVA核心編程
  • SQL語句或一種數據庫系統(如:MySQL,Oracle數據庫)

JDBC環境設置

請確認您已完成如下設置:shell

  • JAVA(JDK)安裝
  • 數據庫系統的安裝(如:MySQL的安裝)

除上述者外環境配置外,還須要創建一個數據庫,爲本程項目做爲測試使用。假設建立一個數據庫:test,在這個數據庫上建立一張表:employees數據庫

建立JDBC應用程序

創建一個JDBC應用程序,本教程中以Java鏈接MySQL爲一個示例,分六個步驟進行:編程

1. 導入包

在程序中包含數據庫編程所需的JDBC類。大多數狀況下,使用 import java.sql.* 就足夠了,以下所示:數組

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

2. 註冊JDBC驅動程序

須要初始化驅動程序,這樣就能夠打開與數據庫的通訊。如下是代碼片斷實現這一目標:服務器

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

3. 打開一個鏈接

使用DriverManager.getConnection()方法來建立一個Connection對象,它表明一個數據庫的物理鏈接,以下所示:yii

//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); 
Java

4. 執行一個查詢

須要使用一個類型爲StatementPreparedStatement的對象,並提交一個SQL語句到數據庫執行查詢。以下:curl

//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); 
Java

若是要執行一個SQL語句:UPDATEINSERTDELETE語句,那麼須要下面的代碼片斷:

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

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); } 
Java

6. 清理環境資源

在使用JDBC與數據交互操做數據庫中的數據後,應該明確地關閉全部的數據庫資源以減小資源的浪費,對依賴於JVM的垃圾收集以下:

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

第一個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.yiibai.com 
Java

若是使用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>
Shell

當運行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> 
Java

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. } 
Java

JDBC數據類型

下表列出了默認的JDBC數據類型與Java數據類型轉換,當使用PreparedStatementCallableStatement對象時可調用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中加強支持BLOBCLOBARRAYREF等數據類型。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()方法是PreparedStatementCallableStatementis類中用於添加單個語句的批處理的聲明。 executeBatch()將開始將全部語句組合到一塊兒並執行。

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

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

JDBC數據流

PreparedStatement對象有能力使用提供參數數據的輸入和輸出流。這使您能夠將整個文件到數據庫中,可容納較大的值,如CLOBBLOB數據類型的列。

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

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

setXXXStream()方法須要一個額外的參數,文件大小(除了參數佔位符)。此參數通知應發送多少數據到數據庫來使用流的驅動程序。

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

相關文章
相關標籤/搜索