Druid接続プールでOceanBaseデータベースに接続するサンプルプログラム|OceanBase Cloud|ドキュメント|分散データベース

Druid接続プールでOceanBaseデータベースに接続するサンプルプログラム

最終更新日：2026-06-08 08:05:36 更新

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

druid-mysql-client サンプルプロジェクトをダウンロード

Druid接続プールでOceanBaseデータベースに接続するサンプルプログラム（MySQLモード）

前提条件

OB Cloudデータベースアカウントに登録し、クラスタインスタンスとOB Cloud MySQLモードのテナントを作成していること。詳細については、クラスタインスタンスの作成およびテナントの作成を参照してください。
対象のMySQL互換モードテナントの接続文字列を取得済みであること。詳細な操作については、接続文字列の取得を参照してください。
JDK 1.8とMavenをインストール済みであること。
Eclipseをインストール済みであること。

説明

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

手順

説明

ここで説明する手順は、Windows環境でEclipse IDE for Java Developers 2022-03を使用してこのプロジェクトをコンパイルおよび実行する場合のものです。他のOS環境やコンパイラを使用する場合は、手順が若干異なる可能性があります。

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

Eclipseを開き、メニューバーからFile->Open Projects from File Systemを選択します。
ポップアップダイアログで、Directoryボタンをクリックしてプロジェクトのディレクトリを選択し、Finishをクリックしてインポートを完了します。

説明

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

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

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

例：

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

コード：

...
url=jdbc:mysql://t5******.********.oceanbase.cloud:3306/test?useSSL=false
username=test_user001
password=******
...

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

プロジェクトナビゲータービューで、druid-mysql-client/src/main/javaディレクトリを見つけて展開します。
Main.javaファイルを右クリックし、Run As->Java Applicationを選択します。
Eclipseのコンソールウィンドウで出力結果を確認します。

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

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

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

druid-mysql-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ファイルのコードは、主に以下の部分で構成されています：

ファイル宣言ステートメント。

このファイルがXMLファイルであり、使用するXMLバージョンが1.0、文字エンコーディング方式がUTF-8であることを宣言します。

コード：
```
<?xml version="1.0" encoding="UTF-8"?>
```
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>
```
基本情報の設定。
1. <groupId>を使用して、プロジェクトが属する組織をcom.exampleと指定します。
2. <artifactId>を使用して、プロジェクトの名前をdruid-mysql-clientと指定します。
3. <version>を使用して、プロジェクトのバージョン番号を1.0-SNAPSHOTと指定します。
コード：
```
    <groupId>com.example</groupId>
    <artifactId>druid-mysql-client</artifactId>
    <version>1.0-SNAPSHOT</version>
```
プロジェクトソースファイルのプロパティ設定。

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>
```
プロジェクトが依存するコンポーネントの設定。
1. データベースとのやり取りを行うために、mysql-connector-java依存ライブラリを追加します：
  1. <groupId>を使用して、依存関係が属する組織をmysqlと指定します。
  2. <artifactId>を使用して、依存関係の名前をmysql-connector-javaと指定します。
  3. <version>を使用して、依存関係のバージョン番号を5.1.40と指定します。
  コード：
