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

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

クリックしてproxool-mysql-clientサンプルプロジェクトをダウンロード

前提条件

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

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

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

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

  説明

  このドキュメントでコードを実行するために使用されているツールはIntelliJ IDEA Community Edition 2021.3.2ですが、個人の好みに応じて適したツールを選択してサンプルコードを実行することもできます。

操作手順

ステップ１：proxool-mysql-clientプロジェクトをIntelliJ IDEAにインポートする

1. IntelliJ IDEAを開きます。

2. ウェルカム画面で、Openオプションをクリックし、プロジェクトのディレクトリに移動します。プロジェクトのルートディレクトリを選択して、OKをクリックします。

   

3. IntelliJ IDEAは、プロジェクトのタイプを自動的に検出し、プロジェクトを読み込みます。

   説明

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

   

4. （オプション）未解決の依存関係を手動でインポートします。

   pom.xml ファイルに対応する依存関係がすべてプロジェクトに自動的にインポートされている場合は、この手順を無視してください。

   IntelliJ IDEAのSyncウィンドウのヒントから、proxool-cglib と proxool の依存関係が解決されていないことがわかります。proxool-mysql-client プロジェクトのルートディレクトリにある lib フォルダには、proxool-cglib と proxool の jar ファイルが含まれています。これらをプロジェクトに追加する手順は以下のとおりです：

   1. IntelliJ IDEAで、File->Project Structureをクリックして、プロジェクト構造の設定に入ります。
   2. 左側のパネルで、Modulesを選択します。
   3. 右側のモジュールリストで、Dependenciesタブを選択し、このページの**+**アイコンをクリックして、JARs or directoriesを選択します。
   4. ポップアップダイアログで、jar ファイルが保存されている lib ディレクトリに移動し、jar ファイルを選択して、OKをクリックします。
   5. Dependenciesタブで、新しく追加された jar ファイルがリストに表示されます。
   6. 適用するまたはOKをクリックして変更を保存します。

   

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

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

例：

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

コード：

...
jdbc-1.proxool.driver-url=jdbc:mysql://t5******.********.oceanbase.cloud:3306/test?useSSL=false
jdbc-1.user=test_user
jdbc-1.password=******
...

ステップ3：proxool-mysql-clientプロジェクトを実行する

1. プロジェクトのナビゲーションバーで、src/main/java/com.exampleディレクトリを見つけて展開します。

2. Mainファイルを右クリックし、**Run 'Main.main()'**を選択します。

3. IntelliJ IDEAは、プロジェクトを自動的にコンパイルして実行し、実行パネルに出力結果を表示します。

   

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

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

   実行結果は次のとおりです：

   +------+---------------+
   | c1   | c2            |
   +------+---------------+
   |    6 | test_update   |
   |    7 | test_insert7  |
   |    8 | test_insert8  |
   |    9 | test_insert9  |
   |   10 | test_insert10 |
   +------+---------------+
   5 rows in set
   

プロジェクトコードについて

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

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

proxool-mysql-client
├── lib
│    ├── proxool-0.9.1.jar
│    └── proxool-cglib.jar
├── src
│   └── main
│       ├── java
│       │   └── com
│       │       └── example
│       │           └── Main.java
│       └── resources
│           └── db.properties
└── pom.xml

ファイルの説明：

