HikariCP接続プールでOceanBaseデータベースに接続するサンプルプログラム

本記事では、HikariCP接続プール、OceanBase Connector/J、およびOceanBaseデータベースを使用してアプリケーションを構築し、テーブルの作成、データの挿入、削除、更新、クエリなどの基本的なデータベース操作を実装する方法について説明します。

hikaricp-oceanbase-client サンプルプロジェクトをダウンロード

前提条件

• 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プロジェクトをインポートすると、プロジェクト内のpom.xmlファイルを自動的に検出し、その記述に基づいて必要な依存ライブラリをダウンロードしてプロジェクトに追加します。

   

3. プロジェクトの状況を確認します。

   

ステップ2：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=******
   

ステップ3：hikaricp-oceanbase-clientプロジェクトのデータベース接続情報を修正する

ステップ2：OceanBaseデータベースのURLを取得するで取得した情報に基づいて、hikaricp-oceanbase-client/src/main/resources/db.properties ファイル内のデータベース接続情報を修正します。

例：

• OBServerノードのIPアドレスは xxx.xxx.xxx.xxx です。
• アクセスポートは2881を使用します。
• アクセスするスキーマ名は 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=******
...

ステップ4：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 依存ライブラリを追加します：

   2. <groupId> を使用して、依存関係が属する組織を com.oceanbase と指定します。

   3. <artifactId> を使用して、依存関係の名前を oceanbase-client と指定します。

   4. <version> を使用して、依存関係のバージョン番号を 2.4.2 と指定します。

   <main id="notice" type='explain'>
     <h4>説明</h4>
     <p>このセクションのコードは、プロジェクトが依存するコンポーネントがOceanBase Connector/JのV2.4.2バージョンであることを定義しています。他のバージョンの情報については、<a href="https://en.oceanbase.com/docs/oceanbase-connector-j-en">OceanBase JDBCドライバ</a>を参照してください。</p>
   </main>
   
   **コード：**
   
   ```java
           <dependency>
               <groupId>com.oceanbase</groupId>
               <artifactId>oceanbase-client</artifactId>
               <version>2.4.2</version>
           </dependency>
   ```
   

   2. 高性能なJDBC接続プールを実現するために、HikariCP 依存ライブラリを追加します：

   3. <groupId> を使用して、依存関係が属する組織を com.zaxxer と指定します。

   4. <artifactId> を使用して、依存関係の名前を HikariCP と指定します。

   5. <version> を使用して、依存関係のバージョン番号を 3.3.1 と指定します。

   **コード：**
   
   ```java
           <dependency>
               <groupId>com.zaxxer</groupId>
               <artifactId>HikariCP</artifactId>
               <version>3.3.1</version>
           </dependency>
   ```
   

   3. ログの記録と管理を容易に行うために、logback-classic 依存ライブラリを追加します：

   4. <groupId> を使用して、依存関係が属する組織を ch.qos.logback と指定します。

   5. <artifactId> を使用して、依存関係の名前を logback-classic と指定します。

   6. <version> を使用して、依存関係のバージョン番号を 1.2.5 と指定します。

   **コード：**
   
   ```java
           <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アドレス、ポート番号、アクセスするスキーマが含まれます。
   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：アクセスするスキーマ名です。
   • $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という名前のpublicクラスを定義します。
   2. Mainクラスのエントリポイントメソッド main を定義します。
   3. HikariConfigオブジェクトを作成し、指定された db.properties ファイルを使用して設定します。
   4. HikariDataSourceオブジェクトを作成し、try-with-resources ブロック内でデータベース接続を取得します。
   5. テーブルを作成するためのメソッドを呼び出し、取得したデータベース接続オブジェクトを渡して、test_hikaricp テーブルを作成します。
   6. データを挿入するためのメソッドを呼び出し、取得したデータベース接続オブジェクトとデータパラメータを渡して、(1,'A1') と (2,'A2') の2行のデータを挿入します。
   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ステートメントの2番目のパラメータ ? の値を 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ステートメントの2番目のパラメータ ? の値を 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を参照してください。