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

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

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

前提条件

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

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

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

  説明

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

手順

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

ステップ１：proxool-oceanbase-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-oceanbase-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@oracel001 -p******
   

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

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

   jdbc:oceanbase://$host:$port/$schema_name?user=$user_name&password=$password
   

   パラメータ説明：

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

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

   • $schema_name：アクセスするスキーマ名。

     注意

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

   • $user_name：テナントの接続アカウント。ODP接続の一般的な形式：ユーザー名@テナント名#クラスタ名またはクラスタ名:テナント名:ユーザー名。直接接続方式の形式：ユーザー名@テナント名。

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

   OceanBase Connector/J URLパラメータの詳細については、データベースURLを参照してください。

   例：

   jdbc:oceanbase://xxx.xxx.xxx.xxx:2881/test_schema001?user=test_user001@oracel001&password=******
   

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

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

例：

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

コード：

...
jdbc-1.proxool.driver-url=jdbc:oceanbase://xxx.xxx.xxx.xxx:2881/test_schema001
jdbc-1.user=test_user001@oracle001
jdbc-1.password=******
...

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

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

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

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

   

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

   obclient [TEST_USER001]> SELECT * FROM test_schema001.test_proxool;
   

   戻り結果は次のとおりです：

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

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

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

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

proxool-oceanbase-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-oceanbase-client と指定します。
   3. <version> を使用して、プロジェクトのバージョン番号を 1.0-SNAPSHOT と指定します。

   コード：

       <groupId>com.example</groupId>
       <artifactId>proxool-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 依存ライブラリを追加し、データベースへの接続と操作に使用します：

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

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

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

   <main id="notice" type='explain'>
     <h4>説明</h4>
     <p>このセクションのコードは、プロジェクトが依存するコンポーネントがOceanBase Connector/JのV2.4.2バージョンであることを定義しています。他のバージョンの情報については、<a href="https://en.oceanbase.com/docs/oceanbase-connector-j-en">OceanBase JDBCドライバ</a> を参照してください。</p>
   </main>
   
   **コード：**
   
   ```java
           <dependency>
               <groupId>com.oceanbase</groupId>
               <artifactId>oceanbase-client</artifactId>
               <version>2.4.2</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. ドライバーのクラス名を設定します。ここでは、OceanBase JDBCドライバーのクラス名 com.oceanbase.jdbc.Driver です。
   2. データベース接続のURLを設定します。ホストIP、ポート番号、アクセスするSchemaを含みます。
   3. データベースのユーザー名を設定します。
   4. データベースのパスワードを設定します。

   コード：

   jdbc-1.proxool.driver-class=com.oceanbase.jdbc.Driver
   jdbc-1.proxool.driver-url=jdbc:oceanbase://$host:$port/$schema_name
   jdbc-1.user=$user_name
   jdbc-1.password=$password
   

   パラメータの説明：

   • $host：OceanBaseデータベースへの接続IPを提供します。ODP接続方式ではODPアドレスを使用し、直接接続方式ではOBServerノードのIPアドレスを使用します。
   • $port：OceanBaseデータベースへの接続ポートを提供します。ODP接続方式のデフォルトポートは 2883 で、ODPデプロイ時にカスタマイズ可能です。直接接続方式のデフォルトポートは 2881 で、OceanBaseデータベースのデプロイ時にカスタマイズ可能です。
   • $schema_name：アクセスするSchema名です。
   • $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. テーブルの作成、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 という名前のテーブルを作成します。このテーブルには c1 と c2 の2つの列があり、それぞれ NUMBER 型と VARCHAR2(32) 型です。

   コード：

       private static void executeDDLStatements(Statement stmt) throws Exception {
           stmt.execute("CREATE TABLE test_proxool (c1 NUMBER, c2 VARCHAR2(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-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>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.oceanbase.jdbc.Driver
#driver-url: url connection string, username and password must be determined
jdbc-1.proxool.driver-url=jdbc:oceanbase://$host:$port/$schema_name
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 NUMBER, c2 VARCHAR2(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"));
            }
        }
    }
}

関連ドキュメント

• OceanBase Connector/Jの詳細については、OceanBase JDBCドライバを参照してください。
• Proxool接続プールの詳細については、Introduction for Usersを参照してください。