```
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.40</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. データベースドライバーのクラス名を com.mysql.jdbc.Driver と指定します。
2. データベース接続のURLを指定します。これには、ホストIPアドレス、ポート番号、アクセスするスキーマが含まれます。
3. データベースのユーザー名を指定します。
4. データベースのパスワードを指定します。
コード：
```
driverClassName=com.mysql.jdbc.Driver
url=jdbc:oceanbase://$host:$port/$database_name?useSSL=false
username=$user_name
password=$password
```
パラメータの説明：
- $host：接続文字列から -h パラメータを取得したもので、OB Cloudデータベースの接続アドレスです。
- $port：接続文字列から -P パラメータを取得したもので、OB Cloudデータベースの接続ポートです。
- $database_name：接続文字列から -D パラメータを取得したもので、アクセスするデータベースの名前です。
- $user_name：接続文字列から -u パラメータを取得したもので、アカウント名です。
- $password：接続文字列から -p パラメータを取得したもので、アカウントのパスワードです。
その他の接続プールパラメータの設定
1. 接続検証用のSQLステートメントとして select 1 を指定します。
2. 接続プールの初期接続数を3に設定します。これは、接続プール起動時に3つの初期接続が作成されることを意味します。
3. 接続プールの最大アクティブ接続数を30に設定します。これは、接続プール内に同時に最大30個の接続が存在できることを意味します。
4. 無効な接続のログを出力するかどうかを true で指定します。これは、無効な接続が回収される際にエラーログに情報が出力されることを意味します。テスト環境では true に設定し、本番環境ではパフォーマンスへの影響を避けるために false に設定できます。
5. 接続プールの最小アイドル接続数を5に設定します。これは、接続プール内のアイドル接続数が5未満になると、接続プールが自動的に新しい接続を作成することを意味します。
6. 接続取得時の最大待機時間を1000ミリ秒に設定します。これは、接続プール内のすべての接続が使用中で、待機時間が1000ミリ秒を超えると、接続取得操作でタイムアウト例外がスローされることを意味します。
7. 接続のアイドル状態での最小保持時間を300000ミリ秒（5分）に設定します。これは、接続が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
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接続プールの一般的な設定パラメータ：

パラメータ	説明
url	データベースのURLを指定します。データベースの種類、ホスト名、ポート番号、データベース名などの情報が含まれます。
username	データベース接続に必要なユーザー名を指定します。
password	データベース接続に必要なパスワードを指定します。
driverClassName	データベースドライバーのクラス名を指定します。`driverClassName` を明示的に設定しない場合、Druid接続プールは `url` からデータベースの種類 (dbType) を自動的に認識し、対応する `driverClassName` を選択します。この自動認識メカニズムにより、設定作業が軽減され、設定プロセスが簡素化されます。ただし、`url` が正しく解析できない場合や、非標準のデータベースドライバークラスを使用する必要がある場合は、正しいドライバークラスがロードされるように、`driverClassName` パラメータを明示的に設定する必要があります。
initialSize	接続プールの初期化時に作成する接続数を指定します。アプリケーション起動時、接続プールは指定された数の接続を作成して接続プールに格納します。
maxActive	接続プール内の最大アクティブ接続数を指定します。接続プールのアクティブ接続数が最大値に達すると、その後の接続要求は、接続が解放されるまで待機します。
maxIdle	接続プール内の最大アイドル接続数を指定します (このプロパティは非推奨です)。接続プールのアイドル接続数が最大値に達すると、余分な接続は閉じられます。
minIdle	接続プール内の最小アイドル接続数を指定します。接続プールのアイドル接続数が最小値を下回ると、接続プールは新しい接続を作成します。
maxWait	接続取得の最大待機時間を指定します。この時間を超えると例外がスローされます。正の数値に設定した場合、それは待機するミリ秒数を表し、この時間を超えると例外がスローされます。
poolPreparedStatements	`PreparedStatement` のキャッシュ (PSCache) メカニズムを有効にするかどうかを指定します。`true` に設定すると、`PreparedStatement` オブジェクトがキャッシュされてパフォーマンスが向上しますが、OBProxyのメモリ使用量が継続的に増加する可能性があるため注意が必要です。このようなシナリオでは、メモリリークやメモリオーバーフローを避けるために、メモリ使用状況を適切に設定および監視する必要があります。
validationQuery	接続検証用のSQLクエリステートメントを指定します。接続が接続プールから取得される際、このクエリステートメントが実行され、接続が有効かどうかが検証されます。
timeBetweenEvictionRunsMillis	接続プールがアイドル接続を検出する間隔時間をミリ秒単位で指定します。接続のアイドル時間が `timeBetweenEvictionRunsMillis` の設定値を超えると、接続は閉じられます。
minEvictableIdleTimeMillis	接続プール内の接続の最小アイドル時間をミリ秒単位で指定します。この時間を超えると接続は回収されます。負の数値に設定した場合、接続は回収されません。
testWhileIdle	アイドル状態の接続をテストするかどうかを指定します。`true` に設定すると、接続がアイドル状態のときに `validationQuery` が実行され、接続が有効かどうかが検証されます。
testOnBorrow	接続を取得する際に接続をテストするかどうかを指定します。`true` に設定すると、接続を取得する際に `validationQuery` が実行され、接続が有効かどうかが検証されます。
testOnReturn	接続を返却する際に接続をテストするかどうかを指定します。`true` に設定すると、接続を返却する際に `validationQuery` が実行され、接続が有効かどうかが検証されます。
filters	接続プール内で事前定義された一連のフィルターを指定します。これらのフィルターは、特定の順序で接続に対する事前処理および後処理操作を行い、追加機能を提供し、接続プールのパフォーマンスを向上させることができます。一般的なフィルターには以下のものがあります： `stat`：接続プールのパフォーマンス指標を統計するために使用されます。例えば、アクティブ接続数、リクエスト数、エラー数などです。 `wall`：SQLファイアウォールとして使用され、安全でないSQLステートメントを遮断・無効化することで、データベースのセキュリティを向上させます。 `log4j`：接続プールのログを `log4j` に出力するために使用され、ログ記録とデバッグを容易にします。 `slf4j`：接続プールのログを `slf4j` に出力するために使用され、ログ記録とデバッグを容易にします。 `config`：外部設定ファイルから接続プールの設定情報を読み込むために使用されます。 `encoding`：接続プールとデータベース間の文字エンコーディングを設定するために使用されます。これらのフィルターを `filters` プロパティに設定することで、接続プールは指定された順序でこれらのフィルターを順次適用します。複数のフィルター名はカンマで区切ることができます。例：`filters=stat,wall,log4j`。

Main.javaコードの紹介

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

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

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

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

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

プログラムのエントリポイントとして、Main という名前のpublicクラスを定義します。クラス名はファイル名と一致させる必要があります。
プログラムのエントリポイントとして、コマンドライン引数を受け取るpublic staticメソッド main を定義します。
例外処理メカニズムを使用して、発生する可能性のある例外をキャッチし、処理します。
loadPropertiesFile メソッドを呼び出して、プロパティファイルを読み込み、Properties オブジェクトを返します。
プロパティファイルの設定に基づいて、createDataSource() メソッドを呼び出して、データソースオブジェクトを作成します。
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();
        }
    }

    // プロパティファイル内の設定情報を取得し、使用するためのメソッドを定義する
    // データソースオブジェクトを取得するためのメソッドを定義する
    // テーブルを作成するためのメソッドを定義する
    // データを挿入するためのメソッドを定義する
    // データを更新するためのメソッドを定義する
    // データを削除するためのメソッドを定義する
    // データをクエリするためのメソッドを定義する
    // テーブルを削除するためのメソッドを定義する
}

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

プライベート静的メソッド 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;
    }
```
データソースオブジェクトを取得するためのメソッドを定義します。

