Commons Pool を使用して OceanBase データベースに接続するサンプルプログラム|OceanBase Cloud|ドキュメント|OceanBaseマニュアル

Commons Pool を使用して OceanBase データベースに接続するサンプルプログラム

最終更新日：2026-09-07 03:33:28 更新

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

      commonpool-mysql-client サンプルプロジェクトをダウンロード
  </a>
  <!-- <a role='video' href='https://obbusiness-private.oss-cn-shanghai.aliyuncs.com/video-center/video/video/05%20commonpool-mysql-client.mp4'>

      Commons Pool を使用して 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：commonpool-mysql-client プロジェクトを Eclipse にインポートする

Eclipse を開き、メニューバーから File -> Open Projects from File System を選択します。
ポップアップダイアログで、Directory ボタンをクリックしてプロジェクトのディレクトリを選択し、Finish をクリックしてインポートを完了します。

説明

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

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

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

例は以下の通りです：

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

コードは以下の通りです：

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

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

プロジェクトナビゲータービューで、src/main/java ディレクトリを見つけて展開します。
Main.java ファイルを右クリックし、Run As -> Java Application を選択します。
Eclipse のコンソールウィンドウで出力結果を確認します。

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

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

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

commonpool-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 ファイルのコードは、主に以下の部分で構成されています：

ファイル宣言文。

このファイルが XML ファイルであることを宣言し、使用する XML バージョンは 1.0、文字エンコーディングは UTF-8 です。

コードは以下の通りです：

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

POM の名前空間と POM モデルバージョンを設定します。
xmlns を使用して、POM の名前空間を http://maven.apache.org/POM/4.0.0 に指定します。
xmlns:xsi を使用して、XML 名前空間 http://www.w3.org/2001/XMLSchema-instance を指定します。
xsi:schemaLocation を使用して、POM の名前空間を http://maven.apache.org/POM/4.0.0 に、POM の XSD ファイルの場所を http://maven.apache.org/xsd/maven-4.0.0.xsd に指定します。
<modelVersion> 要素を使用して、この POM ファイルで使用される POM モデルバージョンを 4.0.0 に指定します。

コードは以下の通りです：

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

基本情報を設定します。
<groupId> を使用して、プロジェクトが属する組織を com.example に指定します。
<artifactId> を使用して、プロジェクト名を commonpool-mysql-client に指定します。
<version> を使用して、プロジェクトのバージョン番号を 1.0-SNAPSHOT に指定します。

コードは以下の通りです：

```java
    <groupId>com.example</groupId>
    <artifactId>commonpool-mysql-client</artifactId>
    <version>1.0-SNAPSHOT</version>
```

プロジェクトのソースファイルのプロパティを設定します。

Maven のコンパイラプラグインを maven-compiler-plugin に指定し、ソースコードとターゲットの Java バージョンを両方とも 8 に設定します。これは、プロジェクトのソースコードが Java 8 の機能を使用して記述され、コンパイルされたバイトコードも Java 8 ランタイム環境と互換性を持つことを意味します。この設定により、プロジェクトのコンパイル時および実行時に Java 8 の構文と機能を正しく処理できるようになります。

<main id="notice" type='explain'>
<h4>説明</h4>
<p>Java 1.8 と Java 8 は、同じバージョンの異なる命名方法です。</p>
</main>

コードは以下の通りです：

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

プロジェクトが依存するコンポーネントを設定します。
データベースと対話するために、mysql-connector-java 依存ライブラリを追加します：
<groupId> を使用して、依存関係が属する組織を mysql に指定します。
<artifactId> を使用して、依存関係の名前を mysql-connector-java に指定します。
<version> を使用して、依存関係のバージョン番号を 5.1.40 に指定します。

コードは以下の通りです：

    ```java
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>5.1.40</version>
            </dependency>
    ```

