HikariCP 连接池连接 OceanBase 数据库示例程序

本文将介绍如何使用 HikariCP 连接池、OceanBase Connector/J 和 OceanBase 数据库构建一个应用程序，实现基本的数据库操作，包括创建表、插入、删除、更新和查询数据等。

点击下载 hikaricp-oceanbase-client 示例工程 HikariCP 连接池连接 OceanBase 数据库示例程序（Oracle 模式）

前提条件

• 您已安装 OceanBase 数据库并且创建了 Oracle 模式租户。

• 您已安装 JDK 1.8 和 Maven。

• 您已安装 Eclipse。

  说明

  本文档运行代码使用的工具是 Eclipse IDE for Java Developers 2022-03 版本，您也可以根据个人喜好选择适合自己的工具运行的示例代码。

操作步骤

1. 将 hikaricp-oceanbase-client 项目导入到 Eclipse 中。
2. 获取 OceanBase 数据库 URL。
3. 修改 hikaricp-oceanbase-client 项目中的数据库连接信息。
4. 运行 hikaricp-oceanbase-client 项目。

步骤一：将 hikaricp-oceanbase-client 项目导入到 Eclipse 中

1. 打开 Eclipse，在菜单栏上选择 File -> Open Projects from File System。

2. 在弹出的对话框中，点击 Directory 按钮选择项目所在的目录，然后点击 Finish 完成导入。

   说明

   当使用 Eclipse 导入 Maven 项目时，Eclipse 会自动检测项目中的 pom.xml 文件，并根据文件中描述的依赖关系自动下载所需的依赖库，并将它们添加到项目中。

   

3. 查看项目情况。

   

步骤二：获取 OceanBase 数据库 URL

1. 联系 OceanBase 数据库部署人员或者管理员获取相应的数据库连接串。

   示例如下：

   obclient -hxxx.xxx.xxx.xxx -P2881 -utest_user001@oracel001 -p******
   

   更多连接串的信息，请参见 通过 OBClient 连接 OceanBase 租户。

2. 根据 OceanBase 数据库连接串信息填写下面 URL 的对应信息。

   jdbc:oceanbase://$host:$port/$schema_name?user=$user_name&password=$password
   

   参数说明：

   • $host：提供 OceanBase 数据库连接 IP。OceanBase 数据库代理（OceanBase Database Proxy，ODP）连接方式使用的是一个 ODP 地址；直连方式使用的是 OBServer 节点的 IP 地址。

   • $port：提供 OceanBase 数据库连接端口。ODP 连接的方式默认是 2883，在部署 ODP 时可自定义；直连方式默认是 2881，在部署 OceanBase 数据库时可自定义。

   • $schema_name：需要访问的 Schema 名称。

     注意

     连接租户的用户需要拥有 CREATE SESSION 权限和该 Schema 的 CREATE TABLE、INSERT、DELETE、UPDATE 和 SELECT 权限。更多有关用户权限的信息，请参见 Oracle 模式下的权限分类。

   • $user_name：提供租户的连接账户。ODP 连接的常用格式：用户名@租户名#集群名 或者 集群名:租户名:用户名；直连方式格式：用户名@租户名。

   • $password：提供账户密码。

   更多 OceanBase Connector/J URL 参数说明信息，请参见 数据库 URL。

   示例如下：

   jdbc:oceanbase://xxx.xxx.xxx.xxx:2881/test_schema001?user=test_user001@oracel001&password=******
   

步骤三：修改 hikaricp-oceanbase-client 项目中的数据库连接信息

根据 步骤二：获取 OceanBase 数据库 URL 中获取的信息修改 hikaricp-oceanbase-client/src/main/resources/db.properties 文件中的数据库连接信息。

示例如下：

• OBServer 节点的 IP 地址为 xxx.xxx.xxx.xxx。
• 访问端口使用的是 2881。
• 需要访问的 Schema 名称为 test_schema001。
• 租户的连接账户是 test_user001@oracle001。oracle001 是在 OceanBase 数据库中创建的一个 Oracle 模式的用户租户，test_user001 是租户 oracle001 的用户名称。
• 密码是 ******。

代码如下：

...
jdbcUrl=jdbc:oceanbase://xxx.xxx.xxx.xxx:2881/test_schema001
username=test_user001@oracle001
password=******
...

步骤四：运行 hikaricp-oceanbase-client 项目

1. 在项目导航器视图中，找到并展开 src/main/java 目录。

