本文提供 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 步执行成功，并无报错信息，说明已正确加载 OceanBase Connector/J 驱动程序的 JAR 包。

   说明

   对于专有云或独立部署的场景， username 的格式为： String username = "用户名@租户#集群";

4. 连接数据库。

   驱动程序加载完成后，使用 OceanBase 数据库的 IP 地址及端口号进行数据库连接。即在如下代码段中，将  String url 字段填入相应的 IP 地址、端口号和 Schema 名称。

   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/schemaname?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();
          }
      }

   数据库连接成功后，可以重新执行上述第 2 步和第 3 步进行加载类。

说明

对于专有云或独立部署的场景， username 的格式为： String username = "用户名@租户#集群";