• lib：プロジェクトに必要な依存ライブラリファイルを格納します。
• proxool-0.9.1.jar：Proxool接続プールライブラリファイル。
• proxool-cglib.jar：Proxool接続プールをサポートするためのCGLibライブラリファイル。
• 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> を使用して、プロジェクトの名前を proxool-mysql-client と指定します。
   3. <version> を使用して、プロジェクトのバージョン番号を 1.0-SNAPSHOT と指定します。

   コード：

       <groupId>com.example</groupId>
       <artifactId>proxool-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. プロジェクトが依存するコンポーネントを設定します。

   <dependency> を使用して依存関係を定義します：

   1. mysql-connector-java ライブラリを追加します。データベースへの接続と操作に使用されます：

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

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

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

    **コード：**
   
    ```java
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>5.1.47</version>
            </dependency>
    ```
   

   2. proxool-cglib 依存ライブラリを追加します。Proxool接続プールをサポートするためのCGLibライブラリです：

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

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

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

    **コード：**
   
    ```java
            <dependency>
                <groupId>proxool</groupId>
                <artifactId>proxool-cglib</artifactId>
                <version>0.9.1</version>
            </dependency>
    ```
   

   3. proxool 依存ライブラリを追加します。Proxool接続プールのコアライブラリです：

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

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

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

    **コード：**
   
    ```java
            <dependency>
                <groupId>proxool</groupId>
                <artifactId>proxool</artifactId>
                <version>0.9.1</version>
            </dependency>
    ```
   

   4. commons-logging 依存ライブラリを追加します。アプリケーションでログ記録を行うための汎用ログライブラリです：

   5. <groupId> を使用して、依存関係が属する組織を commons-logging と指定します。

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

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

    **コード：**
   
    ```java
            <dependency>
                <groupId>commons-logging</groupId>
                <artifactId>commons-logging</artifactId>
                <version>1.2</version>
            </dependency>
    ```
   

db.propertiesコードの紹介

db.properties は本記事の例となる接続プールの設定ファイルであり、接続プールの設定プロパティが含まれています。

本記事の db.properties ファイルは、jdbc-1 という名前のデータソースの接続プールプロパティを設定するためのプロパティファイルの例です。主に以下の部分が含まれます：

1. データソースのエイリアスを TEST に設定します。

   コード：

   jdbc-1.proxool.alias=TEST
   

2. データベース接続パラメータを設定します。

   1. ドライバーのクラス名を設定します。ここではMySQL JDBCドライバーのクラス名 com.mysql.jdbc.Driver です。
   2. データベース接続のURLを設定します。ホストIP、ポート番号、アクセスするデータベース、および追加の接続プロパティを含みます。
   3. データベースのユーザー名を設定します。
   4. データベースのパスワードを設定します。

   コード：

   jdbc-1.proxool.driver-class=com.mysql.jdbc.Driver
   jdbc-1.proxool.driver-url=jdbc:mysql://$host:$port/$database_name?useSSL=false
   jdbc-1.user=$user_name
   jdbc-1.password=$password
   

   パラメータの説明：

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

3. その他のProxool接続プールのパラメータを設定します。

   1. 接続プールの最大接続数を8に設定します。
   2. 接続プールの最小接続数を5に設定します。
   3. 接続プールで利用可能な接続数を4に設定します。
   4. 接続プールの詳細モードを有効に設定します。これにより、より多くのログ情報が表示されます。
   5. 接続プールの統計情報記録間隔を10秒、1分、1日に設定します。
   6. 接続プール統計情報記録のログレベルをエラーレベルに設定します。

   コード：

   jdbc-1.proxool.maximum-connection-count=8
   jdbc-1.proxool.minimum-connection-count=5
   jdbc-1.proxool.prototype-count=4
   jdbc-1.proxool.verbose=true
   jdbc-1.proxool.statistics=10s,1m,1d
   jdbc-1.proxool.statistics-log-level=error
   

よく使われる構成パラメータの説明:

Main.javaコードの紹介

Main.java ファイルはサンプルプログラムの一部であり、Proxool接続プールを使用してデータベース接続を取得し、テーブルの作成、データの挿入、削除、更新、クエリといった一連のデータベース操作を実行し、その結果を出力する方法を示しています。

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

