ApsaraDB for OceanBase (Deprecated)：Java 驅動串連 OceanBase 資料庫

前提條件

• 確保設定了基本的資料庫開發環境。

• 確保電腦上的 Java 環境為 Java JDK 8 版本。

• 擷取 OceanBase Connector/J 驅動程式。請在 OceanBase 官方網站的 資源 -> 下載中心 -> 公用雲端 -> 中介軟體 下的 OceanBase JDBC 驅動程式 中單擊對應的版本，登入後自助下載 OceanBase Connector/J 驅動程式。

Java 驅動串連 OceanBase 資料庫

步驟一：擷取資料庫連接參數

參考 擷取串連參數 文檔，擷取相應的租戶串連參數，例如：

$ obclient -hxxx.xxx.xxx.xxx -P3306 -u a**** -p******

資料庫連接參數包含了訪問資料庫所需的參數資訊，在驗證範例程式碼前，可通過資料庫連接參數驗證登入資料庫，保證資訊正確。

參數說明：

• -h：OceanBase 資料庫連接的網域名稱。

• -P：OceanBase 資料庫連接連接埠，Oracle 模式租戶預設是 1521。

• -u：租戶的串連帳號。

• -p：帳號密碼。

步驟二：安裝 OceanBase Connector/J 驅動

根據下載的實際檔案版本，將 OceanBase Connector/J 的 JAR 包解壓後放入本地 /usr/share/java 路徑中，

$ mv ./oceanbase-client-{version}.jar /usr/share/java

然後設定臨時環境變數。

$ export CLASSPATH=/usr/share/java/oceanbase-client-{version}.jar:$CLASSPATH

步驟三：編寫範例程式碼

編寫 Java 樣本檔案 Test.java。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.ResultSet;
import java.sql.Statement;

public class Test {
    public static void main(String[] args) {
        try {

            Class.forName("com.oceanbase.jdbc.Driver");
            Connection connection = DriverManager.getConnection("jdbc:oceanbase://xxx.xxx.xxx.xxx:3306/?pool=false&user=a****&password=******");
            System.out.println(connection.getAutoCommit());
            Statement sm = connection.createStatement();
            //建立表 t_meta_form
            sm.executeUpdate("CREATE TABLE t_meta_form (name varchar(36) , id int)");
            //插入資料
            sm.executeUpdate("insert into t_meta_form values ('an','1')");
            //查詢資料，並輸出結果
            ResultSet rs = sm.executeQuery("select * from t_meta_form");
            while (rs.next()) {
                String name = rs.getString("name");
                String id = rs.getString("id");
                System.out.println(name + ','+ id);
            }
            //刪除表
            sm.executeUpdate("drop table t_meta_form");
        }catch (SQLException ex) {
            System.out.println("error!");
            ex.printStackTrace() ;
        }catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
}

修改代碼中的資料庫連接參數。參考如下欄位，對應的值，則取自步驟一擷取的資料庫連接參數。

• url：取自 -h 和 -P 參數，jdbc:oceanbase://IP:port/?pool=false。OceanBase 資料庫連接的網域名稱以及連接埠號碼。Oracle 模式租戶預設連接埠號碼為 1521。

• user：取自 -u 參數，串連租戶的帳號。

• password：取自 -p 參數，帳號密碼。

步驟四：執行樣本

1. 代碼編輯完成後，可以通過如下命令進行編譯。

   $ javac Test.java

2. 編譯完成後，運行代碼。

   $ java Test

3. 獲得如下結果，說明資料庫連接成功，樣本語句正確執行。

   true
   an,1