プライベート静的メソッド createDataSource() を定義します。これは、プロパティファイルの設定に基づいて DataSource オブジェクトを作成し、データベース接続の管理と取得に使用されます。具体的な手順は以下のとおりです：
1. プライベート静的メソッド createDataSource() を定義します。このメソッドは Properties オブジェクトをパラメータとして受け取り、Exception 例外をスローする可能性があることを宣言します。
2. DruidDataSourceFactory クラスの createDataSource() メソッドを呼び出し、プロパティ properties を渡して、DataSource オブジェクトを返します。
コード：
```
    private static DataSource createDataSource(Properties properties) throws Exception {
        return DruidDataSourceFactory.createDataSource(properties);
    }
```
テーブルを作成するためのメソッドを定義します。

プライベート静的メソッド 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 INT, name VARCHAR(20))";
            stmt.executeUpdate(sql);
            System.out.println("Table created successfully.");
        }
    }
```
データを挿入するためのメソッドを定義します。

プライベート静的メソッド 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;
    }
```
データを更新するためのメソッドを定義します。

プライベート静的メソッド 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);
        }
    }
```
データを削除するためのメソッドを定義します。

プライベート静的メソッド 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);
        }
    }
```
データをクエリするためのメソッドを定義します。

プライベート静的メソッド 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);
            }
        }
    }
```
テーブルを削除するためのメソッドを定義します。

プライベート静的メソッド 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.");
        }
    }
```

全コード表示

pom.xml

db.properties

Main.java

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

# Database Configuration
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://$host:$port/$database_name?useSSL=false
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
#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 INT, name VARCHAR(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

顧客事例