Druid接続プールによるOceanBaseデータベースへの接続のサンプルプログラム

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

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

Druid接続プールによるOceanBaseデータベースへの接続のサンプルプログラム(Oracleモード)

前提条件

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

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

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

  説明

  このドキュメントでは、Eclipse IDE for Java Developers 2022-03バージョンを使用してコードを実行しますが、個人の好みに応じて、自分に合ったツールを選択してサンプルコードを実行することもできます。

手順

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

ステップ１：druid-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権限と、該当するスキーマに対するCREATE TABLE、DROP 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：druid-oceanbase-clientプロジェクトのデータベース接続情報を修正する

ステップ2：OceanBaseデータベースのURLを取得するで取得した情報に基づいて、druid-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 のユーザー名です。
• パスワードは ****** です。

コード：

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

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

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

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

   

3. Eclipseのコンソールウィンドウで出力結果を確認します。

   

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

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

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

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

   コード：

       <groupId>com.example</groupId>
       <artifactId>druid-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 依存ライブラリを追加します：

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

      説明

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

      コード：

              <dependency>
                  <groupId>com.oceanbase</groupId>
                  <artifactId>oceanbase-client</artifactId>
                  <version>2.4.2</version>
              </dependency>
      

   2. druid 依存ライブラリを追加します：

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

      コード：

              <dependency>
                  <groupId>com.alibaba</groupId>
                  <artifactId>druid</artifactId>
                  <version>1.2.8</version>
              </dependency>
      

db.propertiesコードの紹介

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

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

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

   1. データベースドライバープログラムのクラス名を com.oceanbase.jdbc.Driver と指定します。
   2. ホストIPアドレス、ポート番号、アクセスするSchemaを含むデータベース接続のURLを指定します。
   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：アクセスするSchemaの名前です。
   • $user_name：テナントの接続アカウント。ODP接続の一般的な形式：ユーザー名@テナント名#クラスタ名 または クラスタ名:テナント名:ユーザー名。直接接続方式の形式：ユーザー名@テナント名。
   • $password：アカウントのパスワード。

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

   1. 接続検証用のSQLステートメント select 1 from dual を指定します。
   2. 接続プールの初期接続数を3に指定します。これは、接続プール起動時に3つの初期接続が作成されることを意味します。
   3. 接続プールの最大アクティブ接続数を30に指定します。これは、接続プール内に同時に最大30個の接続が存在できることを意味します。
   4. 廃棄された接続のログ出力を true に指定します。これは、廃棄された接続を回収する際、エラーログに出力されるようにすることを意味します。テスト環境では true に設定し、本番環境では false に設定することで、パフォーマンスへの影響を回避できます。
   5. 接続プールの最小アイドル接続数を5に指定します。これは、接続プール内のアイドル接続数が5未満の場合、接続プールが自動的に新しい接続を作成することを意味します。
   6. 接続取得時の最大待機時間を1000に指定します。単位はミリ秒です。これは、接続プール内の接続がすべて使用されている場合、かつ待機時間が1000ミリ秒を超えた場合、接続取得操作でタイムアウト例外がスローされることを意味します。
   7. 接続がアイドル状態にあるときの最小保持時間を300000に指定します。単位はミリ秒です。これは、接続が300000ミリ秒（5分）アイドル状態で使用されない場合、回収されることを意味します。
   8. 廃棄された接続の回収を true に指定します。これは、接続が removeAbandonedTimeout で定義された時間以上経過した場合、回収されるようにすることを意味します。
   9. 廃棄された接続のタイムアウト時間を300に指定します。単位は秒です。これは、300秒（5分）以上使用されない接続が回収されることを意味します。
   10. アイドル接続回収スレッドの実行間隔時間を10000に指定します。単位はミリ秒です。これは、10000ミリ秒（10秒ごとに）、アイドル接続回収スレッドがアイドル接続の回収操作を実行することを意味します。
   11. 接続取得時に接続の可用性を検証するかどうかを false に指定します。false に設定することでパフォーマンス向上が可能ですが、取得した接続が利用できない可能性もあります。
   12. 接続返却時に接続の可用性を検証するかどうかを false に指定します。false に設定することでパフォーマンス向上が可能ですが、返却された接続が利用できない可能性もあります。
   13. 接続がアイドル状態にあるときに検証を行うかどうかを true に指定します。true の場合、接続プールは定期的に validationQuery を実行して接続の可用性を検証します。
   14. 長時間接続の保活機能を有効にするかどうかを false に指定します。false に設定すると、長時間接続の保活機能は無効になります。
   15. 接続のアイドル時間のしきい値を60000に指定します。単位はミリ秒です。これは、接続のアイドル時間が設定されたしきい値60000ミリ秒（つまり1分）を超えた場合、接続保活メカニズムがその接続を検出し、接続の可用性を確保することを意味します。接続がしきい値内に何らかの操作があった場合、接続のアイドル時間は再計算されます。

   コード：

   validationQuery=select 1 from dual
   initialSize=3
   maxActive=30
   logAbandoned=true
   minIdle=5
   maxWait=1000
   minEvictableIdleTimeMillis=300000
   removeAbandoned=true
   removeAbandonedTimeout=300
   timeBetweenEvictionRunsMillis=10000
   testOnBorrow=false
   testOnReturn=false
   testWhileIdle=true
   keepAlive=false
   keepAliveBetweenTimeMillis=60000
   

