DBCP

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

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

前提条件

• OceanBaseデータベースがインストール済みで、Oracleモードのテナントが作成されていること。

• JDK 1.8とMavenがインストール済みであること。

• Eclipseがインストール済みであること。

  説明

  この記事でコードの実行にはEclipse IDE for Java Developers 2022-03バージョンを使用しています。ご自身の好みに合わせて、適切なツールを選択してサンプルコードを実行することも可能です。

操作手順

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

ステップ１：dbcp-oceanbase-clientプロジェクトをEclipseにインポートする

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

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

   説明

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

   

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

   

ステップ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 権限と、そのSchemaの CREATE TABLE、INSERT、DELETE、UPDATE、および SELECT 権限が付与されていなければなりません。ユーザー権限の詳細については、Oracleモードの権限分類を参照してください。

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

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

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

   例：

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

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

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

例：

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

コード：

...
url=jdbc:oceanbase://xxx.xxx.xxx.xxx:2881/test_user001
username=test_user001@oracle001
password=******
...

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

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

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

   

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

   

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

   obclient [SYS]> SELECT * FROM test_user001.test_tbl1;
   

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

   +------+--------------+
   | ID   | NAME         |
   +------+--------------+
   |    5 | test_update  |
   |    6 | test_insert6 |
   |    7 | test_insert7 |
   |    8 | test_insert8 |
   |    9 | test_insert9 |
   +------+--------------+
   5 rows in set
   

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

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

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

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

   コード：

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

   説明

   この部分のコードでは、プロジェクトが依存するコンポーネントとしてOceanBase Connector/JのバージョンV2.4.2を定義しています。他のバージョンの情報については、OceanBase JDBCドライバーを参照してください

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

   • oceanbase-client依存関係：

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

   • dbcp依存関係：

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

   コード：

       <dependencies>
           <dependency>
               <groupId>com.oceanbase</groupId>
               <artifactId>oceanbase-client</artifactId>
               <version>2.4.2</version>
           </dependency>
           <dependency>
               <groupId>org.apache.commons</groupId>
               <artifactId>commons-dbcp2</artifactId>
               <version>2.9.0</version>
           </dependency>
       </dependencies>
   

db.propertiesコードの紹介

db.properties は本記事の例となる接続プールの設定ファイルであり、接続プールの設定プロパティが含まれています。これらのプロパティには、ドライバーのクラス名、データベースURL、ユーザー名、パスワード、接続プールのサイズと制限、接続のタイムアウト時間、放棄された接続を処理するためのオプションが含まれます。

本記事の db.properties ファイルのコードは、主に以下のいくつかの部分が含まれます：

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

   1. ドライバーのクラス名を設定します。ここでは、OceanBase JDBCドライバーのクラス名 com.oceanbase.jdbc.Driver です。

      説明

      OceanBase Connector/J実装クラスの名前については、OceanBase Javaデータベース接続ドライバーを参照してください。

   2. データベース接続のURLを設定します。これには、ホストIPアドレス、ポート番号、アクセスするSchemaが含まれます。

   3. データベースのユーザー名を設定します。

   4. データベースのパスワードを設定します。

   コード：

   driverClassName=com.oceanbase.jdbc.Driver
   url=jdbc:oceanbase://$host:$port/$schema_name
   username=$user_name
   password=$password
   

   パラメータの説明：

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

