JDBC API是一個Java API,能夠訪問任何類型表列數據,特別是存儲在關係數據庫中的數據。JDBC表明Java數據庫鏈接。java
JDBC庫中所包含的API一般與數據庫使用於:mysql
在學習JDBC以前,須要對如下兩個編程知識有必定的瞭解:sql
請確認您已完成如下設置:shell
除上述者外環境配置外,還須要創建一個數據庫,爲本程項目做爲測試使用。假設建立一個數據庫:test
,在這個數據庫上建立一張表:employees
。數據庫
創建一個JDBC應用程序,本教程中以Java鏈接MySQL爲一個示例,分六個步驟進行:編程
在程序中包含數據庫編程所需的JDBC類。大多數狀況下,使用 import java.sql.*
就足夠了,以下所示:數組
//STEP 1. Import required packages import java.sql.*;
須要初始化驅動程序,這樣就能夠打開與數據庫的通訊。如下是代碼片斷實現這一目標:服務器
//STEP 2: Register JDBC driver Class.forName("com.mysql.jdbc.Driver");
使用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);
須要使用一個類型爲Statement
或PreparedStatement
的對象,並提交一個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);
若是要執行一個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); }
在使用JDBC與數據交互操做數據庫中的數據後,應該明確地關閉全部的數據庫資源以減小資源的浪費,對依賴於JVM的垃圾收集以下:
//STEP 6: Clean-up environment rs.close(); stmt.close(); conn.close();
基於上面的步驟,咱們能夠綜合示例代碼,您能夠使用如下代碼做爲模板來編寫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(); }