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

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

      dbcp-mysql-client サンプルプロジェクトのダウンロード
  </a>
  <a role='video' href='https://obbusiness-private.oss-cn-shanghai.aliyuncs.com/video-center/video/video/04%20dbcp-mysql-client.mp4'>
      
      DBCPコネクションプールを使用してOceanBaseデータベースに接続するサンプルプログラム（MySQLモード）
  </a>

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

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

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

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

  説明

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

手順

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

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

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

   説明

   Eclipseを使用してMavenプロジェクトをインポートすると、Eclipseはプロジェクト内の 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. 現在のJavaクラスを格納するために使用される com.example という名前のパッケージを宣言します。
   2. ファイルを読み取るために使用される java.io.FileInputStream クラスをインポートします。
   3. データベースとの接続を表す java.sql.Connection インターフェースをインポートします。
   4. プリコンパイルされたSQL文を表す java.sql.PreparedStatement インターフェースをインポートします。
   5. データベースクエリの結果セットを表す java.sql.ResultSet インターフェースをインポートします。
   6. SQL操作の例外を表す java.sql.SQLException 例外クラスをインポートします。
   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. 戻り値の型が BasicDataSource であるプライベート静的メソッド createDataSource() を定義します。このメソッドは Exception 例外をスローする可能性があります。
   2. データベース接続の設定情報を格納するために使用される Properties オブジェクト props を作成します。
   3. src/main/resources ディレクトリにある db.properties ファイルを読み取るために使用される FileInputStream オブジェクト is を作成します。
   4. load() メソッドを使用して、db.properties ファイル内のキーと値のペアをpropsオブジェクトにロードします。
   5. BasicDataSourceFactory.createDataSource(props) メソッドを呼び出し、props オブジェクトをパラメータとして使用して BasicDataSource オブジェクトを作成して返します。

   コードは以下の通りです：

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

4. テーブル作成用メソッドの定義。

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

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

   コードは以下の通りです：

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

5. データ挿入用メソッドの定義。

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

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

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

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

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

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

   コードは以下の通りです：

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

6. データ削除用メソッドの定義。

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

   1. Connection オブジェクトをパラメータとして受け取るプライベート静的メソッド deleteData() を定義します。このメソッドは SQLException 例外をスローする可能性があります。
   2. データ削除のSQL文を格納するために使用される文字列変数 deleteDataSql を定義します。
   3. conn.prepareStatement(deleteDataSql) メソッドを使用して、プリコンパイルされたSQL文を実行するために使用される PreparedStatement オブジェクト deleteDataStmt を作成します。
   4. setInt() メソッドを使用して、数値5をSQL文のパラメータ値として設定します。
   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. Connection オブジェクトをパラメータとして受け取るプライベート静的メソッド updateData() を定義します。このメソッドは SQLException 例外をスローする可能性があります。
   2. データ更新のSQL文を格納するために使用される文字列変数 updateDataSql を定義します。
   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. Connection オブジェクトをパラメータとして受け取るプライベート静的メソッド queryData() を定義します。このメソッドは SQLException 例外をスローする可能性があります。

   2. データクエリのSQL文を格納するために使用される文字列変数 queryDataSql を定義します。

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

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

   5. while ループを使用し、rs.next() メソッドを介してクエリ結果セットを反復処理します：

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

   コードは以下の通りです：

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

完全なコードの表示

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.example</groupId>
    <artifactId>dbcp-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の詳細については、Overview of MySQL Connector/Jをご参照ください。