Druid接続プールの一般的な構成パラメータ：

Main.javaコードの紹介

Main.java ファイルは本記事のサンプルプログラムのメインプログラムであり、このサンプルを通じて、データソース、接続オブジェクト、およびさまざまなデータベース操作メソッドを使用してデータベースとインタラクションする方法を学ぶことができます。

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

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

   1. 現在のコードが属するパッケージ名を com.example として宣言します。
   2. Java の IOException クラスをインポートし、入出力例外を処理するために使用します。
   3. Java の InputStream クラスをインポートし、ファイルやその他のソースから入力ストリームを取得するために使用します。
   4. Java の Connection インターフェースをインポートし、データベースへの接続を表すために使用します。
   5. Java の ResultSet インターフェースをインポートし、データベースクエリ結果のデータセットを表すために使用します。
   6. Java の SQLException クラスをインポートし、SQL 例外を処理するために使用します。
   7. Java の Statement インターフェースをインポートし、SQL ステートメントを実行するために使用します。
   8. Java の PreparedStatement インターフェースをインポートし、プリコンパイルされた SQL ステートメントを処理するために使用します。
   9. Java の Properties クラスをインポートし、プロパティファイルを処理するために使用します。
   10. Java の DataSource インターフェースをインポートし、データベース接続を管理するために使用します。
   11. Alibaba Druid 接続プールの DruidDataSourceFactory クラスをインポートし、Druid データソースを作成するために使用します。

   コード：

   package com.example;
   
   import java.io.IOException;
   import java.io.InputStream;
   import java.sql.Connection;
   import java.sql.ResultSet;
   import java.sql.SQLException;
   import java.sql.Statement;
   import java.sql.PreparedStatement;
   import java.util.Properties;
   import javax.sql.DataSource;
   import com.alibaba.druid.pool.DruidDataSourceFactory;
   

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

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

   1. プログラムのエントリポイントとして、Main という名前のパブリッククラスを定義します。クラス名はファイル名と一致させる必要があります。

   2. プログラムのエントリポイントとして、パブリック静的メソッド main を定義します。コマンドライン引数を受け取ります。

   3. 例外処理機構を使用して、発生する可能性のある例外をキャッチして処理します。

   4. loadPropertiesFile メソッドを呼び出して、プロパティファイルをロードし、Properties オブジェクトを返します。

   5. createDataSource() メソッドを呼び出して、プロパティファイル内の設定に基づいてデータソースオブジェクトを作成します。

   6. try-with-resources ステートメントを使用して、データベース接続を取得し、接続使用後に自動的に接続を閉じます。

      1. createTable() メソッドを呼び出して、テーブルを作成します。
      2. insertData() メソッドを呼び出して、データを挿入します。
      3. selectData() メソッドを呼び出して、データをクエリします。
      4. updateData() メソッドを呼び出して、データを更新します。
      5. 再び selectData() メソッドを呼び出して、更新後のデータをクエリします。
      6. deleteData() メソッドを呼び出して、データを削除します。
      7. 再び selectData() メソッドを呼び出して、削除後のデータをクエリします。
      8. dropTable() メソッドを呼び出して、テーブルを削除します。

   コード：

   public class Main {
   
       public static void main(String[] args) {
           try {
               Properties properties = loadPropertiesFile();
               DataSource dataSource = createDataSource(properties);
               try (Connection conn = dataSource.getConnection()) {
                   // Create table
                   createTable(conn);
                   // Insert data
                   insertData(conn);
                   // Query data
                   selectData(conn);
   
                   // Update data
                   updateData(conn);
                   // Query the updated data
                   selectData(conn);
   
                   // Delete data
                   deleteData(conn);
                   // Query the data after deletion
                   selectData(conn);
   
                   // Drop table
                   dropTable(conn);
               }
           } catch (Exception e) {
               e.printStackTrace();
           }
       }
   
       // プロパティファイル内の設定情報を取得および使用するためのメソッドを定義します
       // データソースオブジェクトを取得するためのメソッドを定義します
       // テーブルを作成するためのメソッドを定義します
       // データを挿入するためのメソッドを定義します
       // データを更新するためのメソッドを定義します
       // データを削除するためのメソッドを定義します
       // データをクエリするためのメソッドを定義します
       // テーブルを削除するためのメソッドを定義します
   }
   