プロジェクト内でそのライブラリの機能とクラスを使用できるように、commons-pool2 依存ライブラリを追加します：
<groupId> を使用して、依存関係が属する組織を org.apache.commons に指定します。
<artifactId> を使用して、依存関係の名前を commons-pool2 に指定します。
<version> を使用して、依存関係のバージョン番号を 2.7.0 に指定します。

コードは以下の通りです：

    ```java
            <dependency>
                <groupId>org.apache.commons</groupId>
                <artifactId>commons-pool2</artifactId>
                <version>2.7.0</version>
            </dependency>
    ```

db.properties コードの紹介

db.properties は、本サンプルの接続プールの設定ファイルであり、接続プールの設定プロパティが含まれています。これらのプロパティには、データベース URL、ユーザー名、パスワード、接続プールのその他のオプションが含まれます。

本文の db.properties ファイルのコードは、主に以下の部分で構成されています：

データベース接続パラメータを設定します。
ホスト IP、ポート番号、アクセスするデータベースを含む、データベース接続の URL を設定します。
データベースのユーザー名を設定します。
データベースのパスワードを設定します。

コードは以下の通りです：

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

パラメータの説明：

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

その他の接続プールのパラメータを設定します。
接続プールの最大接続数を 10 に設定します。これは、接続プールに同時に最大 10 個の接続を保持できることを意味します。
接続プールの最大アイドル接続数を 5 に設定します。接続プール内の接続数が最大アイドル接続数を超えると、余分な接続は閉じられます。
接続プールの最小アイドル接続数を 2 に設定します。接続プールに使用中の接続がない場合でも、少なくとも 2 個のアイドル接続が保持されます。
接続プールから接続を取得する際の最大待機時間を 5000 ミリ秒に設定します。接続プールに利用可能な接続がない場合、接続の取得操作は最大待機時間を超えるまで待機します。

コードは以下の通りです：

```java
pool.maxTotal=10
pool.maxIdle=5
pool.minIdle=2
pool.maxWaitMillis=5000
```

注意

具体的なプロパティ（パラメータ）の設定は、プロジェクトの要件やデータベースの特性に依存するため、実際の状況に応じて調整および設定することをお勧めします。

Commons Pool 2 の一般的な設定パラメータ：

パラメータ	説明
url	データベースの種類、ホスト名、ポート番号、データベース名などの情報を含む、データベースに接続するための URL アドレスを指定します。
username	データベースへの接続に必要なユーザー名。
password	データベースへの接続に必要なパスワード。
maxTotal	オブジェクトプール内で作成を許可する最大オブジェクト数を指定します。
maxIdle	オブジェクトプール内で保持を許可する最大アイドルオブジェクト数を指定します。
minIdle	オブジェクトプール内で保持する最小アイドルオブジェクト数を指定します。
blockWhenExhausted	オブジェクトプールが枯渇した際の `borrowObject` 操作の動作を指定します。 `true`：利用可能なオブジェクトができるまで、`borrowObject` メソッドはブロックされます。 `false`：`borrowObject` メソッドは直ちに `NoSuchElementException` 例外をスローします。
maxWaitMillis	プールが枯渇した際の `borrowObject` メソッドの最大待機時間（ミリ秒）を指定します。
testOnBorrow	`borrowObject` メソッドの呼び出し時にオブジェクトを検証するかどうかを指定します。 `true`：`borrowObject` メソッドが呼び出されるたびに、オブジェクトの `validateObject` メソッドを呼び出して検証を行います。 `false`：検証を行いません。
testOnReturn	`returnObject` メソッドの呼び出し時にオブジェクトを検証するかどうかを指定します。 `true`：`returnObject` メソッドが呼び出されるたびに、オブジェクトの `validateObject` メソッドを呼び出して検証を行います。 `false`：検証を行いません。
testWhileIdle	オブジェクトがアイドル状態のときに検証を行うかどうかを指定します。具体的な意味は以下の通りです： `true` に設定した場合、オブジェクトプール内のアイドルオブジェクトが貸し出される前に、定期的に `validateObject` メソッドを呼び出して検証を行います。この検証操作により、アイドルオブジェクトが引き続き有効で利用可能であることを確認できます。 `false` に設定した場合、アイドルオブジェクトの検証を行いません。つまり、`validateObject` メソッドは呼び出されません。
timeBetweenEvictionRunsMillis	アイドルオブジェクトの退避スレッドをスケジュールする時間間隔（ミリ秒）を指定します。
numTestsPerEvictionRun	退避スレッドがスケジュールされるたびにチェックするアイドルオブジェクトの数を指定します。

