JDBC連接數據庫
涉及到建立一個JDBC連接的編程是相當簡單的。下面是這些簡單的四個步驟:
- 導入JDBC包: 添加import語句到Java程序導入所需的類在Java代碼中。
- 注冊JDBC驅動程序:這一步會導致JVM加載所需的驅動程序實現到內存中,因此它可以實現JDBC請求。
- 數據庫URL制定:這是創建格式正確的地址指向到要連接的數據庫。
- 創建連接對象:最后,代碼調用DriverManager對象的getConnection()方法來建立實際的數據庫連接。
導入JDBC包:
import 語句告訴Java編譯器在哪里可以找到在代碼中引用,并放置在您的源代碼最開始的類。
使用標準的JDBC包,它允許選擇,插入,更新和SQL表中刪除數據,添加以下進口到您的源代碼:
1
2
|
import java.sql.* ; // for standard JDBC programs import java.math.* ; // for BigDecimal and BigInteger support |
注冊JDBC驅動程序:
使用它之前,必須注冊你的驅動程序在程序。注冊驅動程序是由Oracle驅動程序的類文件被加載到內存中以便它可以被用作JDBC接口的實現過程。
需要做這個注冊只能在你的程序一次??梢酝ㄟ^以下兩種方式之一注冊一個驅動程序。
方法(I)- Class.forName():
注冊一個驅動程序中最常用的方法是使用Java的Class.forName()方法來動態加載驅動程序的類文件到內存中,它會自動將其注冊。這種方法是可取的,因為它允許使驅動注冊配置,便于攜帶。
下面的示例使用Class.forName()來注冊Oracle驅動程序:
1
2
3
4
5
6
7
|
try { Class.forName( "oracle.jdbc.driver.OracleDriver" ); } catch (ClassNotFoundException ex) { System.out.println( "Error: unable to load driver class!" ); System.exit( 1 ); } |
可以使用getInstance()方法來解決不兼容的JVM,但要編寫了兩個額外的例外情況如下:
1
2
3
4
5
6
7
8
9
10
11
12
13
|
try { Class.forName( "oracle.jdbc.driver.OracleDriver" ).newInstance(); } catch (ClassNotFoundException ex) { System.out.println( "Error: unable to load driver class!" ); System.exit( 1 ); catch (IllegalAccessException ex) { System.out.println( "Error: access problem while loading!" ); System.exit( 2 ); catch (InstantiationException ex) { System.out.println( "Error: unable to instantiate driver!" ); System.exit( 3 ); } |
方法(二) - DriverManager.registerDriver():
可以用它來注冊一個驅動程序的第二種方法是使用staticDriverManager.registerDriver()方法。
應該,如果使用的是不兼容的JDK JVM,比如微軟提供一個使用registerDriver()方法。
下面的示例使用registerDriver()來注冊Oracle驅動程序:
1
2
3
4
5
6
7
8
|
try { Driver myDriver = new oracle.jdbc.driver.OracleDriver(); DriverManager.registerDriver( myDriver ); } catch (ClassNotFoundException ex) { System.out.println( "Error: unable to load driver class!" ); System.exit( 1 ); } |
數據庫URL制定:
當加載的驅動程序,可以建立程序中使用DriverManager.getConnection()方法的連接。為方便參考,讓列出了三個重載DriverManager.getConnection()方法:
- getConnection(String url)
- getConnection(String url, Properties prop)
- getConnection(String url, String user, String password)
在這里,每個表單需要一個數據庫URL。數據庫的URL是指向數據庫地址。
制定一個數據庫URL是大多數用在建立連接相關。
下表列出了下來流行的JDBC驅動程序名和數據庫的URL。
RDBMS JDBC驅動程序的名稱 URL 格式
1
2
3
4
|
MySQL com.mysql.jdbc.Driver jdbc:mysql://hostname/ databaseName ORACLE oracle.jdbc.driver.OracleDriver jdbc:oracle:thin:@hostname:port Number:databaseName DB2 COM.ibm.db2.jdbc.net.DB2Driver jdbc:db2:hostname:port Number/databaseName Sybase com.sybase.jdbc.SybDriver jdbc:sybase:Tds:hostname: port Number/databaseName |
以URL格式所有高亮的部分是靜態的,需要改變只剩余部分按照數據庫設置。
創建連接對象: 使用數據庫URL的用戶名和密碼:
下面三種形式DriverManager.getConnection()方法來創建一個連接對象。getConnection()最常用形式要求傳遞一個數據庫URL,用戶名 username和密碼 password:
對URL數據庫部分databaseName的值:假設使用的是Oracle的瘦驅動程序,需要指定一個主機:端口。
假設有一臺主機TCP/IP地址192.0.0.1 以及主機名和Oracle監聽器被配置為在端口1521,數據庫名稱是EMP,然后完整的數據庫URL是:
1
|
jdbc:oracle:thin:@amrood:1521:EMP |
現在,必須調用適當的用戶名和密碼以及getConnection()方法來獲得一個Connection對象,如下所示:
1
2
3
4
|
String URL = "jdbc:oracle:thin:@amrood:1521:EMP"; String USER = "username"; String PASS = "password" Connection conn = DriverManager.getConnection(URL, USER, PASS); |
只使用一個數據庫URL:
第二種形式 DriverManager.getConnection()方法只需要一個數據庫URL:
1
|
DriverManager.getConnection(String url); |
然而,在這種情況下,數據庫的URL,包括用戶名和密碼,并具有以下的一般形式:
1
|
jdbc:oracle:driver:username/password @database |
所以上面的連接可以創建如下:
1
2
|
String URL = "jdbc:oracle:thin:username/password@amrood:1521:EMP"; Connection conn = DriverManager.getConnection(URL); |
使用數據庫的URL和一個Properties對象:
第三種形式DriverManager.getConnection()方法需要一個數據庫URL和一個Properties對象:
DriverManager.getConnection(String url, Properties info);
Properties對象,保存一組關鍵字 - 值對。它被用來調用getConnection()方法時驅動程序屬性傳遞給驅動程序。
為了使通過前面的例子中所做的相同的連接,使用下面的代碼:
1
2
3
4
5
6
7
8
|
import java.util.*; String URL = "jdbc:oracle:thin:@amrood:1521:EMP" ; Properties info = new Properties( ); info.put( "user" , "username" ); info.put( "password" , "password" ); Connection conn = DriverManager.getConnection(URL, info); |
關閉JDBC連接:
在JDBC程序的結束,它明確要求關閉所有的連接到數據庫,以結束每個數據庫會話。但是,如果忘了,Java垃圾收集器會關閉連接時,它會清除陳舊的對象。
依托垃圾收集,特別是在數據庫編程,是非常差的編程習慣。應該總是在關閉與連接對象關聯的close()方法連接的習慣。
為了確保連接被關閉,可以在代碼中的finally塊執行。 finally塊都會執行,不管是否發生或也不例外。
要關閉上面打開的連接,應該調用close()方法,如下所示:
conn.close();
顯式地關閉連接DBMS節約資源。
創建JDBC應用程序:
有下列涉及構建JDBC應用程序的六個步驟:
- 導入數據包 . 需要包括含有需要進行數據庫編程的JDBC類的包。大多數情況下,使用 import java.sql.* 就可以了.
- 注冊JDBC驅動程序. 需要初始化驅動程序,可以與數據庫打開一個通信通道。
- 打開連接. 需要使用DriverManager.getConnection() 方法創建一個Connection對象,它代表與數據庫的物理連接。
- 執行查詢 . 需要使用類型聲明的對象建立并提交一個SQL語句到數據庫。
- 從結果集中提取數據 . 要求使用適當的關于ResultSet.getXXX()方法來檢索結果集的數據。
- 清理環境. 需要明確地關閉所有的數據庫資源相對依靠JVM的垃圾收集。
示例代碼:
這個范例的例子可以作為一個模板,在需要建立JDBC應用程序。
基于對環境和數據庫安裝在前面的章節中做此示例代碼已寫入。
復制下面的例子FirstExample.java,編譯并運行,如下所示:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
|
//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 |
現在來編譯上面的例子如下:
1
|
C:>javac FirstExample.java |
當運行FirstExample,它會產生以下結果:
1
|
C:>java FirstExample |
1
2
3
4
5
6
|
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 |