2. 他のDBCP接続プールのパラメータを設定します。

   1. 接続プールの初期サイズを 30 に設定します。つまり、接続プールが最初に作成される接続数です。

   2. 接続プールの最大接続数を 30 に設定します。つまり、接続プール内で許容される最大接続数です。

   3. 接続プール内で保持可能なアイドル状態の最大接続数を 10 に設定します。

   4. 接続プール中でアイドル状態を保持する最小接続数を 5 に設定します。アイドル接続数がこの値を下回ると、接続プールは新しい接続を作成します。

   5. 接続プールから接続を取得する際の最大待機時間（ミリ秒単位）を 1000 に設定します。接続プール内のすべての接続が使用中で、利用可能な接続がない場合、接続取得操作は、接続が利用可能になるか、最大待機時間を超えるまで待機します。

   6. 放棄された接続を削除するまでのタイムアウト時間（秒単位）は 1 です。

      説明

      removeAbandonedTimeout のデフォルト値は300秒ですが、この例ではプログラムをテストするために1秒に設定されています。アプリケーションのニーズに合わせて、この値を適切に調整することができます。

   7. プログラム内の接続が使用されなくなった後、接続プールによって回収されるかどうか：

      • メンテナンス中に放棄された接続を検出して、クリーンアップするかどうか設定します。true に設定します。
      • 接続プールから接続を借用する際に、放棄された接続を検出してクリーンアップするかどうかを設定します。true に設定します。

   コード：

   initialSize=30
   maxTotal=30
   maxIdle=10
   minIdle=5
   maxWaitMillis=1000
   removeAbandonedTimeout=1
   
   removeAbandonedOnMaintenance=true
   removeAbandonedOnBorrow=true
   

DBCP接続プールの基本データソース構成パラメータ：

Main.javaコードの紹介

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

本記事の Main.java ファイルのコードには、主に以下のいくつの部分が含まれます：

1. 必要なクラスとインターフェースをインポートします。

   ファイルの読み込み、データベースの操作、データベース接続プールに関連するクラスとインターフェースを含む、必要なクラスとインターフェースをインポートします。これらのクラスとインターフェースは、以降のコードで使用されます。

   1. com.example という名前のパッケージを宣言します。このパッケージは現在のJavaクラスを格納するために使用されます。
   2. java.io.FileInputStream クラスをインポートします。これはファイルを読み込むために使用されます。
   3. java.sql.Connection インターフェースをインポートします。これはデータベースへの接続を意味ます。
   4. java.sql.PreparedStatement インターフェースをインポートします。これはプリコンパイルされたSQLステートメントを意味ます。
   5. java.sql.ResultSet インターフェースをインポートします。これはデータベースクエリの結果セットを意味します。
   6. java.sql.SQLException 例外クラスをインポートします。これは、SQL操作中に発生する例外を意味します。
   7. java.util.Properties クラスをインポートします。これは設定ファイルをロードするために使用されます。
   8. org.apache.commons.dbcp2.BasicDataSource クラスをインポートします。これはデータベース接続プールを意味します。
   9. org.apache.commons.dbcp2.BasicDataSourceFactory クラスをインポートし、データベースの接続プールを作成するために使用されます。

   コード：

   package com.example;
   
   import java.io.FileInputStream;
   import java.sql.Connection;
   import java.sql.PreparedStatement;
   import java.sql.ResultSet;
   import java.sql.SQLException;
   import java.util.Properties;
   
   import org.apache.commons.dbcp2.BasicDataSource;
   import org.apache.commons.dbcp2.BasicDataSourceFactory;
   

2. クラス名とメソッドを定義します。

   1. Mainクラスを作成し、プログラムのエントリポイントとして main メソッドを定義します。
   2. main メソッド内で、まず createDataSource() メソッドを呼び出して、接続プールオブジェクト dataSource を作成します。
   3. try-with-resources ステートメントを使用して、接続プールオブジェクトのライフサイクルの終了時にリソースが自動的に閉じます。
   4. try コードブロック内で、getConnection() メソッドを呼び出して、接続プールからデータベース接続オブジェクト conn を取得します。
   5. createTable()、insertData()、deleteData()、updateData()、queryData() の各メソッドを順に呼び出して、対応するデータベース操作を実行します。
   6. 例外が発生した場合、catch ブロックで例外情報を出力します。

   コード：

   public class Main {
   
       public static void main(String[] args) {
           try (BasicDataSource dataSource = createDataSource()) {
               try (Connection conn = dataSource.getConnection()) {
                   createTable(conn);
                   insertData(conn);
                   deleteData(conn);
                   updateData(conn);
                   queryData(conn);
               }
           } catch (Exception e) {
               e.printStackTrace();
           }
       }
   
       // 接続プールの作成
       // テーブルを作成するためのメソッドを定義する
       // データを挿入するためのメソッドを定義する
       // データを削除するためのメソッドを定義する
       // データを更新するたのメソッドを定義する
       // データをクエリするためのメソッドを定義する
   }
   