3. プロパティファイル内の設定情報を取得および使用するためのメソッドを定義します。

   プライベート静的メソッド loadPropertiesFile() を定義し、プロパティファイルをロードして Properties オブジェクトを返します。具体的な手順は以下のとおりです：

   1. プライベート静的メソッド loadPropertiesFile() を定義し、Properties オブジェクトを返し、IOException 例外がスローされる可能性があることを宣言します。
   2. Properties オブジェクトを作成し、プロパティファイル内のキー値対を格納するために使用します。
   3. try-with-resources ステートメントを使用して、クラスローダーを使用してプロパティファイル db.properties の入力ストリーム is を取得します。
   4. load メソッドを使用して、入力ストリーム内のプロパティを properties オブジェクトにロードします。
   5. ロード済みの properties オブジェクトを返します。

   コード：

       private static Properties loadPropertiesFile() throws IOException {
           Properties properties = new Properties();
           try (InputStream is = Main.class.getClassLoader().getResourceAsStream("db.properties")) {
               properties.load(is);
           }
           return properties;
       }
   

4. データソースオブジェクトを取得するためのメソッドを定義します。

   プライベート静的メソッド createDataSource() を定義し、プロパティファイル内の設定に基づいて DataSource オブジェクトを作成します。データベース接続を管理および取得するために使用します。具体的な手順は以下のとおりです：

   1. プライベート静的メソッド createDataSource() を定義し、Properties オブジェクトをパラメータとして受け取り、Exception 例外がスローされる可能性があることを宣言します。
   2. DruidDataSourceFactory クラスの createDataSource() メソッドを呼び出し、プロパティ properties を渡して、DataSource オブジェクトを返します。

   コード：

       private static DataSource createDataSource(Properties properties) throws Exception {
           return DruidDataSourceFactory.createDataSource(properties);
       }
   

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

   プライベート静的メソッド createTable() を定義し、データベース内にデータテーブルを作成します。具体的な手順は以下のとおりです：

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

   コード：

       private static void createTable(Connection conn) throws SQLException {
           try (Statement stmt = conn.createStatement()) {
               String sql = "CREATE TABLE test_druid (id NUMBER, name VARCHAR2(20))";
               stmt.executeUpdate(sql);
               System.out.println("Table created successfully.");
           }
       }
   

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

   プライベート静的メソッド insertData() を定義し、データベースにデータを挿入します。具体的な手順は以下のとおりです：

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

   2. 文字列変数 insertDataSql を定義し、データ挿入の SQL ステートメントを格納します。

   3. 整数変数 insertedRows を定義し、初期値を 0 とし、挿入データの行数を記録するために使用します。

   4. try-with-resources ステートメントを使用して、接続オブジェクト conn の prepareStatement() メソッドとデータ挿入の SQL ステートメントを使用して、PreparedStatement オブジェクト insertDataStmt を作成します。

   5. for ループステートメントを使用して、5 回繰り返し、5 件のデータを挿入することを示します。

      1. setInt() メソッドを使用して、最初のパラメータの値をループ変数 i に設定します。
      2. setString() メソッドを使用して、2 番目のパラメータの値を文字列 test_insert とループ変数 i の値を連結した文字列に設定します。
      3. executeUpdate() メソッドを使用してデータ挿入の SQL ステートメントを実行し、戻り値の操作行数を insertedRows 変数に累積します。

   6. データ挿入に成功したというメッセージと、挿入された総行数を出力します。

   7. 挿入された総行数を返します。

   コード：

       private static int insertData(Connection conn) throws SQLException {
           String insertDataSql = "INSERT INTO test_druid (id, name) VALUES (?, ?)";
           int insertedRows = 0;
           try (PreparedStatement insertDataStmt = conn.prepareStatement(insertDataSql)) {
               for (int i = 1; i < 6; i++) {
                   insertDataStmt.setInt(1, i);
                   insertDataStmt.setString(2, "test_insert" + i);
                   insertedRows += insertDataStmt.executeUpdate();
               }
               System.out.println("Data inserted successfully. Inserted rows: " + insertedRows);
           }
           return insertedRows;
       }
   

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

   プライベート静的メソッド updateData() を定義し、データベース内のデータを更新します。具体的な手順は以下のとおりです：

   1. プライベート静的メソッド updateData() を定義し、Connection オブジェクトをパラメータとして受け取り、SQLException 例外がスローされる可能性があることを宣言します。
   2. try-with-resources ステートメントを使用して、接続オブジェクト conn の prepareStatement() メソッドとデータ更新の SQL ステートメントを使用して、PreparedStatement オブジェクト pstmt を作成します。
   3. setString() メソッドを使用して、最初のパラメータの値を文字列 test_update に設定します。
   4. setInt() メソッドを使用して、2 番目のパラメータの値を整数値 3 に設定します。
   5. executeUpdate() メソッドを使用してデータ更新の SQL ステートメントを実行し、戻り値の操作行数を updatedRows 変数に代入します。
   6. データ更新に成功したというメッセージと、更新された総行数を出力します。

   コード：

       private static void updateData(Connection conn) throws SQLException {
           try (PreparedStatement pstmt = conn.prepareStatement("UPDATE test_druid SET name = ? WHERE id = ?")) {
               pstmt.setString(1, "test_update");
               pstmt.setInt(2, 3);
               int updatedRows = pstmt.executeUpdate();
               System.out.println("Data updated successfully. Updated rows: " + updatedRows);
           }
       }
   

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

   プライベート静的メソッド deleteData() を定義し、データベース内のデータを削除します。具体的な手順は以下のとおりです：

   1. プライベート静的メソッド deleteData() を定義し、Connection オブジェクトをパラメータとして受け取り、SQLException 例外がスローされる可能性があることを宣言します。
   2. try-with-resources ステートメントを使用して、接続オブジェクト conn の prepareStatement() メソッドとデータ削除の SQL ステートメントを使用して、PreparedStatement オブジェクト pstmt を作成します。
   3. setInt() メソッドを使用して、最初のパラメータの値を整数値 3 に設定します。
   4. executeUpdate() メソッドを使用してデータ削除の SQL ステートメントを実行し、戻り値の操作行数を deletedRows 変数に代入します。
   5. データ削除に成功したというメッセージと、削除された総行数を出力します。

   コード：

       private static void deleteData(Connection conn) throws SQLException {
           try (PreparedStatement pstmt = conn.prepareStatement("DELETE FROM test_druid WHERE id < ?")) {
               pstmt.setInt(1, 3);
               int deletedRows = pstmt.executeUpdate();
               System.out.println("Data deleted successfully. Deleted rows: " + deletedRows);
           }
       }
   

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

   プライベート静的メソッド selectData() を定義し、データベースからデータをクエリします。具体的な手順は以下のとおりです：

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

   2. try-with-resources ステートメントを使用して、接続オブジェクト conn の createStatement() メソッドを使用して、Statement オブジェクト stmt を作成します。

   3. 文字列変数 sql を定義し、データクエリの SQL ステートメントを格納します。

   4. executeQuery() メソッドを使用してデータクエリの SQL ステートメントを実行し、戻り値の結果セットを resultSet 変数に代入します。

   5. while ループステートメントを使用して、結果セット内の各行データをイテレーションします。

      1. getInt() メソッドを使用して、現在行の id フィールドの整数値を取得し、id 変数に代入します。
      2. getString() メソッドを使用して、現在行の name フィールドの文字列値を取得し、name 変数に代入します。
      3. 現在行の id および name フィールドの値を出力します。

   コード：

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

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

    プライベート静的メソッド dropTable() を定義し、データベース内のテーブルを削除します。具体的な手順は以下のとおりです：

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

    コード：

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