Main.java コードの紹介

Main.java ファイルはサンプルプログラムの一部であり、コードは Commons Pool 2 を使用してデータベース操作を実行する方法を示しています。本文の Main.java ファイルのコードは、主に以下の部分で構成されています：

パッケージを定義し、必要なクラスをインポートします。
現在のコードが属するパッケージ名を com.example として宣言します。
入出力例外を処理するために、java.io.IOException クラスをインポートします。
データベースとの接続を表すために、java.sql.Connection クラスをインポートします。このオブジェクトを使用して SQL 文を実行し、結果を取得できます。
ドライバのロードとデータベース接続の確立を管理するために、java.sql.DriverManager クラスをインポートします。このクラスを使用してデータベース接続を取得できます。
SQL クエリの結果セットを表すために、java.sql.ResultSet クラスをインポートします。このオブジェクトを使用してクエリ結果を反復処理および操作できます。
SQL 文に関連する例外状況を処理するために、java.sql.SQLException クラスをインポートします。
SQL 文を実行するオブジェクトとして、java.sql.Statement クラスをインポートします。Connection オブジェクトの createStatement メソッドを使用して作成できます。
設定情報をロードおよび保存するためのキーと値のペアのコレクションとして、java.util.Properties クラスをインポートします。設定ファイルからデータベースの接続情報をロードできます。
オブジェクトの取得や返却など、プールされたオブジェクトの基本操作を定義するオブジェクトプールインターフェースとして、org.apache.commons.pool2.ObjectPool クラスをインポートします。
オブジェクトプールを便利に操作するためのユーティリティメソッドを提供する org.apache.commons.pool2.PoolUtils クラスをインポートします。
オブジェクトプール管理を実装したラッパーオブジェクトとして、org.apache.commons.pool2.PooledObject クラスをインポートします。このインターフェースを実装することで、プールされたオブジェクトのライフサイクルを管理できます。
接続プールの基本機能を実装した ObjectPool インターフェースのデフォルト実装クラスとして、org.apache.commons.pool2.impl.GenericObjectPool クラスをインポートします。
接続プールのプロパティを設定するための GenericObjectPool の設定クラスとして、org.apache.commons.pool2.impl.GenericObjectPoolConfig クラスをインポートします。
プールされたオブジェクトのラッパーを管理するための PooledObject インターフェースのデフォルト実装クラスとして、org.apache.commons.pool2.impl.DefaultPooledObject クラスをインポートします。これには、実際の接続オブジェクトやその他の管理情報を含めることができます。

コードは以下の通りです：

```java
package com.example;

import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

import org.apache.commons.pool2.ObjectPool;
import org.apache.commons.pool2.PoolUtils;
import org.apache.commons.pool2.PooledObject;
import org.apache.commons.pool2.impl.GenericObjectPool;
import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
import org.apache.commons.pool2.impl.DefaultPooledObject;
```

Main クラスを作成し、main メソッドを定義します。

Main クラスと main メソッドを定義します。main メソッドは、接続プールを使用してデータベースから一連の操作を実行する方法を示すために使用されます。具体的な手順は以下の通りです：

