HikariCP コネクションプールを使用して OceanBase データベースに接続するサンプルプログラム

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

      hikaricp-mysql-client サンプルプロジェクトをクリックしてダウンロード
  </a>
  <!-- <a role='video' href='https://obbusiness-private.oss-cn-shanghai.aliyuncs.com/video-center/video/video/03%20hikaricp-mysql-client.mp4'>
      
      HikariCP コネクションプールを使用して OceanBase データベースに接続するサンプルプログラム（MySQLモード）
  </a> -->

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

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

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

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

  説明

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

操作手順

<main id="notice" type='explain'>
  <h4>説明</h4>
  <p>本ドキュメントに記載されている操作手順は、Windows 環境で Eclipse IDE for Java Developers 2022-03 を使用してプロジェクトをコンパイルおよび実行する手順です。他のオペレーティングシステム環境やコンパイラを使用している場合、操作手順が若干異なる場合があります。</p>
</main>

操作手順 1：hikaricp-mysql-client プロジェクトを Eclipse にインポートする

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

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

   説明

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

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

操作手順 2：hikaricp-mysql-client プロジェクトのデータベース接続情報を変更する

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

例は以下のとおりです。

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

コードは以下のとおりです。

...
jdbcUrl=jdbc:mysql://t5******.********.oceanbase.cloud:3306/test?useSSL=false
username=test_user001
password=******
...

操作手順 3：hikaricp-mysql-client プロジェクトを実行する

1. プロジェクトナビゲータービューで、src/main/java ディレクトリを見つけて展開します。

2. Main.java ファイルを右クリックし、Run As -> Java Application を選択します。

3. Eclipse のコンソールウィンドウで、プロジェクトのログ情報と出力結果を確認します。

4. OceanBase クライアント（OBClient）で以下の SQL 文を実行して結果を確認することもできます。

   obclient [(none)]> SELECT * FROM test.test_hikaricp;
   

   返される結果は以下のとおりです。

   +------+-------------+
   | id   | name        |
   +------+-------------+
   |    1 | test_update |
   +------+-------------+
   1 row in set
   

プロジェクトコードの紹介

hikaricp-mysql-client をクリックしてプロジェクトコードをダウンロードします。これは hikaricp-mysql-client.zip という名前の圧縮パッケージです。

