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

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

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

前提条件

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

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

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

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

  説明

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

手順

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

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

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

   説明

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

   

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

   

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

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

例：

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

コード：

...
        <property name="jdbcUrl">jdbc:mysql://t5******.********.oceanbase.cloud:3306/test</property>
        <property name="user">test_user001</property>
        <property name="password">******</property>
...

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

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

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

   

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

   

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

   obclient [test]> SELECT * FROM test_c3p0;
   

   戻り結果は次のとおりです：

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

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

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

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

c3p0-mysql-jdbc
├── src
│   └── main
│       ├── java
│       │   └── com
│       │        └── example
│       │           └── Main.java
│       └── resources
│           └── c3p0-config.xml
└── pom.xml

ファイルの説明：

• src：ソースコードのルートディレクトリです。
• main：アプリケーションの主要なロジックを含むメインコードディレクトリです。
• java：Javaソースコードディレクトリです。
• com：Javaパッケージディレクトリです。
• example：サンプルプロジェクトのパッケージディレクトリです。
• Main.java：メインクラスで、テーブルの作成やデータの挿入などのロジックが含まれます。
• resources：設定ファイルなどを含むリソースファイルディレクトリです。
• c3p0-config.xml：C3P0接続プールの設定ファイルです。
• 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> を使用して、プロジェクトの名前を testc3p0 と指定します。
   3. <version> を使用して、プロジェクトのバージョン番号を 1.0-SNAPSHOT と指定します。

   コード：

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

   説明

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

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

   • mysql-connector-java 依存ライブラリの追加：
   1. <groupId> を使用して、依存関係が属する組織を mysql と指定します。
   2. <artifactId> を使用して、依存関係の名前を mysql-connector-java と指定します。
   3. <version> を使用して、依存関係のバージョン番号を 8.0.25 と指定します。
   • c3p0 依存ライブラリの追加：
   1. <groupId> を使用して、依存関係が属する組織を com.mchange と指定します。
   2. <artifactId> を使用して、依存関係の名前を c3p0 と指定します。
   3. <version> を使用して、依存関係のバージョン番号を 0.9.5.5 と指定します。

   コード：

       <dependencies>
           <dependency>
               <groupId>mysql</groupId>
               <artifactId>mysql-connector-java</artifactId>
               <version>8.0.25</version>
           </dependency>
           <dependency>
               <groupId>com.mchange</groupId>
               <artifactId>c3p0</artifactId>
               <version>0.9.5.5</version>
           </dependency>
       </dependencies>
   

c3p0-config.xmlコードの紹介

c3p0-config.xml ファイルはC3P0接続プールの設定ファイルであり、データベースへの接続に関連するプロパティを設定するために使用されます。各 <property> 要素の値を設定することで、データベースドライバ、接続URL、ユーザー名、パスワード、接続プールサイズなどのプロパティを構成できます。

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

1. ファイル宣言文。

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

   コード：

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

2. 基本情報の設定。

3. <c3p0-config> でc3p0接続プールの設定情報を囲みます。

4. <named-config name="oceanbase"> で、oceanbase という名前の名前付き設定を定義します。コード内では、この名前を使用してこの名前付き設定を参照し、oceanbase データベースに関連する接続情報と接続プールプロパティを取得できます。

コード：

<c3p0-config>
    <named-config name="oceanbase">

        // 各 <property> 要素の値を設定する

    </named-config>
</c3p0-config>

3. データベースドライバの設定。

   <property> を使用して、OceanBaseデータベースへの接続時に使用するMySQL JDBCドライバのクラス名を com.mysql.cj.jdbc.Driver と指定します。

   説明

   MySQL Connector/Jの実装クラス名については、Driver/Datasource Class Nameを参照してください。

   コード：

           <property name="driverClass">com.mysql.cj.jdbc.Driver</property>
   

4. データベース接続情報の設定。

   1. データベース接続のURLを設定します。これには、ホストIPアドレス、ポート番号、アクセスするデータベース、URLパラメータなどの情報が含まれます。
   2. データベースのユーザー名を設定します。
   3. データベースのパスワードを設定します。

   コード：

           <property name="jdbcUrl">jdbc:mysql://$host:$port/$database_name</property>
           <property name="user">$user_name</property>
           <property name="password">$password</property>
   

   パラメータの説明：

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

