Java 應用程序連接 OceanBase 數據庫

OceanBase Connector/J 為基於 Java 開發的應用程序提供與 OceanBase 數據庫的連接。本文主要介紹該連接方式的前提條件和操作步驟。

前提條件

• 確保設置了基本的數據庫開發環境。

• 確保計算機上的 Java 環境為 Java JDK 8 版本。

• 請聯系技術支持人員獲取 OceanBase Connector/J 驅動程序安裝包。

操作步驟步驟

將 OceanBase Connector/J 的 JAR 安裝包放入本地路徑中，通過 cmd 引入 JAR 包，進行如下連接測試：

1. 編寫 Java 示例文件 HelloWorld.java 並加載驅動類。

   public class HelloWorld {
      public static void main(String[] args) {
          try {
              Class.forName("com.oceanbase.jdbc.Driver");
          } catch (ClassNotFoundException e) {
              e.printStackTrace();
          }
      }
   }

2. 編譯 Java 示例文件，命令如下：

   javac -cp target/oceanbase-client-{version}.jar HelloWorld.java

    

   說明

    用戶可以根據情況自行更改編譯路徑。

3. 運行 Java 示例文件，命令如下：

   java -cp .:target/oceanbase-client-{version}.jar HelloWorld

如果第 2 步、第 3 步和第 4 步執行成功，並無報錯信息，說明已正確加載 OceanBase Connector/J 驅動程序的 JAR 包。

驅動程序加載完成后，使用 OceanBase 數據庫的 IP 地址及端口號進行數據庫連接。即在如下代碼段中，將 String url 字段填入相應的 IP 地址、端口號和 Schema Name。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class HelloWorld {
   public static void main(String[] args) {
       try {
           String url = "jdbc:oceanbase://ipaddress:port/shemaname?pool=false";
           String  user = "username";
           String  password = "password";
           Class.forName("com.oceanbase.jdbc.Driver");
           Connection connection = DriverManager.getConnection(url, user, password);
       } catch (ClassNotFoundException e) {
           e.printStackTrace();
       }
   }

數據庫連接成功后，可以重新執行上述第 3 步和第 4 步進行加載類。