HikariCP接続プールを使用したOceanBase Cloudデータベース接続サンプルプログラム

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

      hikaricp-oceanbase-client サンプルプロジェクトをダウンロード
  </a>
  <!-- <a role='video' href='https://obbusiness-private.oss-cn-shanghai.aliyuncs.com/video-center/video/video/03%20hikaricp-%20oceanbase-client.mp4'>
      
      HikariCP接続プールを使用したOceanBase Cloud接続サンプルプログラム（Oracleモード）
  </a> -->

• OceanBase Cloudデータベースアカウントを登録し、クラスタインスタンスとOceanBase CloudのOracleモードテナントを作成していること。詳細については、クラスタインスタンスの作成およびテナントの作成をご参照ください。

• 対象のOracle互換モードテナントの接続文字列を取得していること。詳細な操作については、接続文字列の取得をご参照ください。

• JDK 1.8とMavenをインストールしていること。

• Eclipseをインストールしていること。

  説明

  このドキュメントでコードを実行するために使用されているツールは、Eclipse IDE for Java Developers 2022-03バージョンです。個人の好みに応じて、適したツールを選択してサンプルコードを実行することもできます。

操作手順

ステップ１：hikaricp-oceanbase-clientプロジェクトをEclipseにインポートする

1. Eclipseを開き、メニューバーからFile > Open Projects from File Systemを選択します。

2. ポップアップダイアログで、Directoryボタンをクリックしてプロジェクトのディレクトリを選択し、Finishをクリックしてインポートを完了します。

   説明

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

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

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

前提条件で取得した接続文字列情報に基づいて、hikaricp-oceanbase-client/src/main/resources/db.properties ファイル内のデータベース接続情報を修正します。

例：

...
jdbcUrl=jdbc:oceanbase://t5******.********.oceanbase.cloud:1521/test_schema001
username=test_user
password=******
...

• 接続アドレスはt5******.********.oceanbase.cloudです。
• アクセスポートは1521を使用します。
• アクセスするデータベース名はtest_schema001です。
• テナントの接続アカウントはtest_userです。
• パスワードは******です。

ステップ３：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. 高パフォーマンスなJDBC接続プールを実現するために、HikariCP 依存ライブラリを追加します：

      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アドレス、ポート番号、アクセスするスキーマが含まれます。
   2. データベースのユーザー名を設定します。
   3. データベースのパスワードを設定します。

   コード：

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

   パラメータの説明：

   • $host：接続文字列から -h パラメータを取得したもので、OceanBase Cloudデータベースの接続アドレスです。
   • $port：接続文字列から -P パラメータを取得したもので、OceanBase Cloudデータベースの接続ポートです。
   • $schema_name：接続文字列から -D パラメータを取得したもので、アクセスするデータベース名です。
   • $user_name：接続文字列から -u パラメータを取得したもので、アカウント名です。
   • $password：接続文字列から -p パラメータを取得したもので、アカウントのパスワードです。

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をご参照ください。