1. 程式人生 > >利用JDBC連線Oracle資料庫

利用JDBC連線Oracle資料庫

JDBC是Sun公司制定的一個可以用Java語言連線資料庫的技術。

一、JDBC基礎知識        

        JDBC(Java Data Base Connectivity,java資料庫連線)是一種用於執行SQL語句的Java API,可以為多種關係資料庫提供統一訪問,它由一組用Java語言編寫的類和介面組成。JDBC為資料庫開發人員提供了一個標準的API,據此可以構建更高階的工具和介面,使資料庫開發人員能夠用純 Java API 編寫資料庫應用程式,並且可跨平臺執行,並且不受資料庫供應商的限制。

1、跨平臺執行:這是繼承了Java語言的“一次編譯,到處執行”的特點;

2、不受資料庫供應商的限制:巧妙在於JDBC設有兩種介面,一個是面向應用程式層,其作用是使得開發人員通過SQL呼叫資料庫和處理結果,而不需要考慮資料庫的提供商;另一個是驅動程式層,處理與具體驅動程式的互動,JDBC驅動程式可以利用JDBC API建立Java程式和資料來源之間的橋樑。應用程式只需要編寫一次,便可以移到各種驅動程式上執行。Sun提供了一個驅動管理器,資料庫供應商——如MySQL、Oracle,提供的驅動程式滿足驅動管理器的要求就可以被識別,就可以正常工作。所以JDBC不受資料庫供應商的限制。




        JDBC API可以作為連線Java應用程式與各種關係資料庫的紐帶,在帶來方便的同時也有負面影響,以下是JDBC的優、缺點。優點如下:


操作便捷:JDBC使得開發人員不需要再使用複雜的驅動器呼叫命令和函式;
可移植性強:JDBC支援不同的關係資料庫,所以可以使同一個應用程式支援多個數據庫的訪問,只要載入相應的驅動程式即可;
通用性好:JDBC-ODBC橋接驅動器將JDBC函式換成ODBC;
面向物件:可以將常用的JDBC資料庫連線封裝成一個類,在使用的時候直接呼叫即可。

        缺點如下:


訪問資料記錄的速度受到一定程度的影響;
更改資料來源困難:JDBC可支援多種資料庫,各種資料庫之間的操作必有不同,這就給更改資料來源帶來了很大的麻煩




二、JDBC連線資料庫的流程及其原理

1、在開發環境中載入指定資料庫的驅動程式。例如,接下來的實驗中,使用的資料庫是Oracle,所以需要去下載Oracle支援JDBC的驅動程式(其實這個地方並不需要去官網上下載jdbc驅動,本地安裝的Oracle中就有,是一個ojdbc14.jar的檔案);而開發環境是MyEclipse,將下載得到的驅動程式載入進開發環境中(具體示例的時候會講解如何載入)。




2、在Java程式中載入驅動程式。在Java程式中,可以通過 “Class.forName(“指定資料庫的驅動程式”)” 方式來載入新增到開發環境中的驅動程式,例如載入Oracle的資料驅動程式的程式碼為:  Class.forName(“oracle.jdbc.driver.OracleDriver”)




3、建立資料連線物件:通過DriverManager類建立資料庫連線物件Connection。DriverManager類作用於Java程式和JDBC驅動程式之間,用於檢查所載入的驅動程式是否可以建立連線,然後通過它的getConnection方法,根據資料庫的URL、使用者名稱和密碼,建立一個JDBC Connection 物件。如:Connection connection =  DriverManager.geiConnection(“連線資料庫的URL", "使用者名稱", "密碼”)。其中,URL=協議名+IP地址(域名)+埠+資料庫名稱;使用者名稱和密碼是指登入資料庫時所使用的使用者名稱和密碼。具體示例建立Oracle的資料庫連線程式碼如下:

              conn=DriverManager.getConnection(url, user, password);





4、建立Statement物件:Statement 類的主要是用於執行靜態 SQL 語句並返回它所生成結果的物件。通過Connection 物件的 createStatement()方法可以建立一個Statement物件。例如:Statement statament = connection.createStatement(); 具體示例建立Statement物件程式碼如下:

             Statement statamentMySQL =connectMySQL.createStatement(); 





5、呼叫Statement物件的相關方法執行相對應的 SQL 語句:通過execuUpdate()方法用來資料的更新,包括插入和刪除等操作,例如向staff表中插入一條資料的程式碼:

       statement.excuteUpdate( "INSERT INTO staff(name, age, sex,address, depart, worklen,wage)" + " VALUES ('Tom1', 321, 'M', 'china','Personnel','3','3000' ) ") ; 