2. 右键点击 Main.java 文件，然后选择 Run As -> Java Application。

   

3. 在 Eclipse 的控制台窗口中来查看项目的日志信息和输出结果。

   

4. 也可以在 OceanBase 客户端（OBClient）中执行以下 SQL 语句查看结果。

   obclient [SYS]> SELECT * FROM test_schema001.test_hikaricp;
   

   返回结果如下：

   +------+-------------+
   | ID   | NAME        |
   +------+-------------+
   |    1 | test_update |
   +------+-------------+
   1 row in set
   

项目代码介绍

点击 hikaricp-oceanbase-client 下载项目代码，是一个名称为 hikaricp-oceanbase-client.zip 的压缩包。

解压后，得到一个名为 hikaricp-oceanbase-client 的文件夹。目录结构如下所示：

hikaricp-oceanbase-client
├── src
│   └── main
│       ├── java
│       │   └── com
│       │       └── example
│       │           └── Main.java
│       └── resources
│           └── db.properties
└── pom.xml

文件说明：

• src：源代码根目录。
• main：主代码目录，包含应用程序的主要逻辑。
• java：Java 源代码目录。
• com：Java 包目录。
• example：示例项目的包目录。
• Main.java：主类程序示例文件，包含创建表、插入、删除、更新和查询数据等逻辑。
• resources：资源文件目录，包含配置文件等。
• db.properties：连接池的配置文件，包含了数据库连接的相关参数。
• pom.xml：Maven 项目的配置文件，用于管理项目的依赖和构建设置。

pom.xml 代码介绍

pom.xml 文件是 Maven 项目的配置文件，定义了项目的依赖项、插件和构建规则等信息。Maven 是一个 Java 项目管理工具，可以自动下载依赖项、编译和打包项目等操作。

本文 pom.xml 文件的代码主要包括以下几个部分：

1. 文件声明语句。

   声明本文件是一个 XML 文件，使用的 XML 版本是 1.0，字符编码方式是 UTF-8。

   代码如下：

   <?xml version="1.0" encoding="UTF-8"?>
   

2. 配置 POM 的命名空间和 POM 模型版本。

   1. 通过 xmlns 指定 POM 的命名空间为 http://maven.apache.org/POM/4.0.0。
   2. 通过 xmlns:xsi 指定 XML 命名空间 http://www.w3.org/2001/XMLSchema-instance。
   3. 通过 xsi:schemaLocation 指定 POM 的命名空间为 http://maven.apache.org/POM/4.0.0 和 POM 的 XSD 文件的位置为 http://maven.apache.org/xsd/maven-4.0.0.xsd。
   4. 通过 <modelVersion> 元素指定了该 POM 文件使用的 POM 模型版本为 4.0.0。

   代码如下：

   <project xmlns="http://maven.apache.org/POM/4.0.0"
            xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
            xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <modelVersion>4.0.0</modelVersion>
   
    <!-- 其他配置 -->
   
   </project>
   

3. 配置基本信息。

   1. 通过 <groupId> 指定项目所属组织为 com.example。
   2. 通过 <artifactId> 指定项目的名称为 hikaricp-oceanbase-client。
   3. 通过 <version> 项目的版本号为 1.0-SNAPSHOT。

   代码如下：

       <groupId>com.example</groupId>
       <artifactId>hikaricp-oceanbase-client</artifactId>
       <version>1.0-SNAPSHOT</version>
   

4. 配置项目源文件的属性。

   指定 Maven 的编译器插件为 maven-compiler-plugin，并设置了源代码和目标 Java 版本都为 8。这意味着项目的源代码使用 Java 8 特性编写，且编译后的字节码也将兼容 Java 8 运行时环境。这样设置可以确保项目在编译和运行时能够正确地处理 Java 8 的语法和特性。

   说明

   Java 1.8 和 Java 8 是同一个版本的不同命名方式。

   代码如下：

       <build>
           <plugins>
               <plugin>
                   <groupId>org.apache.maven.plugins</groupId>
                   <artifactId>maven-compiler-plugin</artifactId>
                   <configuration>
                       <source>8</source>
                       <target>8</target>
                   </configuration>
               </plugin>
           </plugins>
       </build>
   