解凍すると、hikaricp-mysql-client という名前のフォルダが作成されます。ディレクトリ構造は以下のとおりです。

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 であることを宣言します。

   コードは以下のとおりです。

   <?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ファイルの場所を に、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-mysql-client に指定します。
   3. <version> を使用して、プロジェクトのバージョン番号を 1.0-SNAPSHOT に指定します。

   コードは以下のとおりです。

       <groupId>com.example</groupId>
       <artifactId>hikaricp-mysql-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. データベースと対話するために、mysql-connector-java 依存ライブラリを追加します。

      1. <groupId> を使用して、依存関係が属する組織を mysql に指定します。
      2. <artifactId> を使用して、依存関係の名前を mysql-connector-java に指定します。
      3. <version> を使用して、依存関係のバージョン番号を 5.1.40 に指定します。

      コードは以下のとおりです。

              <dependency>
                  <groupId>mysql</groupId>
                  <artifactId>mysql-connector-java</artifactId>
                  <version>5.1.40</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. ホスト IP、ポート番号、アクセスするデータベースを含む、データベース接続の URL を設定します。
   2. データベースのユーザー名を設定します。
   3. データベースのパスワードを設定します。

   コードは以下のとおりです。

   jdbcUrl=jdbc:mysql://$host:$port/$database_name?useSSL=false
   username=$user_name
   password=$password
   

   パラメータの説明：

   • $host：接続文字列の -h パラメータから取得した、OceanBase Cloud クラウドデータベースの接続アドレス。
   • $port：接続文字列の -P パラメータから取得した、OceanBase Cloud クラウドデータベースの接続ポート。
   • $database_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. プリコンパイルされた SQL 文を実行するために、java.sql.PreparedStatement クラスをインポートします。
   4. クエリ結果セットを処理するために、java.sql.ResultSet クラスをインポートします。
   5. SQL 例外を処理するために、java.sql.SQLException クラスをインポートします。
   6. HikariCP コネクションプールを設定するために、HikariCP の HikariConfig クラスをインポートします。
   7. HikariCP コネクションプールを作成および管理するために、HikariCP の HikariDataSource クラスをインポートします。

   コードは以下のとおりです。

   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') の 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. テーブルを作成するメソッドを定義します。

   データベース内に test_hikaricp という名前のテーブルを作成するためのプライベート静的メソッド createTable を定義します。このテーブルには id 列と name 列が含まれます。具体的な手順は以下のとおりです。

   1. Connection オブジェクトをパラメータとして受け取り、SQLException 例外をスローする可能性があることを宣言するプライベート静的メソッド createTable を定義します。
   2. test_hikaricp という名前のテーブルを作成するための SQL 文の文字列を定義します。テーブルには id 列（データ型は INT）と name 列（データ型は VARCHAR(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 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. データを挿入するメソッドを定義します。

   データベース内のテーブル test_hikaricp にデータを挿入するためのプライベート静的メソッド insertData を定義します。具体的な手順は以下のとおりです。

   1. Connection オブジェクト、整数型の id パラメータ、および文字列型の name パラメータを受け取り、SQLException 例外をスローする可能性があることを宣言するプライベート静的メソッド insertData を定義します。
   2. test_hikaricp という名前のテーブルにデータを挿入するための SQL 文の文字列を定義します。データには id 列と name 列が含まれます。
   3. 接続オブジェクト conn を使用してプリコンパイルされた SQL 文オブジェクト pstmt を作成し、try-with-resources ブロック内でそのオブジェクトを使用します。
   4. SQL 文の 1 番目のパラメータ ? の値を 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. データをクエリするメソッドを定義します。

   データベースからテーブル test_hikaricp のデータをクエリするためのプライベート静的メソッド selectData を定義します。具体的な手順は以下のとおりです。

   1. Connection オブジェクトをパラメータとして受け取り、SQLException 例外をスローする可能性があることを宣言するプライベート静的メソッド selectData を定義します。
   2. test_hikaricp という名前のテーブル内のすべてのデータをクエリするための SQL 文の文字列を定義します。
   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. データを更新するメソッドを定義します。

   データベース内のテーブル test_hikaricp のデータを更新するためのプライベート静的メソッド updateData を定義します。具体的な手順は以下のとおりです。

   1. Connection オブジェクト、文字列型の name パラメータ、および整数型の id パラメータを受け取り、SQLException 例外をスローする可能性があることを宣言するプライベート静的メソッド updateData を定義します。
   2. test_hikaricp という名前のテーブル内のデータを更新するための SQL 文の文字列を定義します。id 列の値が指定された id と等しいという条件で、name 列の値を指定された name に更新します。
   3. 接続オブジェクト conn を使用してプリコンパイルされた SQL 文オブジェクト pstmt を作成し、try-with-resources ブロック内でそのオブジェクトを使用します。
   4. SQL 文の 1 番目のパラメータ ? の値を 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. データを削除するメソッドを定義します。

   データベースからテーブル test_hikaricp の条件を満たすデータを削除するためのプライベート静的メソッド deleteData を定義します。具体的な手順は以下のとおりです。

   1. Connection オブジェクトと整数型の id パラメータを受け取り、SQLException 例外をスローする可能性があることを宣言するプライベート静的メソッド deleteData を定義します。
   2. test_hikaricp という名前のテーブルから id = ? の条件を満たすデータを削除するための SQL 文の文字列を定義します。
   3. 接続オブジェクト conn を使用してプリコンパイルされた SQL 文オブジェクト pstmt を作成し、try-with-resources ブロック内でそのオブジェクトを使用します。
   4. SQL 文の 1 番目のパラメータ ? の値を 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.");
           }
           }
   

完全なコードの表示

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

<groupId>com.oceanbase</groupId>
<artifactId>hikaricp-mysql-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>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>5.1.40</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>

```java
jdbcUrl=jdbc:mysql://$host:$port/$database_name?useSSL=false
username=$user_name
password=$password

```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;

            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 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 の詳細については、MySQL Connector/Jの概要 をご参照ください。
• HikariCP コネクションプールの使用に関する詳細については、HikariCP をご参照ください。