5. その他のc3p0データベース接続プールのパラメータを設定します。

   1. 接続プールが必要に応じて一度に増やす接続数を20に設定します。つまり、接続プール内の接続が不足した場合、毎回20個の接続を追加します。
   2. 接続プールの初期サイズを10に設定します。つまり、接続プールは起動時に事前に10個の接続を作成します。
   3. 接続プールの最小接続数を5に設定します。つまり、接続プール内で維持される最小接続数は5以上になります。
   4. 接続プールの最大接続数を30に設定します。つまり、接続プールで許可される最大接続数は30を超えません。
   5. 各接続の最大キャッシュステートメント数を0に設定します。つまり、ステートメントはキャッシュされません。
   6. 接続プール内の各接続の最大キャッシュステートメント数を0に設定します。つまり、各接続はステートメントをキャッシュしません。
   7. c3p0が使用するヘルパースレッドの数を3に設定します。これらのヘルパースレッドは、低速なJDBC操作の実行に使用されます。
   8. c3p0接続のプロパティチェック周期を3秒に設定します。つまり、3秒ごとに接続のプロパティをチェックします。
   9. 接続取得のタイムアウト時間を1000ミリ秒に設定します。つまり、1000ミリ秒以内に接続を取得できない場合、タイムアウト例外がスローされます。
   10. 接続プール内のアイドル接続のチェック周期を3秒に設定します。つまり、3秒ごとにアイドル接続の状態をチェックします。
   11. 接続プール内の接続の最大アイドル時間を10秒に設定します。つまり、接続が10秒間使用されない場合、閉じられます。
   12. 接続プール内で最大接続数を超える接続の最大アイドル時間を5秒に設定します。つまり、接続数が最大接続数を超え、かつ5秒以上アイドル状態の場合、その接続は閉じられます。
   13. 接続取得試行時の再試行遅延時間を1000ミリ秒に設定します。つまり、接続取得に失敗した場合、1000ミリ秒後に再度試行します。
   14. c3p0の自動テストテーブルを Test に設定します。これは、接続が有効かどうかをテストするための特殊なテーブルです。
   15. 接続を接続プールに返却する際に接続の有効性をテストするかどうかを設定します。trueに設定すると、接続が接続プールに返却される際に接続の有効性テストが実行されます。

   コード：

          <property name="acquireIncrement">20</property>
          <property name="initialPoolSize">10</property>
          <property name="minPoolSize">5</property>
          <property name="maxPoolSize">30</property>
          <property name="maxStatements">0</property>
          <property name="maxStatementsPerConnection">0</property>
          <property name="numHelperThreads">3</property>
          <property name="propertyCycle">3</property>
          <property name="checkoutTimeout">1000</property>
          <property name="idleConnectionTestPeriod">3</property>
          <property name="maxIdleTime">10</property>
          <property name="maxIdleTimeExcessConnections">5</property>
          <property name="acquireRetryDelay">1000</property>
          <property name="automaticTestTable">Test</property>
          <property name="testConnectionOnCheckin">true</property>
   

C3P0接続プールのよく使われるパラメータ：

Main.javaコードの紹介

Main.java ファイルはサンプルプログラムの一部であり、c3p0接続プールを使用してデータベース接続を取得し、トランザクション内で一連のデータベース操作を実行する方法を示しています。これには、テーブルの作成、データの挿入、データの削除、データの更新、データのクエリ、およびクエリ結果の出力が含まれます。このプログラムは、c3p0接続プールを使用してデータベース接続を管理し、トランザクション操作を実行することで、データベース操作の効率とパフォーマンスを向上させる方法を示しています。

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

1. パッケージの定義と java.sql インターフェースのインポート。

   1. 現在のコードが属するパッケージ名を com.example と宣言します。
   2. データベース接続を表すために使用される java.sql.Connection クラスをインポートします。
   3. プリコンパイルされたデータベース操作を実行するために使用される java.sql.PreparedStatement クラスをインポートします。
   4. データベースクエリ結果セットを表すために使用される java.sql.ResultSet クラスをインポートします。
   5. c3p0接続プールを使用するために使用される com.mchange.v2.c3p0.ComboPooledDataSource クラスをインポートします。

   コード：

   package com.example;
   
   import java.sql.Connection;
   import java.sql.PreparedStatement;
   import java.sql.ResultSet;
   import com.mchange.v2.c3p0.ComboPooledDataSource;
   