プログラムのエントリポイントとして、Main という名前のパブリッククラスを定義します。クラス名はファイル名と一致している必要があります。
プログラムの実行開始点として、パブリックな静的メソッド main を定義します。
データベース設定ファイルをロードします：
データベース設定情報を格納するための Properties オブジェクトを作成します。
Main クラスのクラスローダーを介して db.properties リソースファイルの入力ストリームを取得し、Properties オブジェクトの load() メソッドを使用してその入力ストリームをロードし、プロパティファイル内のキーと値のペアを props オブジェクトにロードします。
スローされる可能性のある IOException 例外をキャッチし、例外のスタックトレース情報を出力します。
データベース接続プールの設定を作成します：
接続プールの動作を設定するためのジェネリックオブジェクトプール設定オブジェクトを作成します。
接続プールで許可される最大接続数を設定します。
接続プールで許可される最大アイドル接続数を設定します。
接続プールで許可される最小アイドル接続数を設定します。
接続を取得する際の最大待機時間を設定します。
データベース接続プールを作成します：スレッドセーフな接続プールオブジェクト connectionPool を作成し、ConnectionFactory オブジェクトと poolConfig 設定オブジェクトを使用してジェネリックオブジェクトプールを作成し、それをスレッドセーフなオブジェクトプールにラップします。接続プールをスレッドセーフにラップすることで、マルチスレッド環境での接続の取得および解放操作の安全性を確保できます。
データベース接続を取得します。接続プールの borrowObject() メソッドを使用してデータベース接続を取得し、try コードブロック内でその接続を使用してデータベース操作を行います。
```
     1. `createTable()` メソッドを呼び出して、テーブルを作成します。
```
insertData() メソッドを呼び出して、データを挿入します。
selectData() メソッドを呼び出して、データをクエリします。
updateData() メソッドを呼び出して、データを更新します。
再度 selectData() メソッドを呼び出して、更新後のデータをクエリします。
deleteData() メソッドを呼び出して、データを削除します。
再度 selectData() メソッドを呼び出して、削除後のデータをクエリします。
dropTable() メソッドを呼び出して、テーブルを削除します。
任意の例外をキャッチして出力します。
その他のデータベース操作メソッドを定義します。

コードは以下の通りです：

```java
public class Main {

    public static void main(String[] args) {
        // Load the database configuration file
        Properties props = new Properties();
        try {
            props.load(Main.class.getClassLoader().getResourceAsStream("db.properties"));
        } catch (IOException e) {
            e.printStackTrace();
        }

        // Create the database connection pool configuration
        GenericObjectPoolConfig<Connection> poolConfig = new GenericObjectPoolConfig<>();
        poolConfig.setMaxTotal(Integer.parseInt(props.getProperty("pool.maxTotal")));
        poolConfig.setMaxIdle(Integer.parseInt(props.getProperty("pool.maxIdle")));
        poolConfig.setMinIdle(Integer.parseInt(props.getProperty("pool.minIdle")));
        poolConfig.setMaxWaitMillis(Long.parseLong(props.getProperty("pool.maxWaitMillis")));

        // Create the database connection pool
        ObjectPool<Connection> connectionPool = PoolUtils.synchronizedPool(new GenericObjectPool<>(new ConnectionFactory(
                props.getProperty("db.url"), props.getProperty("db.username"), props.getProperty("db.password")), poolConfig));

        // Get a database connection
        try (Connection connection = connectionPool.borrowObject()) {
        
            // Create table
            createTable(connection);

            // Insert data
            insertData(connection);
            // Query data
            selectData(connection);

            // Update data
            updateData(connection);
            // Query the updated data
            selectData(connection);

        // Delete data
            deleteData(connection);
        // Query the data after deletion

            selectData(connection);

// Drop table dropTable(connection); } catch (Exception e) { e.printStackTrace(); } }

    // テーブルを作成するためのメソッドを定義します
    // データを挿入するためのメソッドを定義します
    // データを更新するためのメソッドを定義します
    // データを削除するためのメソッドを定義します
    // データをクエリするためのメソッドを定義します
    // テーブルを削除するためのメソッドを定義します
    // ConnectionFactory クラスを定義します
        }
```