1. 必要なクラスとインターフェースのインポート。

   コードが存在するパッケージを定義し、ProxoolおよびJDBC関連のクラスをインポートします。これらのクラスは、データベース接続プールの設定と管理、およびSQL文の実行に使用されます。Proxool接続プールを使用することで、データベース操作のパフォーマンスと信頼性を向上させることができます。具体的な手順は以下の通りです：

   1. コードが存在するパッケージを com.example と定義します。このパッケージは現在のJavaクラスを格納するために使用されます。
   2. Proxoolの設定クラス org.logicalcobwebs.proxool.configuration.PropertyConfigurator をインポートします。
   3. 設定ファイルを読み取るための入力ストリームクラス java.io.InputStream をインポートします。
   4. JDBCのConnectionクラス java.sql.Connection をインポートします。
   5. JDBCのDriverManagerクラス java.sql.DriverManager をインポートします。
   6. JDBCのResultSetクラス java.sql.ResultSet をインポートします。
   7. JDBCのStatementクラス java.sql.Statement をインポートします。
   8. 設定ファイルを読み込むための Propertiesクラス java.util.Properties をインポートします。

   コード：

   package com.example;
   
   import org.logicalcobwebs.proxool.configuration.PropertyConfigurator;
   import java.io.InputStream;
   import java.sql.Connection;
   import java.sql.DriverManager;
   import java.sql.ResultSet;
   import java.sql.Statement;
   import java.util.Properties;
   

2. クラス名とメソッドの定義。

   Javaプログラムのエントリーメソッドを定義します。設定ファイルを読み取ってデータベース接続情報を取得し、Proxoolドライバを使用してデータベース接続を確立した後、定義済みのメソッドを順次呼び出してDDL文、DML文、クエリ文を実行します。発生する可能性のある例外情報をキャッチして出力します。このコードの目的は、データベース関連の操作を実行し、ログレコーダーを使用してログを記録することです。具体的な手順は以下の通りです：

   1. Mainという名前のpublicクラスを定義します。

   2. データベース設定（プロパティ）ファイルのパスを表す、DB_PROPERTIES_FILE という名前のプライベート静的定数を定義します。この定数はコード内で参照することができ、プロパティファイルの読み込みと読み取りに使用されます。

   3. プログラムの実行開始点として、public staticメソッド main を定義します。

      1. 例外が発生する可能性のある処理をtryブロックで囲みます。

         1. 設定ファイルからプロパティを読み取るために使用される Properties オブジェクトを作成します。
         2. Mainクラスのクラスローダーを使用して、設定ファイルの入力ストリームを取得します。
         3. 読み込んだ入力ストリームを使用して設定ファイルを読み込み、プロパティを Properties オブジェクトにロードします。
         4. 読み込んだプロパティを使用して接続プールを設定します。
         5. Proxoolデータベースドライバを動的にロードします。
         6. Proxoolドライバを使用してデータベース接続を確立します。
         7. Statement オブジェクトを作成します。
         8. 定義済みのメソッド executeDDLStatements() を呼び出してDDL文を実行します。これはテーブルを作成する操作です。
         9. 定義済みのメソッド executeDMLStatements() を呼び出してDML文を実行します。これはデータの挿入、更新、削除を行う操作です。
         10. 定義済みのメソッド executeQueryStatements() を呼び出してクエリ文を実行し、データを取得します。

      2. 発生する可能性のある例外情報をキャッチして出力します。

   4. テーブルの作成、DML文の実行、データのクエリを行うためのメソッドを定義します。

   コード：

   public class Main {
       private static final String DB_PROPERTIES_FILE = "/db.properties";
   
       public static void main(String[] args) {
           try {
               Properties properties = new Properties();
               InputStream is = Main.class.getResourceAsStream(DB_PROPERTIES_FILE);
               properties.load(is);
               PropertyConfigurator.configure(properties);
   
               Class.forName("org.logicalcobwebs.proxool.ProxoolDriver");
               try (Connection conn = DriverManager.getConnection("proxool.TEST");
                   Statement stmt = conn.createStatement()) {
                   executeDDLStatements(stmt);
                   executeDMLStatements(stmt);
                   executeQueryStatements(stmt);
               }
           } catch (Exception e) {
               e.printStackTrace();
           }
       }
   
       // テーブルを作成するためのメソッドを定義する
       // DMLステートメントを実行するためのメソッドを定義する
       // データをクエリするためのメソッドを定義する
   }
   

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

   プライベート静的メソッド executeDDLStatements() を定義します。これは、テーブル作成文を含むDDL（データ定義言語）ステートメントを実行するために使用されます。具体的な手順は以下のとおりです：

   1. プライベート静的メソッド executeDDLStatements() を定義します。このメソッドは Statement オブジェクトをパラメータとして受け取り、Exception 例外をスローする可能性があります。
   2. execute() メソッドを使用してSQLステートメントを実行し、test_proxool という名前のテーブルを作成します。このテーブルには、INT 型と VARCHAR(32) 型の2つの列 c1 と c2 があります。

   コード：

       private static void executeDDLStatements(Statement stmt) throws Exception {
           stmt.execute("CREATE TABLE test_proxool (c1 INT, c2 VARCHAR(32))");
       }
   