3. 接続プールを作成します。

   データベース接続プールを作成するための便利なメソッドを提供し、設定ファイルからパラメータを読み取って接続プールオブジェクトを初期化します。具体的な手順は以下のとおりです：

   1. プライベート静的メソッド createDataSource() を定義し、BasicDataSource タイプを返します。このメソッドは Exception 例外をスローする可能性があります。
   2. データベース接続の設定情報をストレージするための Properties オブジェクト props を作成します。
   3. src/main/resources ディレクトリにある db.properties ファイルを読み取るための FileInputStream オブジェクト is を作成します。
   4. load() メソッドを使用して、db.properties ファイル内のキーと値のペアを props オブジェクトにロードします。
   5. BasicDataSourceFactory.createDataSource(props) メソッドを呼び出し、props オブジェクトをパラメータとして使用して、BasicDataSource オブジェクトを作成して返します。

   コード：

       private static BasicDataSource createDataSource() throws Exception {
           Properties props = new Properties();
           FileInputStream is = new FileInputStream("src/main/resources/db.properties");
           props.load(is);
   
           return BasicDataSourceFactory.createDataSource(props);
       }
   

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

   データベース内に指定のテーブルを作成するためのメソッドを提供します。これは接続オブジェクトをパラメータとして受け取り、プリコンパイルされた方式でテーブル作成用のSQLステートメントを実行します。具体的な手順は以下のとおりです：

   1. プライベート静的メソッド createTable() を定義し、Connection オブジェクトをパラメータとして受け取ります。メソッドは SQLException 例外をスローする可能性があります。
   2. テーブル作成用のSQLステートメントをストレージするための文字列変数 createTableSql を定義します。SQLステートメントでテーブル名を test_tbl1 と指定し、2つの列を定義します。1つは id という名前の NUMBER タイプ列で、もう1つは name という名前の VARCHAR2(32) タイプ列です。
   3. conn.prepareStatement(createTableSql) メソッドを使用して、プリコンパイルされたSQLステートメントを実行するための PreparedStatement オブジェクト createTableStmt を作成します。
   4. テーブルを作成するために、execute() メソッドを呼び出してSQLステートメントを実行します。

   コード：

       private static void createTable(Connection conn) throws SQLException {
           String createTableSql = "CREATE TABLE test_tbl1 (id NUMBER, name VARCHAR2(32))";
           try (PreparedStatement createTableStmt = conn.prepareStatement(createTableSql)) {
               createTableStmt.execute();
           }
       }
   

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

   データベースのテーブルに指定されたデータを挿入するためのメソッドを提供します。これは接続オブジェクトをパラメータとして受け取り、プリコンパイルされた方式を使用して、データ挿入用のSQLステートメントを実行します。具体的な手順は以下のとおりです：

   1. プライベート静的メソッド insertData() を定義します。このメソッドは Connection オブジェクトをパラメータとして受け取ります。メソッドは SQLException 例外をスローする可能性があります。

   2. データ挿入用のSQLステートメントをストレージするための文字列変数 insertDataSql を定義します。

   3. conn.prepareStatement(insertDataSql) メソッドを使用して、プリコンパイルされたSQLステートメントを実行するための PreparedStatement オブジェクト insertDataStmt を作成します。

   4. for ループを使用してテーブルにデータを挿入：

      1. 10 回ループして、ループごとに1件のデータを挿入します。
      2. setInt() メソッドを使用して、ループ変数 i の値をSQLステートメントの最初のパラメータ値に設定します。
      3. setString() メソッドを使用して、文字列 test_insert + i をSQLステートメントの2番目のパラメータ値に設定します。
      4. データベースにデータを挿入するために、executeUpdate() メソッドを呼び出してSQLステートメントを実行します。

   コード：

       private static void insertData(Connection conn) throws SQLException {
           String insertDataSql = "INSERT INTO test_tbl1 (id, name) VALUES (?, ?)";
           try (PreparedStatement insertDataStmt = conn.prepareStatement(insertDataSql)) {
               for (int i = 0; i < 10; i++) {
                   insertDataStmt.setInt(1, i);
                   insertDataStmt.setString(2, "test_insert" + i);
                   insertDataStmt.executeUpdate();
               }
           }
       }
   

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

   特定条件を満たすデータをデータベースから削除するためのメソッドを提供します。これは、接続オブジェクトをパラメータとして受け取り、プリコンパイルされた方式を使用して、データを削除するSQLステートメントを実行します。具体的な手順は以下のとおりです：

   1. プライベート静的メソッド deleteData() を定義して、Connection オブジェクトをパラメータとして受け取ります。メソッドは SQLException 例外をスローする可能性があります。
   2. データ削除用のSQLステートメントをストレージするための文字列変数 deleteDataSql を定義します。
   3. conn.prepareStatement(deleteDataSql) メソッドを使用して、プリコンパイルされたSQLステートメントを実行するための PreparedStatement オブジェクト deleteDataStmt を作成します。
   4. setInt() メソッドを使用して、SQLステートメントのパラメータ値として数字5を設定します。
   5. 条件を満たすデータをデータベースから削除するために、executeUpdate() メソッドを呼び出してSQLステートメントを実行します。

   コード：

       private static void deleteData(Connection conn) throws SQLException {
           String deleteDataSql = "DELETE FROM test_tbl1 WHERE id < ?";
           try (PreparedStatement deleteDataStmt = conn.prepareStatement(deleteDataSql)) {
               deleteDataStmt.setInt(1, 5);
               deleteDataStmt.executeUpdate();
           }
       }
   

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

   特定の条件を満たすデータをデータベース内で更新するためのメソッドを提供します。これは接続オブジェクトをパラメータとして受け取り、プリコンパイルされた方式でデータを更新するSQLステートメントを実行します。具体的な手順は以下のとおりです：

   1. プライベート静的メソッド updateData() を定義し、Connection オブジェクトをパラメータとして受け取ります。メソッドは SQLException 例外をスローする可能性があります。
   2. データを更新するのSQLステートメントをストレージするための文字列変数 updateDataSql を定義します。
   3. conn.prepareStatement(updateDataSql) メソッドを使用して、プリコンパイルされたSQLステートメントを実行するための PreparedStatement オブジェクト updateDataStmt を作成します。
   4. setString() メソッドを使用して、文字列 test_update をSQLステートメントの最初のパラメータ値に設定します。
   5. setInt() メソッドを使用して、SQLステートメントの2番目のパラメータ値として数値 5 を設定します。
   6. 条件を満たすデータをデータベース内で更新するために、executeUpdate() メソッドを呼び出してSQLステートメントを実行します。

   コード：

       private static void updateData(Connection conn) throws SQLException {
           String updateDataSql = "UPDATE test_tbl1 SET name = ? WHERE id = ?";
           try (PreparedStatement updateDataStmt = conn.prepareStatement(updateDataSql)) {
               updateDataStmt.setString(1, "test_update");
               updateDataStmt.setInt(2, 5);
               updateDataStmt.executeUpdate();
           }
       }
   

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

   データベースからデータをクエリして処理するためのメソッドを提供します。接続オブジェクトをパラメータとして受け取り、プリコンパイルされた方式でデータをクエリするSQLステートメントを実行します。具体的な手順は以下のとおりです：

   1. プライベート静的メソッド queryData() を定義し、Connection オブジェクトをパラメータとして受け取ります。メソッドは SQLException 例外をスローする可能性があります。

   2. データをクエリするSQLステートメントをストレージするための文字列変数 queryDataSql を定義します。

   3. conn.prepareStatement(queryDataSql) メソッドを使用して、プリコンパイルされたSQLステートメントを実行するための PreparedStatement オブジェクト queryDataStmt を作成します。

   4. queryDataStmt.executeQuery() メソッドを使用してSQLクエリを実行し、ResultSet オブジェクト rs を使用してクエリ結果を受け取ります。

   5. while ループを使用して、rs.next() メソッドでクエリ結果セットをイテレーション：

      1. getInt() メソッドを使用して、結果セットの中から id という名前の列の整数値を取得し、変数 id に代入します。
      2. getString() メソッドを使用して、結果セットの中から name という名前の列の文字列値を取得し、変数 name に代入します。
      3. クエリ結果の id と name を出力します。

   コード：

       private static void queryData(Connection conn) throws SQLException {
           String queryDataSql = "SELECT * FROM test_tbl1";
           try (PreparedStatement queryDataStmt = conn.prepareStatement(queryDataSql)) {
               try (ResultSet rs = queryDataStmt.executeQuery()) {
                   while (rs.next()) {
                       int id = rs.getInt("id");
                       String name = rs.getString("name");
                       System.out.println("id: " + id + ", name: " + name);
                   }
               }
           }
       }
   