2. クラス名とメソッドの定義。

   1. プログラムのエントリポイントとして、Main という名前のpublicクラスを定義します。クラス名はファイル名と一致させる必要があります。
   2. プログラムの実行開始点として、public staticメソッド main を定義します。
   3. try-with-resources ステートメントを使用して、データベース接続を取得し、プリコンパイルされたSQLステートメントを作成します。
   4. データベーストランザクション操作。
   5. 発生する可能性のある例外をキャッチし、例外スタック情報を出力します。
   6. c3p0接続プールからデータベース接続を取得するために使用される、プライベート静的メソッド getConnection を定義します。メソッド内部では、まず ComboPooledDataSource オブジェクト cpds を作成します。このオブジェクトは、パラメータ oceanbase で接続プールの設定を指定します。次に、cpds.getConnection() メソッドを使用して接続プールからデータベース接続を取得し、それを返します。

   コード：

   public class Main {
   
       public static void main(String[] args) {
           try (
               //データベース接続を取得する
               //プリコンパイルされたSQLステートメントを作成する
               ) {
   
               // データベーストランザクション操作：トランザクションの開始、テーブルの作成、データの挿入、データの削除、データの更新、データのクエリ、トランザクションのコミット
   
           } catch (Exception e) {
               e.printStackTrace();
           }
       }
   
       private static Connection getConnection() throws Exception {
           ComboPooledDataSource cpds = new ComboPooledDataSource("oceanbase");
           return cpds.getConnection();
       }
   }
   

3. データベース接続の取得。

   データベース接続を取得し、conn 変数に代入します。

   コード：

                Connection conn = getConnection();
   

4. プリコンパイルされたSQLステートメントの作成。

   1. test_c3p0 という名前のデータベーステーブルを作成するためのプリコンパイルされたSQLステートメントを作成します。
   2. test_c3p0 テーブルにデータを挿入するためのプリコンパイルされたSQLステートメントを作成します。
   3. test_c3p0 テーブルからデータを削除するためのプリコンパイルされたSQLステートメントを作成します。
   4. test_c3p0 テーブル内のデータを更新するためのプリコンパイルされたSQLステートメントを作成します。
   5. test_c3p0 テーブルからデータをクエリするためのプリコンパイルされたSQLステートメントを作成します。

   コード：

                PreparedStatement stmtCreate = conn.prepareStatement("CREATE TABLE test_c3p0 (id INT, name VARCHAR(32))");
                PreparedStatement stmtInsert = conn.prepareStatement("INSERT INTO test_c3p0 VALUES (?, ?)");
                PreparedStatement stmtDelete = conn.prepareStatement("DELETE FROM test_c3p0 WHERE id < ?");
                PreparedStatement stmtUpdate = conn.prepareStatement("UPDATE test_c3p0 SET name = ? WHERE id = ?");
                PreparedStatement stmtSelect = conn.prepareStatement("SELECT * FROM test_c3p0")
   

5. トランザクションの開始。

   データベース接続の自動コミットを false に設定することで、トランザクションのメカニズムを有効にします。

   コード：

               conn.setAutoCommit(false);
   

6. テーブルの作成。

   テーブルを作成するSQLステートメントを実行します。

   コード：

               stmtCreate.execute();
   

7. データの挿入。

   for ループを使用して、test_c3p0 テーブルに10件のデータを挿入します。1列目の値は変数 i の値、2列目の値は文字列 test_insert に変数 i の値を結合したものです。

   コード：

               for (int i = 0; i < 10; i++) {
                   stmtInsert.setInt(1, i);
                   stmtInsert.setString(2, "test_insert" + i);
                   stmtInsert.executeUpdate();
               }
   

8. データの削除。

   削除ステートメントのパラメータを5に設定して、削除操作を実行します。

   コード：

               stmtDelete.setInt(1, 5);
               stmtDelete.executeUpdate();
   

9. データの更新。

   更新ステートメントの最初のパラメータを test_update、2番目のパラメータを5に設定して、更新操作を実行します。

   コード：

               stmtUpdate.setString(1, "test_update");
               stmtUpdate.setInt(2, 5);
               stmtUpdate.executeUpdate();
   

10. データのクエリ。

    1. クエリステートメントを実行し、クエリ結果を ResultSet オブジェクト rs に格納します。
    2. whileループを使用し、rs.next() で結果セットに次の行のデータがあるかどうかを判断します。ある場合は、ループ内のコードを実行します。
    3. ループ内のコードは、各行データの id 列と name 列の値を出力します。
    4. 結果セットを閉じ、関連リソースを解放します。

    コード：

                ResultSet rs = stmtSelect.executeQuery();
                while (rs.next()) {
                    System.out.println(rs.getInt("id") + "   " + rs.getString("name"));
                }
                rs.close();
    

11. トランザクションのコミット。

**コード：**

```java
            conn.commit();
```

全コード表示

<?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.oceanbase</groupId>
    <artifactId>testc3p0</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>8.0.25</version>
        </dependency>
        <dependency>
            <groupId>com.mchange</groupId>
            <artifactId>c3p0</artifactId>
            <version>0.9.5.5</version>
        </dependency>
    </dependencies>
</project>