4. DMLステートメントを実行するためのメソッドを定義します。

   プライベート静的メソッド executeDMLStatements() を定義します。これは、データの挿入、削除、更新を含むDML（データ操作言語）ステートメントを実行するために使用されます。具体的な手順は以下のとおりです：

   1. プライベート静的メソッド executeDMLStatements() を定義します。このメソッドは Statement オブジェクトをパラメータとして受け取り、実行中に例外が発生した場合、Exception 例外をスローします。
   2. for ループを使用して、1から10まで反復します。ループ内で execute() メソッドを使用してSQL挿入ステートメントを実行し、変数 i と関連する文字列値を test_proxool テーブルに挿入します。
   3. SQL削除ステートメントを実行し、test_proxool テーブルから c1 列の値が5以下の行を削除します。
   4. SQL更新ステートメントを実行し、test_proxool テーブルの c1 列の値が6の行の c2 列を test_update に更新します。

   コード：

       private static void executeDMLStatements(Statement stmt) throws Exception {
           for (int i = 1; i <= 10; i++) {
               stmt.execute("INSERT INTO test_proxool VALUES (" + i + ",'test_insert" + i + "')");
           }
           stmt.execute("DELETE FROM test_proxool WHERE c1 <= 5");
           stmt.execute("UPDATE test_proxool SET c2 = 'test_update' WHERE c1 = 6");
       }
   

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

   SELECT クエリステートメントを実行し、結果を処理するためのプライベート静的メソッド executeQueryStatements() を定義します。具体的な手順は以下のとおりです：

   1. プライベート静的メソッド executeQueryStatements() を定義します。このメソッドは Statement オブジェクトをパラメータとして受け取り、実行中に例外が発生した場合は Exception をスローします。
   2. executeQuery() メソッドを使用して SELECT クエリステートメントを実行し、結果を ResultSet オブジェクト rs に格納します。ここでは、test_proxool テーブルのすべてのデータがクエリで返されます。try-with-resources ステートメントを使用して、ResultSet の使用後に自動的に閉じられるようにします。
   3. while ループと next() メソッドを使用して、ResultSet オブジェクト rs 内の各行データを反復処理します。各反復では、rs.next() メソッドがポインタを結果セットの次の行に移動します。次の行のデータが利用可能な場合、このメソッドは true を返し、そうでない場合は false を返します。while ループ内では、rs.next() が true を返す限り、まだ利用可能な行データがあることを意味します。ループ体内のコードが実行され、現在の行のデータが処理されます。すべての行のデータが処理された後、rs.next() は false を返し、ループ終了となります。
   4. getInt() と getString() メソッドを使用して、現在の行の指定された列名の値を取得し、それらをコンソールに出力します。ここでは、c1 列と c2 列の値が出力されます。getInt() メソッドは整数値を取得するために使用され、getString() メソッドは文字列値を取得するために使用されます。

   コード：

       private static void executeQueryStatements(Statement stmt) throws Exception {
           try (ResultSet rs = stmt.executeQuery("SELECT * FROM test_proxool")) {
               while (rs.next()) {
                   System.out.println(rs.getInt("c1") + "   " + rs.getString("c2"));
               }
           }
       }
   