全コード表示

<?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.example</groupId>
    <artifactId>dbcp-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>org.apache.commons</groupId>
            <artifactId>commons-dbcp2</artifactId>
            <version>2.9.0</version>
        </dependency>
    </dependencies>
</project>

# Database Connect Information
driverClassName=com.oceanbase.jdbc.Driver
url=jdbc:oceanbase://$host:$port/$schema_name
username=$user_name
password=$password

# ConnectionPool Parameters
initialSize=30
maxTotal=30
maxIdle=10
minIdle=5
maxWaitMillis=1000
removeAbandonedTimeout=1

removeAbandonedOnMaintenance=true
removeAbandonedOnBorrow=true

package com.example;

import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Properties;

import org.apache.commons.dbcp2.BasicDataSource;
import org.apache.commons.dbcp2.BasicDataSourceFactory;

public class Main {

    public static void main(String[] args) {
        try (BasicDataSource dataSource = createDataSource()) {
            try (Connection conn = dataSource.getConnection()) {
                createTable(conn);
                insertData(conn);
                deleteData(conn);
                updateData(conn);
                queryData(conn);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    
    // Create ConnectionPool
    private static BasicDataSource createDataSource() throws Exception {
        Properties props = new Properties();
        FileInputStream is = new FileInputStream("src/main/resources/db.properties");
        props.load(is);
        
        return BasicDataSourceFactory.createDataSource(props);
    }
    
    // Create table
    private static void createTable(Connection conn) throws SQLException {
        String createTableSql = "CREATE TABLE test_tbl1 (id NUMBER, name VARCHAR2(32))";
        try (PreparedStatement createTableStmt = conn.prepareStatement(createTableSql)) {
            createTableStmt.execute();
        }
    }
    
    // Insert data
    private static void insertData(Connection conn) throws SQLException {
        String insertDataSql = "INSERT INTO test_tbl1 (id, name) VALUES (?, ?)";
        try (PreparedStatement insertDataStmt = conn.prepareStatement(insertDataSql)) {
            for (int i = 0; i < 10; i++) {
                insertDataStmt.setInt(1, i);
                insertDataStmt.setString(2, "test_insert" + i);
                insertDataStmt.executeUpdate();
            }
        }
    }
    
    // Delete data
    private static void deleteData(Connection conn) throws SQLException {
        String deleteDataSql = "DELETE FROM test_tbl1 WHERE id < ?";
        try (PreparedStatement deleteDataStmt = conn.prepareStatement(deleteDataSql)) {
            deleteDataStmt.setInt(1, 5);
            deleteDataStmt.executeUpdate();
        }
    }
    
    // Update data
    private static void updateData(Connection conn) throws SQLException {
        String updateDataSql = "UPDATE test_tbl1 SET name = ? WHERE id = ?";
        try (PreparedStatement updateDataStmt = conn.prepareStatement(updateDataSql)) {
            updateDataStmt.setString(1, "test_update");
            updateDataStmt.setInt(2, 5);
            updateDataStmt.executeUpdate();
        }
    }
    
    // Query data
    private static void queryData(Connection conn) throws SQLException {
        String queryDataSql = "SELECT * FROM test_tbl1";
        try (PreparedStatement queryDataStmt = conn.prepareStatement(queryDataSql)) {
            try (ResultSet rs = queryDataStmt.executeQuery()) {
                while (rs.next()) {
                    int id = rs.getInt("id");
                    String name = rs.getString("name");
                    System.out.println("id: " + id + ", name: " + name);
                }
            }
        }
    }
}

関連ドキュメント

OceanBase Connector/Jの詳細については、OceanBase JDBCドライバーを参照してください。