通過呼叫Statement物件的executeQuery()方法進行資料的查詢,而查詢結果會得到 ResulSet物件,ResulSet表示執行查詢資料庫後返回的資料的集合,ResulSet物件具有可以指向當前資料行的指標。通過該物件的next()方法,使得指標指向下一行,然後將資料以列號或者欄位名取出。如果當next()方法返回null,則表示下一行中沒有資料存在。使用示例程式碼如下:

       ResultSet resultSel = statement.executeQuery( "select * from staff" );




6、關閉資料庫連線:使用完資料庫或者不需要訪問資料庫時,通過Connection的close() 方法及時關閉資料連線。




三、JDBC應用示例實驗

實驗 步驟:
S1、下載ojdbc14.jar驅動檔案,並將該檔案放到你的專案中去; 
S2、在MyEclipse中的專案中新增Oracle驅動程式:在專案名上右鍵-> Build Path ->Add External Archiver然後選擇你剛才放在專案中的檔案, 點確定即可。
S3、開啟Oracle的各項服務,並在Oracle中建一張表。
S4、編寫MyEclipse與Oracle的連線程式:
[cpp] view plaincopyprint?<SPAN style="FONT-SIZE: 16px">import java.sql.Connection;  
import java.sql.DriverManager;  
import java.sql.PreparedStatement;  
import java.sql.ResultSet;  
import java.sql.Statement;  
import java.sql.* ;  
  
public class JDBC_Test {  
    //orcl為oracle資料庫中的資料庫名,localhost表示連線本機的oracle資料庫   
   //1521為連線的埠號   
    private static String url="jdbc:oracle:thin:@localhost:1521:orcl";  
    //system為登陸oracle資料庫的使用者名稱   
    private static String user="system";  
    //manager為使用者名稱system的密碼   
    private static String password="manager";  
    public static Connection conn;  
    public static PreparedStatement ps;  
    public static ResultSet rs;  
    public static Statement st ;  
    //連線資料庫的方法   
    public void getConnection(){  
        try {  
            //初始化驅動包   
            Class.forName("oracle.jdbc.driver.OracleDriver");  
            //根據資料庫連線字元,名稱,密碼給conn賦值   
            conn=DriverManager.getConnection(url, user, password);  
              
        } catch (Exception e) {  
            // TODO: handle exception   
            e.printStackTrace();  
        }  
    }  
     //測試能否與oracle資料庫連線成功   
     public static void main(String[] args) {  
        JDBC_Test basedao=new JDBC_Test();  
        basedao.getConnection();  
        if(conn==null){  
            System.out.println("與oracle資料庫連線失敗!");  
        }else{  
            System.out.println("與oracle資料庫連線成功!");  
        }  
     }  
}  
</SPAN>  

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.* ;

public class JDBC_Test {
	//orcl為oracle資料庫中的資料庫名,localhost表示連線本機的oracle資料庫
   //1521為連線的埠號
	private static String url="jdbc:oracle:thin:@localhost:1521:orcl";
	//system為登陸oracle資料庫的使用者名稱
	private static String user="system";
	//manager為使用者名稱system的密碼
	private static String password="manager";
	public static Connection conn;
	public static PreparedStatement ps;
	public static ResultSet rs;
	public static Statement st ;
	//連線資料庫的方法
	public void getConnection(){
		try {
			//初始化驅動包
			Class.forName("oracle.jdbc.driver.OracleDriver");
			//根據資料庫連線字元,名稱,密碼給conn賦值
			conn=DriverManager.getConnection(url, user, password);
			
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}
	}
	 //測試能否與oracle資料庫連線成功
	 public static void main(String[] args) {
		JDBC_Test basedao=new JDBC_Test();
		basedao.getConnection();
		if(conn==null){
			System.out.println("與oracle資料庫連線失敗!");
		}else{
			System.out.println("與oracle資料庫連線成功!");
		}
	 }
}

S5、如果上述的連線已經建立,就可以利用JDBC中的Java API對資料庫進行操作了,具體的查詢,插入,刪除,更新操作如下:
[cpp] view plaincopyprint?<SPAN style="FONT-SIZE: 16px">程式碼轉載自:http://blog.csdn.net/cxwen78/article/details/6863696   
  
import java.sql.Connection;  
import java.sql.DriverManager;  
import java.sql.ResultSet;  
import java.sql.SQLException;  
import java.sql.Statement;  
  
public class JDBC_Test {  
    // 建立靜態全域性變數   
    static Connection conn;  
  
    static Statement st;  
  