テーブルを作成するためのメソッドを定義します。

createTable という名前のメソッドを定義し、Connection オブジェクトをパラメータとして受け取ります。具体的な手順は以下の通りです：

プライベートな静的メソッド createTable() を定義し、Connection オブジェクトをパラメータとして受け取り、SQLException 例外をスローする可能性があることを宣言します。
接続の createStatement() メソッドを使用して Statement オブジェクトを作成し、try-with-resources 文内でそのオブジェクトを使用してデータベース操作を実行します。
テーブルを作成する SQL 文を格納する文字列変数 sql を定義します。
Statement オブジェクトの executeUpdate() メソッドを使用して sql 文を実行し、テーブルを作成します。
コンソールにテーブル作成成功のメッセージを出力します。

コードは以下の通りです：

```java
    private static void createTable(Connection connection) throws SQLException {
        try (Statement statement = connection.createStatement()) {
            String sql = "CREATE TABLE test_commonpool (id INT,name VARCHAR(20))";
            statement.executeUpdate(sql);
            System.out.println("Table created successfully.");
        }
        }
```

データを挿入するためのメソッドを定義します。

insertData() という名前のメソッドを定義し、Connection オブジェクトをパラメータとして受け取ります。具体的な手順は以下の通りです：

プライベートな静的メソッド insertData() を定義し、Connection オブジェクトをパラメータとして受け取り、SQLException 例外をスローする可能性があることを宣言します。
接続の createStatement() メソッドを使用して Statement オブジェクトを作成し、try-with-resources 文内でそのオブジェクトを使用してデータベース操作を実行します。
データを挿入する SQL 文を格納する文字列変数 sql を定義します。
Statement オブジェクトの executeUpdate() メソッドを使用して sql 文を実行し、データを挿入します。
コンソールにデータ挿入成功のメッセージを出力します。

コードは以下の通りです：

```java
    private static void insertData(Connection connection) throws SQLException {
        try (Statement statement = connection.createStatement()) {
            String sql = "INSERT INTO test_commonpool (id, name) VALUES (1,'A1'), (2,'A2'), (3,'A3')";
            statement.executeUpdate(sql);
            System.out.println("Data inserted successfully.");
        }
        }
```

データを更新するためのメソッドを定義します。

updateData() という名前のメソッドを定義し、Connection オブジェクトをパラメータとして受け取ります。具体的な手順は以下の通りです：

プライベートな静的メソッド updateData() を定義し、Connection オブジェクトをパラメータとして受け取り、SQLException 例外をスローする可能性があることを宣言します。
接続の createStatement() メソッドを使用して Statement オブジェクトを作成し、try-with-resources 文内でそのオブジェクトを使用してデータベース操作を実行します。
データを更新する SQL 文を格納する文字列変数 sql を定義します。
Statement オブジェクトの executeUpdate() メソッドを使用して sql 文を実行し、データを更新します。
コンソールにデータ更新成功のメッセージを出力します。

コードは以下の通りです：

```java
    private static void updateData(Connection connection) throws SQLException {
        try (Statement statement = connection.createStatement()) {
            String sql = "UPDATE test_commonpool SET name = 'A11' WHERE id = 1";
            statement.executeUpdate(sql);
            System.out.println("Data updated successfully.");
        }
        }
```

データを削除するためのメソッドを定義します。

deleteData() という名前のメソッドを定義し、Connection オブジェクトをパラメータとして受け取ります。具体的な手順は以下の通りです：

