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

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

dbcp-mysql-client サンプルプロジェクトをダウンロード DBCP接続プールでOceanBaseデータベースに接続するサンプルプログラム（MySQLモード）

前提条件

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

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

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

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

  説明

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

手順

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

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

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

   説明

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

   

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

   

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

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

例：

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

コード：

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

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

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

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

   

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

   

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

   obclient [test]> SELECT * FROM test_tbl1;
   

   戻り値は以下のとおりです：

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

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

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

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

dbcp-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であることを宣言します。

   コード：

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

   コード：

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

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

   • MySQL JDBC依存関係：

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

   • dbcp依存関係：

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

   コード：

       <dependencies>
           <dependency>
               <groupId>mysql</groupId>
               <artifactId>mysql-connector-java</artifactId>
               <version>5.1.47</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. ドライバーのクラス名を設定します。ここでは、MySQL JDBCドライバーのクラス名 com.mysql.jdbc.Driver です。
   2. データベース接続のURLを設定します。ホストIP、ポート番号、アクセスするデータベースなどの情報が含まれます。
   3. データベースのユーザー名を設定します。
   4. データベースのパスワードを設定します。
   5. 接続プロパティを設定します。useSSL=false はSSL暗号化接続を使用しないことを表し、characterEncoding=UTF-8 はUTF-8エンコーディングを使用してデータを転送することを表します。

   コード：

   driverClassName=com.mysql.jdbc.Driver
   url=jdbc:mysql://$host:$port/$database_name
   username=$user_name
   password=$password
   connectionProperties=useSSL=false;characterEncoding=UTF-8
   

   パラメータの説明：

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

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. FileInputStream オブジェクト is を作成します。src/main/resources ディレクトリにある db.properties ファイルを読み取るために使用されます。
   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. 文字列変数 createTableSql を定義します。テーブル作成のSQLステートメントを格納するために使用されます。SQLステートメントでは、テーブル名を test_tbl1 と指定し、2つの列を定義します。1つは id という名前の INT 型の列で、もう1つは name という名前の VARCHAR(32) 型の列です。
   3. conn.prepareStatement(createTableSql) メソッドを使用して、プリコンパイルされたSQLステートメントを実行するための PreparedStatement オブジェクト createTableStmt を作成します。
   4. SQLステートメントを実行するために execute() メソッドを呼び出し、テーブルを作成します。

   コード：

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

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

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

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

   2. 文字列変数 insertDataSql を定義します。データ挿入のSQLステートメントを格納するために使用されます。

   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. 文字列変数 deleteDataSql を定義します。データ削除のSQLステートメントを格納するために使用されます。
   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. 文字列変数 updateDataSql を定義します。データ更新のSQLステートメントを格納するために使用されます。
   3. conn.prepareStatement(updateDataSql) メソッドを使用して、プリコンパイルされたSQLステートメントを実行するための PreparedStatement オブジェクト updateDataStmt を作成します。
   4. setString() メソッドを使用して、文字列 test_update をSQLステートメントの最初のパラメータ値に設定します。
   5. setInt() メソッドを使用して、数値 5 をSQLステートメントの2番目のパラメータ値に設定します。
   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. 文字列変数 queryDataSql を定義します。データクエリのSQLステートメントを格納するために使用されます。

   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-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.47</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.mysql.jdbc.Driver
url=jdbc:mysql://$host:$port/$database_name
username=$user_name
password=$password
connectionProperties=useSSL=false;characterEncoding=UTF-8

# 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 INT, name VARCHAR(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);
                }
            }
        }
    }
}

関連ドキュメント

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