5. 配置项目所依赖组件。

   1. 添加 oceanbase-client 依赖库，用于与数据库进行交互：

      1. 通过 <groupId> 指定依赖项所属的组织为 com.oceanbase。
      2. 通过 <artifactId> 指定依赖项的名称为 oceanbase-client。
      3. 通过 <version> 指定依赖项的版本号为 2.4.2。

      说明

      本部分代码定义项目所依赖组件是 OceanBase Connector/J 的 V2.4.2 版本，如果需要了解其他版本的信息，请参见 OceanBase JDBC 驱动程序

      代码如下：

              <dependency>
                  <groupId>com.oceanbase</groupId>
                  <artifactId>oceanbase-client</artifactId>
                  <version>2.4.2</version>
              </dependency>
      

   2. 添加 HikariCP 依赖库，用于实现高性能的 JDBC 连接池：

      1. 通过 <groupId> 指定依赖项所属的组织为 com.zaxxer。
      2. 通过 <artifactId> 指定依赖项的名称为 HikariCP。
      3. 通过 <version> 指定依赖项的版本号为 3.3.1。

      代码如下：

              <dependency>
                  <groupId>com.zaxxer</groupId>
                  <artifactId>HikariCP</artifactId>
                  <version>3.3.1</version>
              </dependency>
      

   3. 添加 logback-classic 依赖库，用于方便地进行日志记录和管理：

      1. 通过 <groupId> 指定依赖项所属的组织为 ch.qos.logback。
      2. 通过 <artifactId> 指定依赖项的名称为 logback-classic。
      3. 通过 <version> 指定依赖项的版本号为 1.2.5。

      代码如下：

              <dependency>
                  <groupId>ch.qos.logback</groupId>
                  <artifactId>logback-classic</artifactId>
                  <version>1.2.5</version>
              </dependency>
      

db.properties 代码介绍

db.properties 是本文示例的连接池配置文件，其中包含了连接池的配置属性。这些属性包括数据库 URL、用户名、密码、连接池其他可选项。

本文 db.properties 文件的代码主要包括以下几个部分：

1. 配置数据库连接参数。

   1. 配置数据库连接的 URL，包括主机 IP、端口号、需要访问的 Schema。
   2. 配置数据库用户名。
   3. 配置数据库密码。

   代码如下：

   jdbcUrl=jdbc:oceanbase://$host:$port/$schema_name
   username=$user_name
   password=$password
   

   参数解释：

   • $host：提供 OceanBase 数据库连接 IP。ODP 连接方式使用的是一个 ODP 地址；直连方式使用的是 OBServer 节点的 IP 地址。
   • $port：提供 OceanBase 数据库连接端口。ODP 连接的方式默认是 2883，在部署 ODP 时可自定义；直连方式默认是 2881，在部署 OceanBase 数据库时可自定义。
   • $schema_name：需要访问的 Schema 名称。
   • $user_name：提供租户的连接账户。ODP 连接的常用格式：用户名@租户名#集群名 或者 集群名:租户名:用户名；直连方式格式：用户名@租户名。
   • $password：提供账户密码。

2. 配置其他连接池的参数。

   1. 启用预编译 SQL 语句的缓存。
   2. 设置预编译 SQL 语句的缓存大小为 250。
   3. 设置连接的最大生命周期为 1800000 毫秒（30 分钟），超过这个时间连接将被关闭。
   4. 设置连接的空闲超时时间为 600000 毫秒（10 分钟），超过这个时间且连接处于空闲状态时，连接将被关闭。
   5. 设置连接的超时时间为 30000 毫秒（30 秒），超过这个时间仍未获得连接时，将抛出异常。

   代码如下：

   dataSource.cachePrepStmts=true
   dataSource.prepStmtCacheSize=250
   dataSource.maxLifetime=1800000
   dataSource.idleTimeout=600000
   dataSource.connectionTimeout=30000
   

HikariCP 连接池常用基本参数:

Main.java 代码介绍

Main.java 文件是示例程序的一部分，用于演示通过 HikariCP 连接池获取数据库连接，并执行一系列数据库操作，包括创建表、插入数据、删除数据、更新数据、查询数据，并将查询结果打印出来。

本文 Main.java 文件的代码主要包括以下几个部分：

