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

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

前提条件

• OceanBaseデータベースをインストールし、MySQLテナントを作成していること。

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

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

  説明

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

手順

1. proxool-mysql-client プロジェクトをIntelliJ IDEAにインポートします。
2. OceanBaseデータベースのURLを取得します。
3. proxool-mysql-client プロジェクト内のデータベース接続情報を修正します。
4. proxool-mysql-client プロジェクトを実行します。

ステップ１：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. ApplyまたはOKをクリックして変更を保存します。

ステップ2：OceanBaseデータベースのURLを取得する

1. OceanBaseデータベースのデプロイ担当者または管理者から、該当するデータベース接続文字列を取得します。

   例：

   obclient -hxxx.xxx.xxx.xxx -P2881 -utest_user001@mysql001 -p****** -Dtest -A
   

   接続文字列の詳細については、OBClientを使用してOceanBaseテナントに接続するを参照してください。

2. OceanBaseデータベースの接続文字列情報に基づいて、以下のURLの対応する情報を入力します。

   jdbc:mysql://$host:$port/$database_name?user=$user_name&password=$password
   

   パラメータ説明：

   • $host：OceanBaseデータベースへの接続IPアドレスです。OceanBaseデータベースプロキシ(OceanBase Database Proxy、ODP)経由で接続する場合はODPアドレスを使用し、直接接続する場合はOBServerノードのIPアドレスを使用します。

   • $port：OceanBaseデータベースへの接続ポートです。ODP接続経由の場合のデフォルトポートは2883で、ODPデプロイ時にカスタマイズ可能です。直接接続する場合のデフォルトは2881で、OceanBaseデータベースのデプロイ時にカスタマイズ可能です。

   • $database_name：アクセスするデータベース名。

     注意

     テナントに接続するユーザーには、データベースに対する CREATE、INSERT、DELETE、UPDATE、および SELECT 権限が付与されていなければなりません。その他のユーザー権限の詳細については、MySQLモードの権限分類を参照してください。

   • user_name：テナントの接続アカウントです。ODP接続経由の場合の形式はユーザー名@テナント名#クラスタ名 または クラスタ名:テナント名:ユーザー名となります。直接接続の場合の形式はユーザー名@テナント名です。

   • password：アカウントのパスワード。

   MySQL Connector/J接続プロパティの詳細については、Configuration Propertiesを参照してください。

   例：

   jdbc:mysql://xxx.xxx.xxx.xxx:2881/test?user=test_user001@mysql001&password=******
   

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

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

例：

• OBServerノードのIPアドレスはxxx.xxx.xxx.xxxです。
• アクセスポートは2881を使用します。
• アクセスするデータベース名はtestです。
• テナントの接続アカウントはtest_user001@mysql001です。mysql001はOceanBaseデータベースで作成されたMySQLモードのユーザーテナントであり、test_user001はテナントmysql001のユーザー名です。
• パスワードは******です。

コード：

...
jdbc-1.proxool.driver-url=jdbc:mysql://xxx.xxx.xxx.xxx:2881/test?useSSL=false
jdbc-1.user=test_user@mysql001
jdbc-1.password=******
...

ステップ4：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ライブラリを追加します。データベースへの接続と操作に使用されます：

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

      コード：

              <dependency>
                  <groupId>mysql</groupId>
                  <artifactId>mysql-connector-java</artifactId>
                  <version>5.1.47</version>
              </dependency>
      

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

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

      コード：

              <dependency>
                  <groupId>proxool</groupId>
                  <artifactId>proxool-cglib</artifactId>
                  <version>0.9.1</version>
              </dependency>
      

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

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

      コード：

              <dependency>
                  <groupId>proxool</groupId>
                  <artifactId>proxool</artifactId>
                  <version>0.9.1</version>
              </dependency>
      

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

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

      コード：

              <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：OceanBaseデータベースへの接続IPアドレスです。ODP接続方式の場合はODPアドレスを使用し、直接接続方式の場合はOBServerノードのIPアドレスを使用します。
   • $port：OceanBaseデータベースへの接続ポートです。ODP接続方式のデフォルトは 2883 で、ODPデプロイ時にカスタマイズ可能です。直接接続方式のデフォルトは 2881 で、OceanBaseデータベースのデプロイ時にカスタマイズ可能です。
   • $database_name：アクセスするデータベースの名前です。
   • $user_name：テナントの接続アカウントです。ODP接続の一般的な形式はユーザー名@テナント名#クラスタ名 または クラスタ名:テナント名:ユーザー名です。直接接続方式の形式はユーザー名@テナント名です。
   • $password：アカウントのパスワードです。

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. 例外が発生する可能性のあるコードブロックをキャッチします。

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

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

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

   コード：

   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 という名前のテーブルを作成します。このテーブルには c1 と c2 の2つの列があり、それぞれ INT 型と VARCHAR(32) 型です。

   コード：

       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. データをクエリするためのメソッドを定義します。

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

   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接続プールの使用方法の詳細については、ユーザー向け紹介を参照してください。