全コード表示

<?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>druid-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>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>1.2.8</version>
        </dependency>
    </dependencies>
</project>

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

# Connection Pool Configuration
#To check whether the database link is valid, MySQL must be configured to select 1; Oracle is select 1 from dual
validationQuery=select 1 from dual
#Initial number of connections
initialSize=3
#Maximum number of activations, that is, the maximum number of Connection pool
maxActive=30
#When closing the Abandoned connection, the error log is output. When the link is recycled, the console prints information. The test environment can add true, while the online environment is false. Will affect performance.
logAbandoned=true
#Minimum number of activations during idle time
minIdle=5
#The maximum waiting time for a connection, in milliseconds
maxWait=1000
#The maximum time to start the eviction thread is the survival time of a link (previous value: 25200000, the converted result of this time is: 2520000/1000/60/60=7 hours)
minEvictableIdleTimeMillis=300000
#Whether to recycle after exceeding the time limit
removeAbandoned=true
#Exceeding the time limit (in seconds), currently 5 minutes. If any business processing time exceeds 5 minutes, it can be adjusted appropriately.
removeAbandonedTimeout=300
# Run the idle connection collector Destroy thread every 10 seconds to detect the interval time between connections, based on the judgment of testWhileIdle
timeBetweenEvictionRunsMillis=10000
#When obtaining a link, not verifying its availability can affect performance.
testOnBorrow=false
#Check whether the link is available when returning the link to the Connection pool.
testOnReturn=false
#This configuration can be set to true, without affecting performance and ensuring security. The meaning is: Detect when applying for a connection. If the idle time is greater than timeBetweenEviceRunsMillis, execute validationQuery to check if the connection is valid.
testWhileIdle=true
#Default false, if configured as true, connection detection will be performed in the DestroyConnectionThread thread (timeBetweenEvaluation once)
keepAlive=false
#If keepAlive rule takes effect and the idle time of the connection exceeds it, the connection will only be detected
keepAliveBetweenTimeMillis=60000