全コード表示

<?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>proxool-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.47</version>
        </dependency>
        <dependency>
            <groupId>proxool</groupId>
            <artifactId>proxool-cglib</artifactId>
            <version>0.9.1</version>
        </dependency>
        <dependency>
            <groupId>proxool</groupId>
            <artifactId>proxool</artifactId>
            <version>0.9.1</version>
        </dependency>
        <dependency>
            <groupId>commons-logging</groupId>
            <artifactId>commons-logging</artifactId>
            <version>1.2</version>
        </dependency>
    </dependencies>
</project>

#alias: the alias of the data source
jdbc-1.proxool.alias=TEST
#driver-class: driver name
jdbc-1.proxool.driver-class=com.mysql.jdbc.Driver
#driver-url: url connection string, username and password must be determined
jdbc-1.proxool.driver-url=jdbc:mysql://$host:$port/$database_name?useSSL=false
jdbc-1.user=$user_name
jdbc-1.password=$password
#The maximum number of database connections. The default is 15
jdbc-1.proxool.maximum-connection-count=8
#The minimum number of database connections, defaults to 5
jdbc-1.proxool.minimum-connection-count=5
#The number of available connections in the Connection pool. If the number of connections in the current Connection pool is less than this value, new connections will be established (assuming that the maximum number of available connections is not exceeded). For example, if we have three active connections and two available connections, and our prototype count is 4, the database Connection pool will try to establish another two connections. This is different from the minimum connection count Minimum connection count also counts active connections. Prototype count is the number of spare connections
jdbc-1.proxool.prototype-count=4
#verbose: detailed information settings. Parameter bool value
jdbc-1.proxool.verbose=true
#statistics: connection pool usage statistics. Parameter "10s, 1m, 1d"
jdbc-1.proxool.statistics=10s,1m,1d
#statistics-log-level:  log statistics tracking type. Parameter 'ERROR' or 'INFO'
jdbc-1.proxool.statistics-log-level=error

package com.example;

import org.logicalcobwebs.proxool.configuration.PropertyConfigurator;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.Properties;

public class Main {
    private static final String DB_PROPERTIES_FILE = "/db.properties";

    public static void main(String[] args) {
        try {
            Properties properties = new Properties();
            InputStream is = Main.class.getResourceAsStream(DB_PROPERTIES_FILE);
            properties.load(is);
            PropertyConfigurator.configure(properties);

            Class.forName("org.logicalcobwebs.proxool.ProxoolDriver");
            try (Connection conn = DriverManager.getConnection("proxool.TEST");
                Statement stmt = conn.createStatement()) {
                executeDDLStatements(stmt);
                executeDMLStatements(stmt);
                executeQueryStatements(stmt);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    private static void executeDDLStatements(Statement stmt) throws Exception {
        stmt.execute("CREATE TABLE test_proxool (c1 INT, c2 VARCHAR(32))");
    }

    private static void executeDMLStatements(Statement stmt) throws Exception {
        for (int i = 1; i <= 10; i++) {
            stmt.execute("INSERT INTO test_proxool VALUES (" + i + ",'test_insert" + i + "')");
        }
        stmt.execute("DELETE FROM test_proxool WHERE c1 <= 5");
        stmt.execute("UPDATE test_proxool SET c2 = 'test_update' WHERE c1 = 6");
    }

    private static void executeQueryStatements(Statement stmt) throws Exception {
        try (ResultSet rs = stmt.executeQuery("SELECT * FROM test_proxool")) {
            while (rs.next()) {
                System.out.println(rs.getInt("c1") + "   " + rs.getString("c2"));
            }
        }
    }
}

関連ドキュメント

• MySQL Connector/Jの詳細については、MySQL Connector/Jの概要をご参照ください。
• Proxool接続プールの使用方法の詳細については、ユーザー向け紹介をご参照ください。