1. 导入所需的类和包。

   1. 定义当前 Java 文件的包名为 com.example，用于组织和管理 Java 类。
   2. 导入 java.sql.Connection 类，用于建立和管理与数据库的连接。
   3. 导入 java.sql.PreparedStatement 类，用于执行预编译的 SQL 语句。
   4. 导入 java.sql.ResultSet 类，用于处理查询结果集。
   5. 导入 java.sql.SQLException 类，用于处理 SQL 异常。
   6. 导入 HikariCP 的 HikariConfig 类，用于配置 HikariCP 连接池。
   7. 导入 HikariCP 的 HikariDataSource 类，用于创建和管理 HikariCP 连接池。

   代码如下：

   package com.example;
   
   import java.sql.Connection;
   import java.sql.PreparedStatement;
   import java.sql.ResultSet;
   import java.sql.SQLException;
   import com.zaxxer.hikari.HikariConfig;
   import com.zaxxer.hikari.HikariDataSource;
   

2. 定义类名和方法。

   定义一个 Main 类，其中的 main 方法作为程序的入口。在 main 方法中，通过读取 db.properties 文件来配置 HikariCP 连接池，并获取数据库连接。然后依次调用了一系列的方法来创建表、插入数据、查询数据、更新数据和删除数据。如果在操作过程中发生 SQLException 异常，则会打印异常信息的堆栈跟踪。具体步骤如下：

   1. 定义一个名为 Main 的公共类。
   2. 定义 Main 类的入口方法 main。
   3. 创建一个 HikariConfig 对象，并通过指定的 db.properties 文件进行配置。
   4. 创建一个 HikariDataSource 对象，并在 try-with-resources 块中获取一个数据库连接。
   5. 调用用于创建表的方法，传递了获取的数据库连接对象，创建表 test_hikaricp。
   6. 调用用于插入数据的方法，传递了获取的数据库连接对象和数据参数，插入 (1,'A1') 和 (2,'A2') 两行数据。
   7. 调用用于查询数据的方法，传递了获取的数据库连接对象，查看数据插入情况。
   8. 调用用于更新数据的方法，传递了获取的数据库连接对象和更新参数，将 id 为 1 的行中 name 列的值更新为 test_update。
   9. 调用用于查询数据的方法，传递了获取的数据库连接对象，查看更新数据情况。
   10. 调用了一个用于删除数据的方法，传递了获取的数据库连接对象和删除参数，将 id 为 2 的行删除。
   11. 调用了一个用于查询数据的方法，传递了获取的数据库连接对象，查看删除数据情况。
   12. 如果在 try 块中发生了 SQLException 异常，将打印异常的堆栈跟踪信息。
   13. 定义用于创建表、插入数据、查询数据、更新数据和删除数据的方法。

   代码如下：

   public class Main {
       public static void main(String[] args) {
           try {
               HikariConfig config = new HikariConfig("/db.properties");
               try (HikariDataSource dataSource = new HikariDataSource(config);
                   Connection conn = dataSource.getConnection()) {
                   createTable(conn);
   
                   insertData(conn, 1, "A1");
                   insertData(conn, 2, "A2");
   
                   selectData(conn);
   
                   updateData(conn, "test_update", 1);
                   selectData(conn);
   
                   deleteData(conn, 2);
                   selectData(conn);
               }
           } catch (SQLException e) {
               e.printStackTrace();
           }
       }
   
       // 定义用于创建表的方法
       // 定义用于插入数据的方法
       // 定义用于查询数据的方法
       // 定义用于更新数据的方法
       // 定义用于删除数据的方法
   }
   

3. 定义用于创建表的方法。

   定义一个私有静态方法 createTable，用于在数据库中创建一个名为 test_hikaricp 的表，该表包含 id 列和 name 列。具体步骤如下：

   1. 定义一个私有静态方法 createTable，该方法接受一个 Connection 对象作为参数，并声明可能抛出 SQLException 异常。
   2. 定义一个 SQL 语句字符串，用于创建名为 test_hikaricp 的表，表包含 id 列（数据类型为 NUMBER）和 name 列（数据类型为 VARCHAR2(50)）。
   3. 使用连接对象 conn 创建一个预编译的 SQL 语句对象 pstmt，并在 try-with-resources 块中使用该对象。
   4. 执行 SQL 语句，创建名为 test_hikaricp 的表。
   5. 在控制台输出打印消息，表示表创建成功。

   代码如下：

       private static void createTable(Connection conn) throws SQLException {
           String sql = "CREATE TABLE test_hikaricp (id NUMBER, name VARCHAR2(50))";
           try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
               pstmt.executeUpdate();
               System.out.println("Table created successfully.");
           }
       }
   