package com.example;

import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.PreparedStatement;
import java.util.Properties;
import javax.sql.DataSource;
import com.alibaba.druid.pool.DruidDataSourceFactory;

public class Main {

    public static void main(String[] args) {
        try {
            Properties properties = loadPropertiesFile();
            DataSource dataSource = createDataSource(properties);
            try (Connection conn = dataSource.getConnection()) {
                // Create table
                createTable(conn);
                // Insert data
                insertData(conn);
                // Query data
                selectData(conn);

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

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

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

    private static Properties loadPropertiesFile() throws IOException {
        Properties properties = new Properties();
        try (InputStream is = Main.class.getClassLoader().getResourceAsStream("db.properties")) {
            properties.load(is);
        }
        return properties;
    }

    private static DataSource createDataSource(Properties properties) throws Exception {
        return DruidDataSourceFactory.createDataSource(properties);
    }

    private static void createTable(Connection conn) throws SQLException {
        try (Statement stmt = conn.createStatement()) {
            String sql = "CREATE TABLE test_druid (id NUMBER, name VARCHAR2(20))";
            stmt.executeUpdate(sql);
            System.out.println("Table created successfully.");
        }
    }

    private static int insertData(Connection conn) throws SQLException {
        String insertDataSql = "INSERT INTO test_druid (id, name) VALUES (?, ?)";
        int insertedRows = 0;
        try (PreparedStatement insertDataStmt = conn.prepareStatement(insertDataSql)) {
            for (int i = 1; i < 6; i++) {
                insertDataStmt.setInt(1, i);
                insertDataStmt.setString(2, "test_insert" + i);
                insertedRows += insertDataStmt.executeUpdate();
            }
            System.out.println("Data inserted successfully. Inserted rows: " + insertedRows);
        }
        return insertedRows;
    }

    private static void updateData(Connection conn) throws SQLException {
        try (PreparedStatement pstmt = conn.prepareStatement("UPDATE test_druid SET name = ? WHERE id = ?")) {
            pstmt.setString(1, "test_update");
            pstmt.setInt(2, 3);
            int updatedRows = pstmt.executeUpdate();
            System.out.println("Data updated successfully. Updated rows: " + updatedRows);
        }
    }

    private static void deleteData(Connection conn) throws SQLException {
        try (PreparedStatement pstmt = conn.prepareStatement("DELETE FROM test_druid WHERE id < ?")) {
            pstmt.setInt(1, 3);
            int deletedRows = pstmt.executeUpdate();
            System.out.println("Data deleted successfully. Deleted rows: " + deletedRows);
        }
    }

    private static void selectData(Connection conn) throws SQLException {
        try (Statement stmt = conn.createStatement()) {
            String sql = "SELECT * FROM test_druid";
            ResultSet resultSet = stmt.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 conn) throws SQLException {
        try (Statement stmt = conn.createStatement()) {
            String sql = "DROP TABLE test_druid";
            stmt.executeUpdate(sql);
            System.out.println("Table dropped successfully.");
        }
    }
}

参照ドキュメント

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