    public static void main(String[] args) {  
        insert();   //插入新增記錄   
        update();   //更新記錄資料   
        delete();   //刪除記錄   
        query();    //查詢記錄並顯示   
    }  
      
    /* 插入資料記錄,並輸出插入的資料記錄數*/  
    public static void insert() {  
          
        conn = getConnection(); // 首先要獲取連線,即連線到資料庫   
  
        try {  
            String sql = "INSERT INTO staff(name, age, sex,address, depart, worklen,wage)"  
                    + " VALUES ('Tom1', 32, 'M', 'china','Personnel','3','3000')";  // 插入資料的sql語句   
              
            st = (Statement) conn.createStatement();    // 建立用於執行靜態sql語句的Statement物件   
              
            int count = st.executeUpdate(sql);  // 執行插入操作的sql語句,並返回插入資料的個數   
              
            System.out.println("向staff表中插入 " + count + " 條資料"); //輸出插入操作的處理結果   
              
            conn.close();   //關閉資料庫連線   
              
        } catch (SQLException e) {  
            System.out.println("插入資料失敗" + e.getMessage());  
        }  
    }  
      
    /* 更新符合要求的記錄,並返回更新的記錄數目*/  
    public static void update() {  
        conn = getConnection(); //同樣先要獲取連線,即連線到資料庫   
        try {  
            String sql = "update staff set wage='2200' where name = 'lucy'";// 更新資料的sql語句   
              
            st = (Statement) conn.createStatement();    //建立用於執行靜態sql語句的Statement物件,st屬區域性變數   
              
            int count = st.executeUpdate(sql);// 執行更新操作的sql語句,返回更新資料的個數   
              
            System.out.println("staff表中更新 " + count + " 條資料");      //輸出更新操作的處理結果   
              
            conn.close();   //關閉資料庫連線   
              
        } catch (SQLException e) {  
            System.out.println("更新資料失敗");  
        }  
    }  
  
    /* 查詢資料庫,輸出符合要求的記錄的情況*/  
    public static void query() {  
          
        conn = getConnection(); //同樣先要獲取連線,即連線到資料庫   
        try {  
            String sql = "select * from staff";     // 查詢資料的sql語句   
            st = (Statement) conn.createStatement();    //建立用於執行靜態sql語句的Statement物件,st屬區域性變數   
              
            ResultSet rs = st.executeQuery(sql);    //執行sql查詢語句,返回查詢資料的結果集   
            System.out.println("最後的查詢結果為:");  
            while (rs.next()) { // 判斷是否還有下一個資料   
                  
                // 根據欄位名獲取相應的值   
                String name = rs.getString("name");  
                int age = rs.getInt("age");  
                String sex = rs.getString("sex");  
                String address = rs.getString("address");  
                String depart = rs.getString("depart");  
                String worklen = rs.getString("worklen");  
                String wage = rs.getString("wage");  
                  
                //輸出查到的記錄的各個欄位的值   
                System.out.println(name + " " + age + " " + sex + " " + address  
                        + " " + depart + " " + worklen + " " + wage);  
              
            }  
            conn.close();   //關閉資料庫連線   
              
        } catch (SQLException e) {  
            System.out.println("查詢資料失敗");  
        }  
    }  
  
    /* 刪除符合要求的記錄,輸出情況*/  
    public static void delete() {  
  
        conn = getConnection(); //同樣先要獲取連線,即連線到資料庫   
        try {  
            String sql = "delete from staff  where name = 'lili'";// 刪除資料的sql語句   
            st = (Statement) conn.createStatement();    //建立用於執行靜態sql語句的Statement物件,st屬區域性變數   
              
            int count = st.executeUpdate(sql);// 執行sql刪除語句,返回刪除資料的數量   
              
            System.out.println("staff表中刪除 " + count + " 條資料\n");    //輸出刪除操作的處理結果   
              
            conn.close();   //關閉資料庫連線   
              
        } catch (SQLException e) {  
            System.out.println("刪除資料失敗");  
        }  
          
    }  
      
    /* 獲取資料庫連線的函式*/  
    public static Connection getConnection() {  
        Connection con = null;  //建立用於連線資料庫的Connection物件   
        try {  
            Class.forName("com.mysql.jdbc.Driver");// 載入Mysql資料驅動   
              
            con = DriverManager.getConnection(  
                    "jdbc:mysql://localhost:3306/myuser", "root", "root");// 建立資料連線  
              
        } catch (Exception e) {  
            System.out.println("資料庫連線失敗" + e.getMessage());  
        }  
        return con; //返回所建立的資料庫連線   
    }  
}  
</SPAN>