Druid コネクションプールを使用して OceanBase データベースに接続するサンプルプログラム

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

      druid-mysql-clientをクリックして サンプルプロジェクトをダウンロード
  </a>
  <!-- <a role='video' href='https://obbusiness-private.oss-cn-shanghai.aliyuncs.com/video-center/video/video/06%20druid-mysql-client.mp4'>

前提条件

• OceanBase Cloud クラウドデータベースアカウントを登録し、クラスタインスタンスと OceanBase Cloud MySQLテナントを作成していること。詳細は、クラスタインスタンスの作成およびテナントの作成をご参照ください。

• 対象の MySQL互換モード テナントの接続文字列を取得していること。詳細な操作については、接続文字列の取得をご参照ください。

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

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

  説明

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

操作手順

<main id="notice" type='explain'>
<h4>説明</h4>
<p>本ドキュメントに記載されている操作手順は、Windows 環境で Eclipse IDE for Java Developers 2022-03 を使用してプロジェクトをコンパイルおよび実行する手順です。他のオペレーティングシステム環境やコンパイラを使用している場合、操作手順が若干異なる場合があります。</p>
</main>

操作手順 1：druid-mysql-client プロジェクトを Eclipse にインポートする

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

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

   説明

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

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

操作手順 2：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=******
...

操作手順 3：druid-mysql-client プロジェクトを実行する

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

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

3. 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 ファイルのコードは、主に以下のセクションで構成されています。

1. ファイル宣言文。

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

コードは以下のとおりです。

```java
<?xml version="1.0" encoding="UTF-8"?>
```

2. POM の名前空間と POM モデルバージョンを設定します。

3. xmlns を使用して、POM の名前空間を http://maven.apache.org/POM/4.0.0。`と指定します。 に指定します。

4. xmlns:xsi を使用して、XML 名前空間を http://www.w3.org/2001/XMLSchema-instance。`と指定します。 に指定します。

5. xsi:schemaLocation を使用して、POM の名前空間を http://maven.apache.org/POM/4.0.0 に、POM の XSD ファイルの場所を http://maven.apache.org/xsd/maven-4.0.0.xsd に指定します。

6. <modelVersion> 要素を使用して、この POM ファイルで使用される POM モデルバージョンを 4.0.0 に指定します。

コードは以下のとおりです。

```java
<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. 基本情報を設定します。

4. <groupId> を使用して、プロジェクトが属する組織を com.example に指定します。

5. <artifactId> を使用して、プロジェクト名を druid-mysql-client に指定します。

6. <version> を使用して、プロジェクトのバージョン番号を 1.0-SNAPSHOT に指定します。

コードは以下のとおりです。

```java
    <groupId>com.example</groupId>
    <artifactId>druid-mysql-client</artifactId>
    <version>1.0-SNAPSHOT</version>
```

4. プロジェクトソースファイルのプロパティを設定します。

Maven のコンパイラプラグインを maven-compiler-plugin に指定し、ソースコードとターゲット Java バージョンの両方を 8 に設定します。これは、プロジェクトのソースコードが Java 8 の機能を使用して記述され、コンパイルされたバイトコードも Java 8 ランタイム環境と互換性があることを意味します。この設定により、プロジェクトのコンパイル時および実行時に Java 8 の構文と機能を正しく処理できるようになります。

<main id="notice" type='explain'>
<h4>説明</h4>
<p>Java 1.8 と Java 8 は、同じバージョンの異なる命名方法です。</p>
</main>

コードは以下のとおりです。

```java
    <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. プロジェクトが依存するコンポーネントを設定します。

6. データベースと対話するために、mysql-connector-java 依存ライブラリを追加します。

7. <groupId> を使用して、依存関係が属する組織を mysql に指定します。

8. <artifactId> を使用して、依存関係の名前を mysql-connector-java に指定します。

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

コードは以下のとおりです。

    ```java
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>5.1.40</version>
            </dependency>
    ```

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

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

4. <artifactId> を使用して、依存関係の名前を druid に指定します。

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

コードは以下のとおりです。

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

db.properties 代码介绍