プライベートな静的メソッド deleteData() を定義し、Connection オブジェクトをパラメータとして受け取り、SQLException 例外をスローする可能性があることを宣言します。
接続の createStatement() メソッドを使用して Statement オブジェクトを作成し、try-with-resources 文内でそのオブジェクトを使用してデータベース操作を実行します。
データを削除する SQL 文を格納する文字列変数 sql を定義します。
Statement オブジェクトの executeUpdate() メソッドを使用して sql 文を実行し、データを削除します。
コンソールにデータ削除成功のメッセージを出力します。

コードは以下の通りです：

```java
    private static void deleteData(Connection connection) throws SQLException {
        try (Statement statement = connection.createStatement()) {
            String sql = "DELETE FROM test_commonpool WHERE id = 2";
            statement.executeUpdate(sql);
            System.out.println("Data deleted successfully.");
        }
        }
```

データをクエリするためのメソッドを定義します。

selectData() という名前のメソッドを定義し、Connection オブジェクトをパラメータとして受け取ります。具体的な手順は以下の通りです：

プライベートな静的メソッド selectData() を定義し、Connection オブジェクトをパラメータとして受け取り、SQLException 例外をスローする可能性があることを宣言します。
接続の createStatement() メソッドを使用して Statement オブジェクトを作成し、try-with-resources 文内でそのオブジェクトを使用してデータベース操作を実行します。
データをクエリする SQL 文を格納する文字列変数 sql を定義します。
Statement オブジェクトの executeQuery() メソッドを使用して sql 文を実行し、結果を ResultSet オブジェクトに格納します。
resultSet.next() メソッドを使用して次の行のデータがあるかどうかを判断し、ループに入ります。
resultSet.getInt() メソッドを使用して現在の行の整数データを取得します。このメソッドのパラメータはデータの列名です。
resultSet.getString() メソッドを使用して現在の行の文字列データを取得します。このメソッドのパラメータはデータの列名です。
コンソールに現在の行のデータを出力します。

コードは以下の通りです：

```java
    private static void selectData(Connection connection) throws SQLException {
        try (Statement statement = connection.createStatement()) {
            String sql = "SELECT * FROM test_commonpool";
            ResultSet resultSet = statement.executeQuery(sql);
            while (resultSet.next()) {
                int id = resultSet.getInt("id");
                String name = resultSet.getString("name");
                System.out.println("id: " + id + ", name: " + name);
            }
            }
            }
```

テーブルを削除するためのメソッドを定義します。

dropTable() という名前のメソッドを定義し、Connection オブジェクトをパラメータとして受け取ります。具体的な手順は以下の通りです：

プライベートな静的メソッド dropTable() を定義し、Connection オブジェクトをパラメータとして受け取り、SQLException 例外をスローする可能性があることを宣言します。
接続の createStatement() メソッドを使用して Statement オブジェクトを作成し、try-with-resources 文内でそのオブジェクトを使用してデータベース操作を実行します。
テーブルを削除する SQL 文を格納する文字列変数 sql を定義します。
Statement オブジェクトの executeUpdate() メソッドを使用して sql 文を実行し、テーブルを削除します。
コンソールにテーブル削除成功のメッセージを出力します。

コードは以下の通りです：

```java
    private static void dropTable(Connection connection) throws SQLException {
        try (Statement statement = connection.createStatement()) {
            String sql = "DROP TABLE test_commonpool";
            statement.executeUpdate(sql);
            System.out.println("Table dropped successfully.");
        }
        }
```

ConnectionFactory クラスを定義します。

BasePooledObjectFactory クラスを継承し、接続オブジェクトの作成と管理メソッドを実装した、ConnectionFactory という名前の静的内部クラスを定義します。具体的な手順は以下の通りです：

<main id="notice" type='explain'>
<h4>説明</h4>
<p><code>@Override</code> は、以下のメソッドが親クラスのメソッドをオーバーライドしていることを示すアノテーションです。</p>
</main>