4. 定义用于插入数据的方法。

   定义一个私有静态方法 insertData，用于向数据库中的表 test_hikaricp 插入数据。具体步骤如下：

   1. 定义一个私有静态方法 insertData，该方法接受一个 Connection 对象、一个整数类型的 id 参数和一个字符串类型的 name 参数，并声明可能抛出 SQLException 异常。
   2. 定义一个 SQL 语句字符串，用于向名为 test_hikaricp 的表中插入数据，数据包括 id 和 name 列。
   3. 使用连接对象 conn 创建一个预编译的 SQL 语句对象 pstmt，并在 try-with-resources 块中使用该对象。
   4. 设置 SQL 语句中第一个参数 ? 的值为 id。
   5. 设置 SQL 语句中第二个参数 ? 的值为 name。
   6. 执行 SQL 语句，向表中插入数据。
   7. 在控制台输出打印消息，表示数据插入成功。

   代码如下：

       private static void insertData(Connection conn, int id, String name) throws SQLException {
           String sql = "INSERT INTO test_hikaricp (id, name) VALUES (?, ?)";
           try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
               pstmt.setInt(1, id);
               pstmt.setString(2, name);
               pstmt.executeUpdate();
               System.out.println("Data inserted successfully.");
           }
       }
   

5. 定义用于查询数据的方法。

   定义一个私有静态方法 selectData，用于从数据库中查询表 test_hikaricp 的数据。具体步骤如下：

   1. 定义一个私有静态方法 selectData，该方法接受一个 Connection 对象作为参数，并声明可能抛出 SQLException 异常。
   2. 定义一个 SQL 语句字符串，用于查询名为 test_hikaricp 的表中的所有数据。
   3. 使用连接对象 conn 创建一个预编译的 SQL 语句对象 pstmt，并在 try-with-resources 块中使用该对象。同时，通过调用 executeQuery() 方法执行 SQL 查询，并返回查询结果集对象 rs。
   4. 在控制台输出打印消息，表示正在打印用户数据。
   5. 遍历查询结果集，使用 next() 方法检查结果集中是否还有下一行数据，如果有，则进入循环。
   6. 从结果集中获取 id 列的值，并将其赋给变量 id。
   7. 从结果集中获取 name 列的值，并将其赋给变量 name。
   8. 在控制台输出打印每行数据的 id 和 name 值。
   9. 在控制台输出一个空行。

   代码如下：

       private static void selectData(Connection conn) throws SQLException {
           String sql = "SELECT * FROM test_hikaricp";
           try (PreparedStatement pstmt = conn.prepareStatement(sql);
               ResultSet rs = pstmt.executeQuery()) {
               System.out.println("User Data:");
               while (rs.next()) {
                   int id = rs.getInt("id");
                   String name = rs.getString("name");
                   System.out.println("ID: " + id + ", Name: " + name);
               }
               System.out.println();
           }
       }
   

6. 定义用于更新数据的方法。

   定义一个私有静态方法 updateData，用于更新数据库中表 test_hikaricp 中的数据。具体步骤如下：

   1. 定义一个私有静态方法 updateData，该方法接受一个 Connection 对象、一个字符串类型的 name 参数和一个整数类型的 id 参数，并声明可能抛出 SQLException 异常。
   2. 定义一个 SQL 语句字符串，用于更新名为 test_hikaricp 的表中的数据，将 name 列的值更新为指定的 name，条件是 id 列的值等于指定的 id。
   3. 使用连接对象 conn 创建一个预编译的 SQL 语句对象 pstmt，并在 try-with-resources 块中使用该对象。
   4. 设置 SQL 语句中第一个参数 ? 的值为 name。
   5. 设置 SQL 语句中第二个参数 ? 的值为 id。
   6. 执行 SQL 语句，更新表中的数据。
   7. 在控制台输出打印消息，表示数据更新成功。

   代码如下：

       private static void updateData(Connection conn, String name, int id) throws SQLException {
           String sql = "UPDATE test_hikaricp SET name = ? WHERE id = ?";
           try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
               pstmt.setString(1, name);
               pstmt.setInt(2, id);
               pstmt.executeUpdate();
               System.out.println("Data updated successfully.");
           }
       }
   