db.properties は、本ドキュメントのサンプルのコネクションプール設定ファイルであり、コネクションプールの設定プロパティが含まれています。これらのプロパティには、データベース URL、ユーザー名、パスワード、およびコネクションプールのその他のオプションが含まれます。

本ドキュメントの db.properties ファイルのコードは、主に以下のセクションで構成されています。

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

2. データベースドライバのクラス名を com.mysql.jdbc.Driver に指定します。

3. ホスト IP、ポート番号、アクセスするスキーマを含む、データベース接続の URL を指定します。

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

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

コードは以下のとおりです。

```java
driverClassName=com.mysql.jdbc.Driver
url=jdbc:oceanbase://$host:$port/$database_name?useSSL=false
username=$user_name
password=$password
```

パラメータの説明：

* `$host`：接続文字列の `-h` パラメータから取得した、OceanBase Cloud クラウドデータベースの接続アドレス。
* `$port`：接続文字列の `-P` パラメータから取得した、OceanBase Cloud クラウドデータベースの接続ポート。
* `$database_name`：接続文字列の `-D` パラメータから取得した、アクセスするデータベース名。
* `$user_name`：接続文字列の `-u` パラメータから取得した、アカウント名。
* `$password`：接続文字列の `-p` パラメータから取得した、アカウントのパスワード。

2. その他のコネクションプールのパラメータを設定します。

3. 接続を検証する SQL 文 select 1 を指定します。

4. コネクションプールの初期接続数を 3 に指定します。これは、コネクションプールの起動時に 3 つの初期接続が作成されることを示します。

5. コネクションプールの最大アクティブ接続数を 30 に指定します。これは、コネクションプール内に同時に最大 30 個の接続が存在できることを示します。

6. 破棄された接続のログを出力するかどうかを true に指定します。これは、破棄された接続を再利用する際に、エラーログに情報を出力することを示します。テスト環境では true に設定できますが、本番環境ではパフォーマンスへの影響を避けるために false に設定します。

7. コネクションプールの最小アイドル接続数を 5 に指定します。これは、コネクションプール内のアイドル接続数が 5 未満になった場合、コネクションプールが自動的に新しい接続を作成することを示します。

8. 接続取得時の最大待機時間を 1000（単位：ミリ秒）に指定します。これは、コネクションプール内の接続がすべて使用されており、待機時間が 1000 ミリ秒を超えた場合、接続取得操作がタイムアウト例外をスローすることを示します。

9. アイドル時の接続の最小保持時間を 300000（単位：ミリ秒）に指定します。これは、接続が 300000 ミリ秒（5 分）アイドル状態になった後、使用されなければ再利用されることを示します。

10. 破棄された接続を回収するかどうかを true に指定します。これは、接続が removeAbandonedTimeout で定義された時間を超えた場合に再利用されることを示します。

11. 破棄された接続のタイムアウト時間を 300（単位：秒）に指定します。これは、300 秒（5 分）を超えて使用されていない接続が再利用されることを示します。

12. アイドル接続回収スレッドの実行間隔を 10000（単位：ミリ秒）に指定します。これは、10000 ミリ秒（10 秒）ごとに、アイドル接続再利用スレッドがアイドル接続の再利用操作を 1 回実行することを示します。

13. 接続取得時に接続の可用性を検証するかどうかを false に指定します。false に設定するとパフォーマンスは向上しますが、取得した接続が使用できない可能性があります。

14. 接続返却時に接続の可用性を検証するかどうかを false に指定します。false に設定するとパフォーマンスは向上しますが、返却された接続が使用できない可能性があります。

15. アイドル時に接続を検証するかどうかを true に指定します。true に設定すると、コネクションプールは定期的に validationQuery を実行して接続の可用性を検証します。

16. 長い接続のキープアライブ機能を有効にするかどうかを false に指定します。false に設定すると、長い接続のキープアライブは有効になりません。

17. 接続のアイドル時間しきい値を 60000（単位：ミリ秒）に指定します。これは、接続のアイドル時間が設定されたしきい値の 60000 ミリ秒（つまり 1 分）を超えた場合、接続キープアライブメカニズムがその接続を検出し、接続の可用性を確保することを示します。しきい値時間内に接続で何らかの操作があった場合、接続のアイドル時間は再計算されます。