接続オブジェクトを作成および管理するためのファクトリクラスとして、org.apache.commons.pool2.BasePooledObjectFactory<Connection> クラスを継承した ConnectionFactory という名前の静的内部クラスを定義します。
データベースの URL を格納する、プライベートで不変の文字列変数を定義します。
データベースに接続するためのユーザー名を格納する、プライベートで不変の文字列変数を定義します。
データベースに接続するためのパスワードを格納する、プライベートで不変の文字列変数を定義します。
クラスのメンバ変数 url、username、および password を初期化するための ConnectionFactory クラスのコンストラクタを定義します。コンストラクタは、データベースの URL、データベースに接続するためのユーザー名、およびパスワードの 3 つのパラメータを受け取り、これらのパラメータの値を対応するメンバ変数にそれぞれ割り当てます。これにより、ConnectionFactory オブジェクトを作成する際に、コンストラクタを介してデータベース関連の情報を渡すことができます。
新しい接続オブジェクトを作成するために、BasePooledObjectFactory クラスの create() メソッドをオーバーライドします。
DriverManager クラスの getConnection() メソッドを使用して接続オブジェクトを作成し、返します。
接続オブジェクトを破棄するために、BasePooledObjectFactory クラスの destroyObject() メソッドをオーバーライドします。
接続オブジェクトの close() メソッドを呼び出して接続を閉じます。
接続オブジェクトの有効性を検証するために、BasePooledObjectFactory クラスの validateObject() メソッドをオーバーライドします。
接続オブジェクトの isValid() メソッドを呼び出して接続が有効かどうかを確認し、タイムアウト時間を 5000 ミリ秒に設定します。
接続オブジェクトを PooledObject オブジェクトにラップするために、BasePooledObjectFactory クラスの wrap() メソッドをオーバーライドします。
DefaultPooledObject クラスのコンストラクタを使用して PooledObject オブジェクトを作成し、接続オブジェクトをパラメータとして渡します。

コードは以下の通りです：

```java
static class ConnectionFactory extends org.apache.commons.pool2.BasePooledObjectFactory<Connection> {
        private final String url;
        private final String username;
        private final String password;

        public ConnectionFactory(String url, String username, String password) {
            this.url = url;
            this.username = username;
            this.password = password;
        }

        @Override
        public Connection create() throws Exception {
            return DriverManager.getConnection(url, username, password);
        }

        @Override
        public void destroyObject(org.apache.commons.pool2.PooledObject<Connection> p) throws Exception {
            p.getObject().close();
            }

        @Override
        public boolean validateObject(org.apache.commons.pool2.PooledObject<Connection> p) {
            try {
                return p.getObject().isValid(5000);
            } catch (SQLException e) {
                return false;
        }
        }

        @Override
        public PooledObject<Connection> wrap(Connection connection) {
            return new DefaultPooledObject<>(connection);
        }
        }
```

完全なコードの表示

pom.xml

db.properties

Main.java

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

4.0.0

com.example commonpool-mysql-client 1.0-SNAPSHOT org.apache.maven.plugins maven-compiler-plugin

8 8

<dependencies>
    <dependency>

mysql mysql-connector-java 5.1.40 org.apache.commons commons-pool2 2.7.0 ```

# Database Configuration
db.url=jdbc:mysql://$host:$port/$database_name?useSSL=false
db.username=$user_name
db.password=$password

# Connection Pool Configuration
pool.maxTotal=10
pool.maxIdle=5
pool.minIdle=2
pool.maxWaitMillis=5000

```java
package com.example;

import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

import org.apache.commons.pool2.ObjectPool;
import org.apache.commons.pool2.PoolUtils;
import org.apache.commons.pool2.PooledObject;
import org.apache.commons.pool2.impl.GenericObjectPool;
import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
import org.apache.commons.pool2.impl.DefaultPooledObject;