7. 定义用于删除数据的方法。

   定义一个私有静态方法 deleteData，用于从数据库中删除表 test_hikaricp 中满足条件的数据。具体步骤如下：

   1. 定义一个私有静态方法 deleteData，该方法接受一个 Connection 对象和一个整数类型的 id 参数，并声明可能抛出 SQLException 异常。
   2. 定义一个 SQL 语句字符串，用于从名为 test_hikaricp 的表中删除满足条件 id = ? 的数据。
   3. 使用连接对象 conn 创建一个预编译的 SQL 语句对象 pstmt，并在 try-with-resources 块中使用该对象。
   4. 设置 SQL 语句中第一个参数 ? 的值为 id。
   5. 执行 SQL 语句，从表中删除满足条件的数据。
   6. 在控制台输出打印消息，表示数据删除成功。

   代码如下：

       private static void deleteData(Connection conn, int id) throws SQLException {
           String sql = "DELETE FROM test_hikaricp WHERE id = ?";
           try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
               pstmt.setInt(1, id);
               pstmt.executeUpdate();
               System.out.println("Data deleted successfully.");
           }
       }
   

完整的代码展示

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.oceanbase</groupId>
    <artifactId>hikaricp-oceanbase-client</artifactId>
    <version>1.0-SNAPSHOT</version>
    <build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <configuration>
                    <source>8</source>
                    <target>8</target>
                </configuration>
            </plugin>
        </plugins>
    </build>

    <dependencies>
        <dependency>
            <groupId>com.oceanbase</groupId>
            <artifactId>oceanbase-client</artifactId>
            <version>2.4.2</version>
        </dependency>
        <dependency>
            <groupId>com.zaxxer</groupId>
            <artifactId>HikariCP</artifactId>
            <version>3.3.1</version>
        </dependency>
        <dependency>
            <groupId>ch.qos.logback</groupId>
            <artifactId>logback-classic</artifactId>
            <version>1.2.5</version>
        </dependency>
    </dependencies>
</project>

jdbcUrl=jdbc:oceanbase://$host:$port/$schema_name
username=$user_name
password=$password

dataSource.cachePrepStmts=true
dataSource.prepStmtCacheSize=250
dataSource.maxLifetime=1800000
dataSource.idleTimeout=600000
dataSource.connectionTimeout=30000

package com.example;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;

public class Main {
    public static void main(String[] args) {
        try {
            HikariConfig config = new HikariConfig("/db.properties");
            try (HikariDataSource dataSource = new HikariDataSource(config);
                 Connection conn = dataSource.getConnection()) {
                createTable(conn);

                insertData(conn, 1, "A1");
                insertData(conn, 2, "A2");

                selectData(conn);

                updateData(conn, "test_update", 1);
                selectData(conn);

                deleteData(conn, 2);
                selectData(conn);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    private static void createTable(Connection conn) throws SQLException {
        String sql = "CREATE TABLE test_hikaricp (id NUMBER, name VARCHAR2(50))";
        try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
            pstmt.executeUpdate();
            System.out.println("Table created successfully.");
        }
    }

    private static void insertData(Connection conn, int id, String name) throws SQLException {
        String sql = "INSERT INTO test_hikaricp (id, name) VALUES (?, ?)";
        try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
            pstmt.setInt(1, id);
            pstmt.setString(2, name);
            pstmt.executeUpdate();
            System.out.println("Data inserted successfully.");
        }
    }

    private static void selectData(Connection conn) throws SQLException {
        String sql = "SELECT * FROM test_hikaricp";
        try (PreparedStatement pstmt = conn.prepareStatement(sql);
             ResultSet rs = pstmt.executeQuery()) {
            System.out.println("User Data:");
            while (rs.next()) {
                int id = rs.getInt("id");
                String name = rs.getString("name");
                System.out.println("ID: " + id + ", Name: " + name);
            }
            System.out.println();
        }
    }

    private static void updateData(Connection conn, String name, int id) throws SQLException {
        String sql = "UPDATE test_hikaricp SET name = ? WHERE id = ?";
        try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
            pstmt.setString(1, name);
            pstmt.setInt(2, id);
            pstmt.executeUpdate();
            System.out.println("Data updated successfully.");
        }
    }

    private static void deleteData(Connection conn, int id) throws SQLException {
        String sql = "DELETE FROM test_hikaricp WHERE id = ?";
        try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
            pstmt.setInt(1, id);
            pstmt.executeUpdate();
            System.out.println("Data deleted successfully.");
        }
    }
}

相关文档

• 更多 OceanBase Connector/J 的信息，请参见 OceanBase JDBC 驱动程序。
• 更多使用 HikariCP 连接池的信息，请参见 HikariCP。