コードは以下のとおりです。

```java
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 コネクションプールの一般的な設定パラメータ：

Main.java 代码介绍

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

本ドキュメントの Main.java ファイルのコードは、主に以下のセクションで構成されています。

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

2. 現在のコードが属するパッケージ名を com.example と宣言します。

3. 入出力例外を処理するために、Java の IOException クラスをインポートします。

4. ファイルまたはその他のソースから入力ストリームを取得するために、Java の InputStream クラスをインポートします。

5. データベースとの接続を表すために、Java の Connection インターフェースをインポートします。

6. データベースクエリ結果のデータセットを表すために、Java の ResultSet インターフェースをインポートします。

7. SQL 例外を処理するために、Java の SQLException クラスをインポートします。

8. SQL 文を実行するために、Java の Statement インターフェースをインポートします。

9. プリコンパイルされた SQL 文のために、Java の PreparedStatement インターフェースをインポートします。

10. プロパティファイルを処理するために、Java の Properties クラスをインポートします。

11. データベース接続を管理するために、Java の DataSource インターフェースをインポートします。

12. Druid データソースを作成するために、Alibaba Druid コネクションプールの DruidDataSourceFactory クラスをインポートします。

コードは以下のとおりです。

```java
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()` メソッドを呼び出して、テーブルを作成します。
   

7. insertData() メソッドを呼び出して、データを挿入します。

8. selectData() メソッドを呼び出して、データをクエリします。

9. updateData() メソッドを呼び出して、データを更新します。

10. 再度 selectData() メソッドを呼び出して、更新されたデータをクエリします。

11. deleteData() メソッドを呼び出して、データを削除します。

12. 再度 selectData() メソッドを呼び出して、削除後のデータをクエリします。

13. dropTable() メソッドを呼び出して、テーブルを削除します。

コードは以下のとおりです。

```java
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. プロパティファイル内の設定情報を取得して使用するためのメソッドを定義します。

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

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

コードは以下のとおりです。

```java
    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. データソースオブジェクトを取得するためのメソッドを定義します。

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

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

コードは以下のとおりです。

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

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

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

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

コードは以下のとおりです。

```java
    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.");
        }
        }
```

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

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

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

2. データを挿入する SQL 文を格納する文字列変数 insertDataSql を定義します。

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

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

5. for ループ文を使用して 5 回反復し、5 件のデータを挿入することを示します。

6. setInt() メソッドを使用して、最初のパラメータの値をループ変数 i に設定します。

7. setString() メソッドを使用して、2 番目のパラメータの値を文字列 test_insert にループ変数 i の値を加えたものに設定します。

8. executeUpdate() メソッドを使用してデータ挿入用の SQL 文を実行し、返された操作行数を insertedRows 変数に累積します。

9. データの挿入が成功したことを示すメッセージと、挿入された合計行数を出力します。

10. 挿入された合計行数を返します。

コードは以下のとおりです。

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

コードは以下のとおりです。

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

コードは以下のとおりです。

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

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

3. データをクエリする SQL 文を格納する文字列変数 sql を定義します。

4. executeQuery() メソッドを使用してデータクエリ用の SQL 文を実行し、返された結果セットを resultSet 変数に代入します。

5. while ループ文を使用して、結果セット内の各行のデータを反復処理します。

6. getInt() メソッドを使用して、現在の行の id フィールドの整数値を取得し、id 変数に代入します。

7. getString() メソッドを使用して、現在の行の name フィールドの文字列値を取得し、name 変数に代入します。

8. 現在の行の id および name フィールドの値を出力します。

コードは以下のとおりです。

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

コードは以下のとおりです。

```java
    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.");
        }
        }
```

完全なコードの表示

```java
<?xml version="1.0" encoding="UTF-8"?>

<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>

# 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

```java
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 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.");
    }
}

関連情報

MySQL Connector/J の詳細については、MySQL Connector/Jの概要 をご参照ください。