--- title: "HikariCP 连接池连接 OceanBase 数据库示例程序 - OceanBase 数据库 V4.6.0 | OceanBase 文档中心" description: HikariCP 连接池连接 OceanBase 数据库示例程序 本文将介绍如何使用 HikariCP 连接池、MySQL Connector/J 和 OceanBase 数据库构建一个应用程序，实现基本的数据库操作，包括创建表、插入、删除、更新和查询数据等。 点击下载 hikaricp-mysql-client 示… --- 切换语言 - 中文站 - 简体中文 - International - English - 日本站 - 日本語 文档反馈![](https://mdn.alipayobjects.com/huamei_22khvb/afts/img/A*P8CuR4UJ_FkAAAAAAAAAAAAADiGDAQ/original) OceanBase 数据库分布式版 - V 4.6.0 # HikariCP 连接池连接 OceanBase 数据库示例程序 更新时间：2026-07-01 18:07:24 [编辑](https://github.com/oceanbase/oceanbase-doc/edit/V4.6.0/zh-CN/300.develop/100.application-development-of-mysql-mode/100.connect-to-oceanbase-database-of-mysql-mode/1400.use-the-database-connection-pool-of-mysql-mode/500.hikaricp-connection-pool-configuration-example-of-mysql-mode.md) 本文将介绍如何使用 HikariCP 连接池、MySQL Connector/J 和 OceanBase 数据库构建一个应用程序，实现基本的数据库操作，包括创建表、插入、删除、更新和查询数据等。 [![](https://file.oceanbase.com/doc/img/lQLPJyFovGIOcJQWFrAqhLlgRRsPvwU-H7hJ_i0A_22_22.png) 点击下载 hikaricp-mysql-client 示例工程](https://obbusiness-private.oss-cn-shanghai.aliyuncs.com/doc/img/observer-enterprise/V4.2.0/3.develop/connection-pool/hikaricp-mysql-client/hikaricp-mysql-client.zip) [![](https://mdn.alipayobjects.com/huamei_22khvb/afts/img/A*DFPmToHK6hgAAAAAAAAAAAAADiGDAQ/original) HikariCP 连接池连接 OceanBase 数据库示例程序（MySQL 模式）](https://obbusiness-private.oss-cn-shanghai.aliyuncs.com/video-center/video/video/03%20hikaricp-mysql-client.mp4) ## 前提条件 - 您已安装 OceanBase 数据库并且创建了 MySQL 模式租户。 - 您已安装 JDK 1.8 和 Maven。 - 您已安装 Eclipse。 #### 说明 本文档运行代码使用的工具是 Eclipse IDE for Java Developers 2022-03 版本，您也可以根据个人喜好选择适合自己的工具运行的示例代码。 ## 操作步骤 #### 说明 本文中给出的操作步骤是在 Windows 环境下使用 Eclipse IDE for Java Developers 2022-03 编译和运行该项目的步骤。如果您使用的是其他操作系统环境或编译器，那么操作步骤可能会略有不同。 1. 将 `hikaricp-mysql-client` 项目导入到 Eclipse 中。 2. 获取 OceanBase 数据库 URL。 3. 修改 `hikaricp-mysql-client` 项目中的数据库连接信息。 4. 运行 `hikaricp-mysql-client` 项目。 ### 步骤一：将 hikaricp-mysql-client 项目导入到 Eclipse 中 1. 打开 Eclipse，在菜单栏上选择 **File** -> **Open Projects from File System**。 2. 在弹出的对话框中，点击 **Directory** 按钮选择项目所在的目录，然后点击 **Finish** 完成导入。 #### 说明 当使用 Eclipse 导入 Maven 项目时，Eclipse 会自动检测项目中的 `pom.xml` 文件，并根据文件中描述的依赖关系自动下载所需的依赖库，并将它们添加到项目中。 ![1](https://obbusiness-private.oss-cn-shanghai.aliyuncs.com/doc/img/observer-enterprise/V4.2.0/3.develop/connection-pool/hikaricp-mysql-client/1.png) 3. 查看项目情况。 ![2](https://obbusiness-private.oss-cn-shanghai.aliyuncs.com/doc/img/observer-enterprise/V4.2.0/3.develop/connection-pool/hikaricp-mysql-client/2.png) ### 步骤二：获取 OceanBase 数据库 URL 1. 联系 OceanBase 数据库部署人员或者管理员获取相应的数据库连接串。 **示例如下：** ```shell obclient -hxxx.xxx.xxx.xxx -P2881 -utest_user001@mysql001 -p****** -Dtest ``` 更多连接串的信息，请参见 [通过 OBClient 连接 OceanBase 租户](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005682522)。 2. 根据 OceanBase 数据库连接串信息填写下面 URL 的对应信息。 ```shell jdbc:mysql://$host:$port/$database_name?user=$user_name&password=$password&useSSL=false ``` **参数说明：** - `$host`：提供 OceanBase 数据库连接 IP。OceanBase 数据库代理（OceanBase Database Proxy，ODP）连接方式使用的是一个 ODP 地址；直连方式使用的是 OBServer 节点的 IP 地址。 - `$port`：提供 OceanBase 数据库连接端口。ODP 连接的方式默认是 `2883`，在部署 ODP 时可自定义；直连方式默认是 `2881`，在部署 OceanBase 数据库时可自定义。 - `$database_name`：需要访问的数据库名称。 #### 注意 连接租户的用户需要拥有该数据库的 `CREATE`、`INSERT`、`DELETE`、`UPDATE` 和 `SELECT` 权限。更多有关用户权限的信息，请参见 [MySQL 模式下的权限分类](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005685770)。 - `user_name`：提供租户的连接账户。ODP 连接的常用格式：`用户名@租户名#集群名` 或者 `集群名:租户名:用户名`；直连方式格式：`用户名@租户名`。 - `password`：提供账户密码。 更多有关 MySQL Connector/J 连接属性信息，请参见 [Configuration Properties](https://dev.mysql.com/doc/connector-j/en/connector-j-reference-configuration-properties.html)。 **示例如下：** ```shell jdbc:mysql://xxx.xxx.xxx.xxx:2881/test?user=test_user001@mysql001&password=******&useSSL=false ``` ### 步骤三：修改 hikaricp-mysql-client 项目中的数据库连接信息 根据 **步骤二：获取 OceanBase 数据库 URL** 中获取的信息修改文件 `hikaricp-mysql-client/src/main/resources/db.properties` 中的数据库连接信息。 ![3](https://obbusiness-private.oss-cn-shanghai.aliyuncs.com/doc/img/observer-enterprise/V4.2.0/3.develop/connection-pool/hikaricp-mysql-client/3.png) **示例如下：** - OBServer 节点的 IP 地址为 `xxx.xxx.xxx.xxx`。 - 访问端口使用的是 2881。 - 需要访问的数据库名称为 `test`。 - 租户的连接账户是 `test_user001@mysql001`。`mysql001` 是在 OceanBase 数据库中创建的一个 MySQL 模式的用户租户，`test_user001` 是租户 `mysql001` 的用户名称。 - 密码是 `******`。 **代码如下：** ```java ... jdbcUrl=jdbc:mysql://xxx.xxx.xxx.xxx:2881/test?useSSL=false username=test_user001@mysql001 password=****** ... ``` ### 步骤四：运行 hikaricp-mysql-client 项目 1. 在项目导航器视图中，找到并展开 **src/main/java** 目录。 2. 右键点击 **Main.java** 文件，然后选择 **Run As** -> **Java Application**。 ![4](https://obbusiness-private.oss-cn-shanghai.aliyuncs.com/doc/img/observer-enterprise/V4.2.0/3.develop/connection-pool/hikaricp-mysql-client/4.png) 3. 在 Eclipse 的控制台窗口中来查看项目的日志信息和输出结果。 ![5](https://obbusiness-private.oss-cn-shanghai.aliyuncs.com/doc/img/observer-enterprise/V4.2.0/3.develop/connection-pool/hikaricp-mysql-client/5.png) 4. 也可以在 OceanBase 客户端（OBClient）中执行以下 SQL 语句查看结果。 ```shell obclient [(none)]> SELECT * FROM test.test_hikaricp; ``` **返回结果如下：** ```shell +------+-------------+ | id | name | +------+-------------+ | 1 | test_update | +------+-------------+ 1 row in set ``` ## 项目代码介绍 点击 [hikaricp-mysql-client](https://obbusiness-private.oss-cn-shanghai.aliyuncs.com/doc/img/observer-enterprise/V4.2.0/3.develop/connection-pool/hikaricp-mysql-client/hikaricp-mysql-client.zip) 下载项目代码，是一个名称为 `hikaricp-mysql-client.zip` 的压缩包。 解压后，得到一个名为 `hikaricp-mysql-client` 的文件夹。目录结构如下所示： ```shell hikaricp-mysql-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`。 **代码如下：** ```java ``` 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. 通过 `` 元素指定了该 POM 文件使用的 POM 模型版本为 `4.0.0`。 **代码如下：** ```java 4.0.0 ``` 3. 配置基本信息。 1. 通过 `` 指定项目所属组织为 `com.example`。 2. 通过 `` 指定项目的名称为 `hikaricp-mysql-client`。 3. 通过 `` 项目的版本号为 `1.0-SNAPSHOT`。 **代码如下：** ```java com.example hikaricp-mysql-client 1.0-SNAPSHOT ``` 4. 配置项目源文件的属性。 指定 Maven 的编译器插件为 `maven-compiler-plugin`，并设置了源代码和目标 Java 版本都为 8。这意味着项目的源代码使用 Java 8 特性编写，且编译后的字节码也将兼容 Java 8 运行时环境。这样设置可以确保项目在编译和运行时能够正确地处理 Java 8 的语法和特性。 #### 说明 Java 1.8 和 Java 8 是同一个版本的不同命名方式。 **代码如下：** ```java org.apache.maven.plugins maven-compiler-plugin 8 8 ``` 5. 配置项目所依赖组件。 1. 添加 `mysql-connector-java` 依赖库，用于与数据库进行交互： 1. 通过 `` 指定依赖项所属的组织为 `mysql`。 2. 通过 `` 指定依赖项的名称为 `mysql-connector-java`。 3. 通过 `` 指定依赖项的版本号为 `5.1.40`。 **代码如下：** ```java mysql mysql-connector-java 5.1.40 ``` 2. 添加 `HikariCP` 依赖库，用于实现高性能的 JDBC 连接池： 1. 通过 `` 指定依赖项所属的组织为 `com.zaxxer`。 2. 通过 `` 指定依赖项的名称为 `HikariCP`。 3. 通过 `` 指定依赖项的版本号为 `3.3.1`。 **代码如下：** ```java com.zaxxer HikariCP 3.3.1 ``` 3. 添加 `logback-classic` 依赖库，用于方便地进行日志记录和管理： 1. 通过 `` 指定依赖项所属的组织为 `ch.qos.logback`。 2. 通过 `` 指定依赖项的名称为 `logback-classic`。 3. 通过 `` 指定依赖项的版本号为 `1.2.5`。 **代码如下：** ```java ch.qos.logback logback-classic 1.2.5 ``` ### db.properties 代码介绍 `db.properties` 是本文示例的连接池配置文件，其中包含了连接池的配置属性。这些属性包括数据库 URL、用户名、密码、连接池其他可选项。 本文 `db.properties` 文件的代码主要包括以下几个部分： 1. 配置数据库连接参数。 1. 配置数据库连接的 URL，包括主机 IP、端口号、需要访问的数据库。 2. 配置数据库用户名。 3. 配置数据库密码。 **代码如下：** ```java jdbcUrl=jdbc:mysql://$host:$port/$database_name?useSSL=false username=$user_name password=$password ``` **参数解释：** - `$host`：提供 OceanBase 数据库连接 IP。ODP 连接方式使用的是一个 ODP 地址；直连方式使用的是 OBServer 节点的 IP 地址。 - `$port`：提供 OceanBase 数据库连接端口。ODP 连接的方式默认是 `2883`，在部署 ODP 时可自定义；直连方式默认是 `2881`，在部署 OceanBase 数据库时可自定义。 - `$database_name`：需要访问的数据库名称。 - `$user_name`：提供租户的连接账户。ODP 连接的方式格式：`用户名@租户名#集群名` 或者 `集群名:租户名:用户名`；直连方式格式：`用户名@租户名`。 - `$password`：提供账户密码。 2. 配置其他连接池的参数。 1. 启用预编译 SQL 语句的缓存。 2. 设置预编译 SQL 语句的缓存大小为 250。 3. 设置连接的最大生命周期为 1800000 毫秒（30 分钟），超过这个时间连接将被关闭。 4. 设置连接的空闲超时时间为 600000 毫秒（10 分钟），超过这个时间且连接处于空闲状态时，连接将被关闭。 5. 设置连接的超时时间为 30000 毫秒（30 秒），超过这个时间仍未获得连接时，将抛出异常。 **代码如下：** ```java dataSource.cachePrepStmts=true dataSource.prepStmtCacheSize=250 dataSource.maxLifetime=1800000 dataSource.idleTimeout=600000 dataSource.connectionTimeout=30000 ``` #### 注意 具体的属性（参数）配置取决于项目需求和数据库的特点，建议您根据实际情况进行调整和配置。更多 HikariCP 连接池参数的信息，请参见 [Configuration](https://github.com/brettwooldridge/HikariCP#essentials)。 **HikariCP 连接池常用基本参数:** | 分类 | 参数 | 缺省值 | 描述 | | 必选参数 | dataSourceClassName | N/A | 用于指定 JDBC 驱动程序提供的 DataSource 类的名称。 #### 注意 `dataSourceClassName` 通常不需要显式配置，因为 HikariCP 可以自动检测和加载适当的驱动程序。 | | jdbcUrl | N/A | 用于指定 JDBC 连接数据库的 URL。 | | username | N/A | 用于指定连接数据库时使用的用户名。 | | password | N/A | 指定连接数据库时使用的密码。 | | 常用可选参数 | autoCommit | true | 用于控制连接池返回的连接的默认自动提交行为。 | | connectionTimeout | 30000 | 用于控制客户端从连接池获取连接时的最大等待时间。单位为毫秒，默认值是 30000（30 秒）。最低可接受的连接超时时间是 250 毫秒。 | | idleTimeout | 600000 | 用于控制连接在池中空闲的最大时间。单位为毫秒，默认值是 600000（10 分钟）。该设置有如下限制： - 仅在 `minimumIdle` 小于`maximumPoolSize` 时生效。 - 当连接池中的连接达到 `minimumIdle` 数量时，空闲连接不会被回收。只有当连接数超过 `minimumIdle` 时，连接才可能被回收。 | | keepaliveTime | 0 | 用于控制连接保活的频率，以防止连接被数据库或网络基础设施超时。单位为毫秒，默认值是 0，表示禁用连接保活。该值必须小于 `maxLifetime` 属性的值。 | | maxLifetime | 1800000 | 用于控制连接在连接池中的最大生命周期。已经被使用的连接不会被自动回收，只有当连接被关闭时，才会从连接池中移除。单位为毫秒，默认值是 1800000（30 分钟）。如果将 `maxLifetime` 设置为 0，表示连接在连接池中没有最大生命周期的限制，即连接的生命周期是无限的。 | | connectionTestQuery | N/A | 用于执行连接池向数据库发送的连接测试查询。它在从连接池中获取连接之前执行，以验证与数据库的连接是否仍然有效。 | | minimumIdle | N/A | 用于控制连接池中保持的最小空闲连接数量。如果空闲连接数低于这个值，并且连接池中的总连接数少于 `maximumPoolSize`，HikariCP 会尽力快速且高效地添加额外的连接。默认情况下，`minimumIdle` 属性的值与 `maximumPoolSize` 属性相同。 | | maximumPoolSize | 10 | 用于控制连接池允许的最大大小，包括空闲和正在使用的连接。这个值决定了与数据库后端的实际连接数的最大数量。 | | poolName | N/A | 用于表示用户定义的连接池名称。在日志记录和 JMX 管理控制台中，这个名称主要用于识别连接池和连接池配置。默认情况下，它会被自动生成一个名称。 | ### 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 连接池。 **代码如下：** ```java 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. 定义用于创建表、插入数据、查询数据、更新数据和删除数据的方法。 **代码如下：** ```java 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` 列（数据类型为 `INT`）和 `name` 列（数据类型为 `VARCHAR(50)`）。 3. 使用连接对象 `conn` 创建一个预编译的 SQL 语句对象 `pstmt`，并在 `try-with-resources` 块中使用该对象。 4. 执行 SQL 语句，创建名为 `test_hikaricp` 的表。 5. 在控制台输出打印消息，表示表创建成功。 **代码如下：** ```java private static void createTable(Connection conn) throws SQLException { String sql = "CREATE TABLE IF NOT EXISTS test_hikaricp (id INT, name VARCHAR(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. 在控制台输出打印消息，表示数据插入成功。 **代码如下：** ```java 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. 在控制台输出一个空行。 **代码如下：** ```java 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. 在控制台输出打印消息，表示数据更新成功。 **代码如下：** ```java 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. 在控制台输出打印消息，表示数据删除成功。 **代码如下：** ```java 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."); } } ``` ### 完整的代码展示 pom.xml db.properties Main.java ```java 4.0.0 com.oceanbase hikaricp-mysql-client 1.0-SNAPSHOT org.apache.maven.plugins maven-compiler-plugin 8 8 mysql mysql-connector-java 5.1.40 com.zaxxer HikariCP 3.3.1 ch.qos.logback logback-classic 1.2.5 ``` dataSource.cachePrepStmts=true dataSource.prepStmtCacheSize=250 dataSource.maxLifetime=1800000 dataSource.idleTimeout=600000 dataSource.connectionTimeout=30000 ``` 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); private static void createTable(Connection conn) throws SQLException { String sql = "CREATE TABLE IF NOT EXISTS test_hikaricp (id INT, name VARCHAR(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."); } } } ``` ## 相关文档 - 更多 MySQL Connector/J 的信息，请参见 [Overview of MySQL Connector/J](https://dev.mysql.com/doc/connector-j/en/connector-j-overview.html)。 - 更多使用 HikariCP 连接池的信息，请参见 [HikariCP](https://github.com/brettwooldridge/HikariCP#essentials)。 上一篇 下一篇 ![有帮助](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*y6ocSqN8cqsAAAAAAAAAAAAAARQnAQ)![无帮助](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*BG9IQJyLHF8AAAAAAAAAAAAAARQnAQ)![反馈](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*eTWdQKCRKHwAAAAAAAAAAAAAARQnAQ)[AI](https://www.oceanbase.com/obi) 咨询热线