public class Main {

public static void main(String[] args) { // Load the database configuration file Properties props = new Properties(); try { props.load(Main.class.getClassLoader().getResourceAsStream("db.properties")); } catch (IOException e) { e.printStackTrace(); }

    // Create the database connection pool configuration

GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig<>(); poolConfig.setMaxTotal(Integer.parseInt(props.getProperty("pool.maxTotal"))); poolConfig.setMaxIdle(Integer.parseInt(props.getProperty("pool.maxIdle"))); poolConfig.setMinIdle(Integer.parseInt(props.getProperty("pool.minIdle"))); poolConfig.setMaxWaitMillis(Long.parseLong(props.getProperty("pool.maxWaitMillis")));

// Create the database connection pool ObjectPool connectionPool = PoolUtils.synchronizedPool(new GenericObjectPool<>(new ConnectionFactory( props.getProperty("db.url"), props.getProperty("db.username"), props.getProperty("db.password")), poolConfig));

// Get a database connection try (Connection connection = connectionPool.borrowObject()) {

// Create table createTable(connection);

// Insert data insertData(connection); // Query data selectData(connection);

// Update data updateData(connection); // Query the updated data selectData(connection);

// Delete data deleteData(connection); // Query the data after deletion selectData(connection);

// Drop table dropTable(connection); } catch (Exception e) { e.printStackTrace(); } }

private static void createTable(Connection connection) throws SQLException {
    try (Statement statement = connection.createStatement()) {

String sql = "CREATE TABLE test_commonpool (id INT,name VARCHAR(20))"; statement.executeUpdate(sql); System.out.println("Table created successfully."); } }

private static void insertData(Connection connection) throws SQLException {
    try (Statement statement = connection.createStatement()) {

String sql = "INSERT INTO test_commonpool (id, name) VALUES (1,'A1'), (2,'A2'), (3,'A3')"; statement.executeUpdate(sql); System.out.println("Data inserted successfully."); } }

private static void updateData(Connection connection) throws SQLException {
    try (Statement statement = connection.createStatement()) {

String sql = "UPDATE test_commonpool SET name = 'A11' WHERE id = 1"; statement.executeUpdate(sql); System.out.println("Data updated successfully."); } }

private static void deleteData(Connection connection) throws SQLException {
    try (Statement statement = connection.createStatement()) {
        String sql = "DELETE FROM test_commonpool WHERE id = 2";

statement.executeUpdate(sql); System.out.println("Data deleted successfully."); } }

private static void selectData(Connection connection) throws SQLException { try (Statement statement = connection.createStatement()) { String sql = "SELECT * FROM test_commonpool"; ResultSet resultSet = statement.executeQuery(sql); while (resultSet.next()) { int id = resultSet.getInt("id"); String name = resultSet.getString("name"); System.out.println("id: " + id + ", name: " + name); } } }

private static void dropTable(Connection connection) throws SQLException { try (Statement statement = connection.createStatement()) { String sql = "DROP TABLE test_commonpool"; statement.executeUpdate(sql); System.out.println("Table dropped successfully."); } }

static class ConnectionFactory extends org.apache.commons.pool2.BasePooledObjectFactory { private final String url; private final String username; private final String password;

public ConnectionFactory(String url, String username, String password) { this.url = url; this.username = username; this.password = password; }

    @Override

public Connection create() throws Exception { return DriverManager.getConnection(url, username, password); }

    @Override

public void destroyObject(org.apache.commons.pool2.PooledObject p) throws Exception { p.getObject().close(); }

    @Override

public boolean validateObject(org.apache.commons.pool2.PooledObject p) { try { return p.getObject().isValid(5000); } catch (SQLException e) { return false; } }

@Override public PooledObject wrap(Connection connection) { return new DefaultPooledObject<>(connection); } } } ```

OceanBase

顧客事例

Commons Pool を使用して OceanBase データベースに接続するサンプルプログラム

前提条件

説明

操作手順

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

説明

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

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

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

pom.xml コードの紹介

db.properties コードの紹介

注意

Main.java コードの紹介

完全なコードの表示

関連情報