<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>
    <named-config name="oceanbase">
        <!-- Configure Database Driver -->
        <property name="driverClass">com.mysql.cj.jdbc.Driver</property>
        <!-- Configure Database Link Address -->
        <property name="jdbcUrl">jdbc:mysql://$host:$port/$database_name</property>
        <!-- Configure database username -->
        <property name="user">$user_name</property>
        <!-- Configure database password -->
        <property name="password">$password</property>
        <!-- How many connection objects does the database Connection pool want from the database at one time -->
        <property name="acquireIncrement">20</property>
        <!-- Initialize connections -->
        <property name="initialPoolSize">10</property>
        <!-- Minimum number of connections -->
        <property name="minPoolSize">5</property>
        <!-- The maximum number of connections reserved in the Connection pool. Default: 15 -->
        <property name="maxPoolSize">30</property>
        <!-- JDBC standard parameter used to control the number of PreparedStatements loaded within the data source. However, the pre cached statements belong to a single connection rather than the entire Connection pool. So setting this parameter requires considering multiple factors. If both maxStatements and maxStatementsPerConnection are 0, the cache is turned off. Default:0 -->
        <property name="maxStatements">0</property>
        <!-- MaxStatementsPerConnection defines the maximum number of cached statements owned by a single connection in the Connection pool. Default: 0 -->
        <property name="maxStatementsPerConnection">0</property>
        <!-- C3p0 is an asynchronous operation, and slow JDBC operations are completed by the helper process. Expanding these operations can effectively improve performance by enabling multiple operations to be executed simultaneously through multithreading. Default:3 -->
        <property name="numHelperThreads">3</property>
        <!-- The user can wait up to 300 seconds before modifying the system configuration parameters. Default: 300 -->
        <property name="propertyCycle">3</property>
        <!-- The default setting for obtaining the connection timeout is to wait for a unit of milliseconds -->
        <property name="checkoutTimeout">1000</property>
        <!-- Check all free connections in the Connection pool every few seconds. Default: 0 -->
        <property name="idleConnectionTestPeriod">3</property>
        <!-- The maximum idle time, within seconds, if not used, the connection will be discarded. If it is 0, it will never be discarded. Default: 0 -->
        <property name="maxIdleTime">10</property>
        <!-- Configure the lifetime of the connection. Connections beyond this time will be automatically disconnected and discarded by the Connection pool. Of course, the connection being used will not be immediately disconnected, but will wait for it to close before disconnecting. When configured to 0, there is no restriction on the lifetime of the connection. -->
        <property name="maxIdleTimeExcessConnections">5</property>
        <!-- The interval time between two connections, in milliseconds. Default: 1000 -->
        <property name="acquireRetryDelay">1000</property>
        <!-- C3p0 will create an empty table called Test and use its built-in query statement for testing. If this parameter is defined, the property preferredTestQuery will be ignored. You cannot perform any operations on this Test table, it will only be used for c3p0 testing. Default: null -->
        <property name="automaticTestTable">Test</property>
        <!-- Test if the connection is valid when obtaining it -->
        <property name="testConnectionOnCheckin">true</property>
    </named-config>
</c3p0-config>

package com.example;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import com.mchange.v2.c3p0.ComboPooledDataSource;

public class Main {

    public static void main(String[] args) {
        try (Connection conn = getConnection();

             PreparedStatement stmtCreate = conn.prepareStatement("CREATE TABLE test_c3p0 (id INT, name VARCHAR(32))");
             PreparedStatement stmtInsert = conn.prepareStatement("INSERT INTO test_c3p0 VALUES (?, ?)");
             PreparedStatement stmtDelete = conn.prepareStatement("DELETE FROM test_c3p0 WHERE id < ?");
             PreparedStatement stmtUpdate = conn.prepareStatement("UPDATE test_c3p0 SET name = ? WHERE id = ?");
             PreparedStatement stmtSelect = conn.prepareStatement("SELECT * FROM test_c3p0")) {

            // Begin transaction
            conn.setAutoCommit(false);

            // Create table
            stmtCreate.execute();

            // Insert data
            for (int i = 0; i < 10; i++) {
                stmtInsert.setInt(1, i);
                stmtInsert.setString(2, "test_insert" + i);
                stmtInsert.executeUpdate();
            }

            // Delete data
            stmtDelete.setInt(1, 5);
            stmtDelete.executeUpdate();

            // Update data
            stmtUpdate.setString(1, "test_update");
            stmtUpdate.setInt(2, 5);
            stmtUpdate.executeUpdate();

            // Query data
            ResultSet rs = stmtSelect.executeQuery();
            while (rs.next()) {
                System.out.println(rs.getInt("id") + "   " + rs.getString("name"));
            }
            rs.close();

            // Commit transaction
            conn.commit();

        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    private static Connection getConnection() throws Exception {
        ComboPooledDataSource cpds = new ComboPooledDataSource("oceanbase");
        return cpds.getConnection();
    }
}

関連ドキュメント

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