Tomcat接続プールを使用してOceanBase データベースに接続するサンプルプログラム

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

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

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

手順

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

1. IntelliJ IDEA を開き、File > Open... オプションを選択します。

2. ポップアップ表示される Open File or Project ウィンドウで、対応するプロジェクトファイルを選択し、OK をクリックしてプロジェクトファイルのインポートを完了します。

3. IntelliJ IDEAはプロジェクト内の各種ファイルを自動的に認識し、Project ツールウィンドウでプロジェクトのディレクトリ構造、ファイルリスト、モジュールリスト、依存関係などの情報を確認できます。Project ツールウィンドウは通常、IntelliJ IDEAインターフェースの左端にあり、デフォルトで開いています。Project ツールウィンドウが閉じている場合は、メニューバーの View > Tool Windows > Project をクリックするか、ショートカットキー Alt + 1 を使用して再度開くことができます。

   説明

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

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

手順2：tomcat-mysql-client プロジェクトのデータベース接続情報を変更する

前提条件で取得した接続文字列情報に基づいて、application.properties ファイル内のデータベース接続情報を変更します。

例は以下の通りです：

• データベースドライバ名：com.oceanbase.jdbc.Driver
• 接続アドレス：t5******.********.oceanbase.cloud
• アクセスポート：3306
• アクセスするSchema名：TEST
• テナントの接続アカウント：xymysql（xymysql はOB Cloudで作成されたデータベースアカウントです）。
• パスワード：******

サンプルコードは以下の通りです：

#Apache Commons DBCP2 Connection Pool
#Database Connection Pool Driver Class Name
db.app.pool.driverClassName=com.oceanbase.jdbc.Driver
#Database URL
db.app.pool.url=jdbc:oceanbase://t5******.********.oceanbase.cloud/TEST?characterEncoding=UTF-8
#Database username
db.app.pool.username=xymysql
#Database password
db.app.pool.password=******
#Initial size of connection pool
db.app.pool.initialSize=3
#Maximum number of connections in the connection pool
db.app.pool.maxTotal=10
#Maximum number of idle connections in the connection pool
db.app.pool.maxIdle=20
#Minimum number of idle connections in the connection pool
db.app.pool.minIdle=5
#Maximum wait time for obtaining connections (in milliseconds)
db.app.pool.maxWaitMillis=5000
#Verify the connection's query statement
db.app.pool.validationQuery=select 1 from dual

手順4：tomcat-mysql-client プロジェクトのTomcat実行環境を構築する

1. Tomcat 8.5.95 バージョンをダウンロードします。

   Apache Tomcat 公式サイトからTomcat 8.5.95 バージョンの圧縮パッケージをダウンロードします。ダウンロードした圧縮パッケージを、Tomcatをインストールしたいディレクトリに解凍します。

2. IDEAでTomcatを設定します。

   IntelliJ IDEAを開き、File メニューから Settings > Plugins を選択します。Settings ウィンドウの中央にある検索ボックスで Smart Tomcat を検索し、ダウンロード後に Apply を選択します。このとき、Settings ウィンドウの左下端に Tomcat Server タブが表示されるので、Tomcat Server タブに入り、右側の + ボタンをクリックして、解凍したTomcatディレクトリを選択します。Apply をクリックしてから OK をクリックし、設定を完了します。

3. Tomcatの実行構成を作成します。

   IDEAの上部ツールバーで、Run > Edit Configurations を選択します。Run/Debug Configurations ウィンドウで、+ ボタンをクリックし、Tomcat Server を選択して、実行サーバー名 Name を入力します。Configuration 選択ボックスでインストールしたバージョンの Tomcat sever を選択し、Context path の値を / に変更し、SSL port の値に 8080 を入力します。Before launch 選択ボックスで + をクリックし、Launch Web Browser を選択します。Edit をクリックしてURLに http://localhost:8080/hello/getData を入力します。Apply をクリックしてから OK をクリックし、設定を完了します。

4. Tomcatサーバーを実行します。

   IDEAの上部ツールバーで、作成したTomcat実行構成を選択します。実行ボタン（緑色の三角形）をクリックしてTomcatサーバーを起動します。IDEAの Run ウィンドウでTomcatサーバーの起動ログを確認できます。

手順5：tomcat-mysql-client プロジェクトを実行する

1. 実行パス。

   IDEAの上部ツールバーで、作成したTomcat実行構成を選択します。実行ボタン（緑色の三角形）をクリックしてTomcatサーバーを起動します。Google ChromeまたはIEブラウザでパス http://localhost:8080/hello/getData を開き、実行結果を確認します。

2. 実行結果。

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

   • データ挿入後の結果。

     tomcat 连接池测试0
     tomcat 连接池测试1
     tomcat 连接池测试2
     tomcat 连接池测试3
     tomcat 连接池测试4
     tomcat 连接池测试5
     tomcat 连接池测试6
     tomcat 连接池测试7
     tomcat 连接池测试8
     tomcat 连接池测试9
     

   • データ変更後の結果。

     -----修改后-----
     POOl 连接池测试0
     POOl 连接池测试1
     POOl 连接池测试2
     POOl 连接池测试3
     POOl 连接池测试4
     POOl 连接池测试5
     POOl 连接池测试6
     POOl 连接池测试7
     POOl 连接池测试8
     POOl 连接池测试9
     

   • Webインターフェースに返される結果。

プロジェクトコードの紹介

tomcat-mysql-client をクリックしてプロジェクトコードをダウンロードします。これは tomcat-mysql-client という名前の圧縮パッケージです。

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

│--pom.xml
│
├─.idea
│
├─src
│  ├─main
│  │  ├─java
│  │  │  └─com
│  │  │      └─oceanbase
│  │  │          └─testtomcat
│  │  │              ├─config
│  │  │              │   └─UserConfig.java
│  │  │              │
│  │  │              ├─controller
│  │  │              │   └─UserController.java
│  │  │              │
│  │  │              └─pojo
│  │  │                  └─User.java
│  │  │
│  │  ├─resources
│  │  │    └─application.properties
│  │  │    
│  │  └─webapp    
│  │      └─WEB-INF
│  │          └─web.xml
│  │             
│  │                
│  │
│  └─test
│      └─java
│         
│
└─target

ファイルの説明：

• pom.xml：Mavenプロジェクトの設定ファイルであり、プロジェクトの依存関係、プラグイン、ビルドなどの情報が含まれています。
• .idea：IDE（統合開発環境）で使用されるディレクトリであり、プロジェクト関連の設定情報を保存するために使用されます。
• src：通常、プロジェクト内でソースコードを格納するディレクトリを表すために使用されます。
• main：主要なソースコードとリソースファイルを格納するディレクトリです。
• java：Javaソースコードを格納するディレクトリです。
• com：Javaパッケージのルートディレクトリを格納します。
• oceanbase：プロジェクトのルートディレクトリを格納します。
• testtomcat：JFinalフレームワークの関連コードを格納します。
• config：設定ファイルディレクトリであり、アプリケーションの設定クラスファイルが含まれています。
• UserConfig.java：ユーザー設定クラスファイルです。
• controller：コントローラディレクトリであり、アプリケーションのコントローラクラスファイルが含まれています。
• UserController.java：ユーザーコントローラクラスファイルです。
• pojo：JavaBeanまたはエンティティクラスを格納します。
• User.java：ユーザーエンティティクラスを格納します。
• resources：設定ファイルやSQLファイルなどのリソースファイルを格納するディレクトリです。
• application.properties：データベース接続情報を格納する設定ファイルです。
• webapp：Webアプリケーションディレクトリであり、Webアプリケーションの静的リソースと設定ファイルが含まれています。
• WEB-INF：WebアプリケーションのWEB-INFディレクトリであり、設定ファイルやその他の保護されたリソースファイルを格納するために使用されます。
• web.xml：Webアプリケーションのデプロイメント記述子ファイルです。
• test：テストコードとリソースファイルを格納するディレクトリです。
• target：コンパイル後のClassファイル、Jarパッケージなどのファイルを格納するディレクトリです。

pom.xml コードの紹介

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.oceanbase に指定します。
   2. <artifactId> を使用して、プロジェクト依存関係を tomcat-mysql-client に指定します。
   3. <version> を使用して、プロジェクトのバージョン番号を 1.0-SNAPSHOT に指定します。
   4. <packaging> を使用して、プロジェクトのパッケージ化方式をWARファイル（Webアプリケーションアーカイブファイル）に指定します。

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

    <groupId>com.oceanbase</groupId>
    <artifactId>tomcat-mysql-client</artifactId>
    <version>1.0-SNAPSHOT</version>
    <!-- Packaging method (default to jar) -->
    <packaging>war</packaging>
   

4. MAVENバージョンを設定します。

   <maven.compiler.source> および <maven.compiler.target> を使用して、コンパイラのソースコードバージョンとターゲットコードバージョンを両方ともJava 8に指定します。

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

    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>
   

5. コア依存関係を設定します。

   1. 依存関係が属する組織を com.jfinal、名前を jfinal、バージョン番号を 5.0.6 に指定します。この依存関係により、JFinalフレームワークの機能を使用できます。

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

      <dependency>
          <groupId>com.jfinal</groupId>
          <artifactId>jfinal</artifactId>
          <version>5.0.6</version>
      </dependency>
      

   2. 依存関係が属する組織を com.alibaba、名前を druid、バージョン番号を 1.2.8 に指定します。この依存関係により、データベース接続の取得と解放を管理および最適化するためのDruidライブラリを使用できます。

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

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

   3. 依存関係が属する組織を org.apache.commons、名前を commons-dbcp2、バージョン番号を 2.9.0 に指定します。この依存関係により、データベース接続の取得と解放を管理および最適化するためのApache Commons DBCP2ライブラリを使用できます。

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

      <dependency>
          <groupId>org.apache.commons</groupId>
          <artifactId>commons-dbcp2</artifactId>
          <version>2.9.0</version>
      </dependency>
      

   4. 依存関係が属する組織を mysql、名前を mysql-connector-java、バージョン番号を 5.1.40 に指定します。この依存関係により、接続、クエリ、トランザクションなど、OceanBaseが提供するクライアント機能を使用できます。

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

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

application.properties ファイルの紹介

application.properties ファイルは、OceanBase データベースに接続するためのデータベース接続情報を設定します。これには、データベースドライバのクラス名、接続URL、ユーザー名、パスワード、および接続プールに関連するパラメータが含まれます。これらのパラメータは、データベース操作を実行するために、アプリケーション内でデータベース接続を取得および管理するために使用されます。

• db.app.pool.driverClassName を使用して、データベースドライバを com.mysql.jdbc.Driver に指定し、OceanBase データベースとの接続を確立するために使用します。

• db.app.pool.url を使用して、データベースに接続するURLを指定します。

• db.app.pool.username を使用して、データベースに接続するユーザー名を指定します。

• db.app.pool.password を使用して、データベースに接続するパスワードを指定します。

• db.app.pool.initialSize を使用して、接続プールの初期サイズを 3 に指定します。つまり、初期時に3つのデータベース接続を作成します。

• db.app.pool.maxTotal を使用して、接続プールの最大サイズを 10 に指定します。つまり、接続プール内に最大10個のデータベース接続を作成できます。

• db.app.pool.maxIdle を使用して、接続プールの最大アイドル接続数を 20 に指定します。

• db.app.pool.minIdle を使用して、接続プールの最小アイドル接続数を 5 に指定します。

• db.app.pool.maxWaitMillis を使用して、データベース接続のタイムアウト時間を 5000ms に指定します。つまり、データベース接続を取得する際、5000msを超えても接続を取得できない場合はタイムアウト例外をスローします。

• db.app.pool.validationQuery を使用して、データベース接続を検証するためのSQLクエリ文を select 1 に指定します。つまり、接続プールから接続を取得する際、このクエリ文を実行して接続の有効性を検証します。

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

    #Apache Commons DBCP2 Connection Pool
    #Database Connection Pool Driver Class Name
    db.app.pool.driverClassName=com.mysql.jdbc.Driver
    #Database URL
    db.app.pool.url=jdbc:mysql:////host:port/schema_name?characterEncoding=UTF-8
    #Database username
    db.app.pool.username=user_name
    #Database password
    db.app.pool.password=******
    #Initial size of connection pool
    db.app.pool.initialSize=3
    #Maximum number of connections in the connection pool
    db.app.pool.maxTotal=10
    #Maximum number of idle connections in the connection pool
    db.app.pool.maxIdle=20
    #Minimum number of idle connections in the connection pool
    db.app.pool.minIdle=5
    #Maximum wait time for obtaining connections (in milliseconds)
    db.app.pool.maxWaitMillis=5000
    #Verify the connection's query statement
    db.app.pool.validationQuery=select 1 
  

Tomcat組み込み接続プールDBCPの一般的なパラメータ：

web.xml コードの紹介

web.xml ファイルは、Webアプリケーションのフィルタを設定するために使用されます。

web.xml 設定ファイルの内容は以下の通りです：

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

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

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

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

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

   1. xmlns:xsi を使用して、XML名前空間を http://www.w3.org/2001/XMLSchema-instance に指定します。
   2. xmlns を使用して、XMLの名前空間を http://java.sun.com/xml/ns/javaee に指定します。
   3. xsi:schemaLocation を使用して、XMLの名前空間を http://java.sun.com/xml/ns/javaee に指定し、XMLのXSDファイルの場所を http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd に指定します。
   4. <id> および <version> 要素を使用して、WebアプリケーションのIDを WebApp_ID、バージョン番号を 3.0 に指定します。

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

    <web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
             xmlns="http://java.sun.com/xml/ns/javaee" 
             xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd" 
             id="WebApp_ID" 
             version="3.0">
   

3. JFinalフィルタを設定します。

   WebアプリケーションでJFinalフレームワークを使用するために、jfinal という名前のフィルタを設定します。フィルタのクラスを com.jfinal.core.JFinalFilter に指定します。初期化パラメータ configClass を指定することで、JFinalフレームワークの設定クラスの場所を com.oceanbase.testtomcat.config.UserConfig に指定します。JFinalフィルタは、WebアプリケーションでJFinalフレームワークを使用し、指定された設定クラスに基づいてJFinalフレームワークの動作を設定するために使用されます。

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

    <filter>
        <filter-name>jfinal</filter-name>
        <filter-class>com.jfinal.core.JFinalFilter</filter-class>
        <init-param>
            <param-name>configClass</param-name>
            <!-- your jfinal configuration location -->
            <param-value>com.oceanbase.testtomcat.config.UserConfig</param-value>
        </init-param>
    </filter>
   

4. JFinalフィルタマッピングを設定します。

   jfinal フィルタをすべてのリクエストパスに適用します。つまり、このフィルタはアプリケーション内のすべてのリクエストに適用されます。

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

    <filter-mapping>
        <filter-name>jfinal</filter-name>
        <url-pattern>/*</url-pattern>
    </filter-mapping>
   

UserConfig.java ファイルの紹介

UserConfig.java ファイルは、アプリケーションのルーティング、プラグイン、データベース接続などの関連情報を設定するために使用されます。

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

1. 他のクラスとインターフェースの参照。

   現在のファイルに以下のインターフェースとクラスが含まれていることを宣言します：

   • StatFilter クラス：データベースアクセスのパフォーマンスを統計するために使用されます。
   • JdbcConstants クラス：データベースタイプの定数を定義するために使用されます。
   • WallFilter クラス：SQLインジェクション攻撃を防ぐために使用されます。
   • PropKit クラス：設定ファイルを読み取るために使用されます。
   • ActiveRecordPlugin クラス：データベースを操作するために使用されます。
   • Db クラス：データベース操作を実行するために使用されます。
   • MysqlDialect クラス：データベースのダイアレクトを指定するために使用されます。
   • DruidPlugin クラス：データベースに接続するために使用されます。
   • Engine クラス：テンプレートエンジンを設定するために使用されます。
   • UserController クラス：ユーザー関連のリクエストを処理するために使用されます。
   • User クラス：ユーザーデータを渡して保存するために使用されます。

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

   import com.alibaba.druid.filter.stat.StatFilter;
   import com.alibaba.druid.util.JdbcConstants;
   import com.alibaba.druid.wall.WallFilter;
   import com.jfinal.config.*;
   import com.jfinal.kit.PropKit;
   import com.jfinal.plugin.activerecord.ActiveRecordPlugin;
   import com.jfinal.plugin.activerecord.Db;
   import com.jfinal.plugin.activerecord.dialect.MysqlDialect;
   import com.jfinal.plugin.druid.DruidPlugin;
   import com.jfinal.template.Engine;
   import com.oceanbase.testjfinal.controller.UserController;
   import com.oceanbase.testjfinal.pojo.User;
   

2. UserConfig クラスの定義。

   JFinalConfig クラスの各メソッドをオーバーライドすることで、定数、ルーティング、プラグイン、データベース接続などの情報を設定できます。

   1. configConstant メソッドの定義。

      JFinalフレームワークの定数を設定するために使用され、PropKit を使用して設定ファイル内の設定を読み取ります。

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

      @Override
      public void configConstant(Constants constants) {
          PropKit.use("application.properties");
      }
      

   2. configRoute メソッドの定義。

      ルーティングマッピングを設定するために使用され、routes.add メソッドを使用して "/hello" パスを UserController クラスのデフォルトアクセスベージにマッピングします。

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

      @Override
      public void configRoute(Routes routes) {
          routes.add("/hello", UserController.class, "/");
      }
      

   3. configEngine メソッドの定義。

      テンプレートエンジンを設定するために使用されます。

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

      @Override
      public void configEngine(Engine engine) {
      }
      

   4. configPlugin メソッドの定義。

      アプリケーションのプラグインを設定するために使用されます。init メソッドを呼び出してデータベース接続とテーブル構造を初期化し、DruidPlugin および ActiveRecordPlugin プラグインを作成して plugins に追加します。同時に、activeRecordPlugin の addMapping メソッドを呼び出して、データベーステーブルとエンティティクラスのマッピング関係を追加し、TEST_USER テーブルを User クラスにマッピングします。

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

      @Override
      public void configPlugin(Plugins plugins) {
          init();
          DruidPlugin druidPlugin = createDruidPlugin();
          plugins.add(druidPlugin);
      
          ActiveRecordPlugin activeRecordPlugin = createActiveRecordPlugin(druidPlugin);
          activeRecordPlugin.addMapping("TOMCAT_TEST", User.class);
          plugins.add(activeRecordPlugin);
      }
      

   5. createDruidPlugin メソッドの定義。

      DruidPlugin プラグインを作成し、接続プールサイズ、SQLファイアウォール、接続エラー処理などの関連パラメータを設定するために使用されます。

      • PropKit の get メソッドを呼び出して、設定ファイルからURL、ユーザー名、パスワード、ドライバクラスなどのデータベース接続関連の属性値を取得します。次に、DruidPlugin オブジェクトを作成し、取得した属性値を使用して初期化します。

      • addFilter メソッドを呼び出して、データベースアクセスのパフォーマンスを統計するための StatFilter インスタンスを DruidPlugin に追加します。WallFilter インスタンスを作成し、setDbType メソッドを使用してデータベースタイプをOceanBaseに設定し、SQLファイアウォールフィルタリングを行うために DruidPlugin に追加します。

      • setInitialSize メソッドを呼び出して接続プールの初期サイズを設定し、setMaxPoolPreparedStatementPerConnectionSize メソッドで各接続プールの最大プリペアドステートメント数を設定し、setTimeBetweenConnectErrorMillis メソッドで2回の接続エラー間の時間間隔を設定し、setValidationQuery メソッドで接続の検証クエリ文を設定します。最後に、作成した DruidPlugin インスタンスを返します。

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

        private DruidPlugin createDruidPlugin() {
            DruidPlugin druidPlugin = new DruidPlugin(
                PropKit.get("db.app.pool.url"),
                PropKit.get("db.app.pool.username"),
                PropKit.get("db.app.pool.password"),
                PropKit.get("db.app.pool.driverClassName")
            );
        
            druidPlugin.addFilter(new StatFilter());
            WallFilter wallFilter = new WallFilter();
            wallFilter.setDbType(JdbcConstants.OCEANBASE);
            druidPlugin.addFilter(wallFilter);
        
            druidPlugin.setInitialSize(PropKit.getInt("db.app.pool.initialSize"));
            druidPlugin.setMaxPoolPreparedStatementPerConnectionSize(PropKit.getInt("db.app.pool.maxTotal"));
            druidPlugin.setTimeBetweenConnectErrorMillis(PropKit.getInt("db.app.pool.maxWaitMillis"));
            druidPlugin.setValidationQuery("select 1");
        
            return druidPlugin;
        }
        

   6. init メソッドの定義。

      データベース接続の初期化とデータベーステーブルの作成に使用されます。initDbConnection メソッドを呼び出してデータベース接続を初期化し、ActiveRecordPlugin インスタンスを返します。次に、SQL文を実行してユーザーテーブル TOMCAT_TEST が存在するかどうかをクエリします。テーブル TOMCAT_TEST が存在する場合、SQL文 DROP TABLE TOMCAT_TEST を実行してそのテーブルを削除します。その後、CREATE TABLE 文を実行して TOMCAT_TEST という名前のデータベーステーブルを作成します。このテーブルには ID と USERNAME の2つのフィールドが含まれます。最後に ActiveRecordPlugin プラグインの接続を閉じ、データベース接続を解放します。

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

      public void init() {
          ActiveRecordPlugin arp = initDbConnection();
      
          // Check if table exists
          boolean tableExists = Db.queryInt("SELECT COUNT(*) FROM information_schema.TABLES WHERE TABLE_SCHEMA = 'TEST' AND TABLE_NAME = 'TOMCAT_TEST'") > 0;
      
          // Drop table if it exists
          if (tableExists) {
              Db.update("DROP TABLE TOMCAT_TEST");
          }
      
          // Create table
          String sql = "CREATE TABLE TOMCAT_TEST (ID int, USERNAME varchar(50))";
          Db.update(sql);
      
          arp.stop();
      }
      

   7. initDbConnection メソッドの定義。

      データベース接続を初期化するために使用されます。まず、createDruidPlugin メソッドを呼び出して DruidPlugin オブジェクトを作成し、それを変数 druidPlugin に代入します。このメソッドは、データベース接続プールの管理に使用される DruidPlugin の作成と設定を担当します。次に、createActiveRecordPlugin メソッドを呼び出して ActiveRecordPlugin オブジェクトを作成し、DruidPlugin オブジェクトをパラメータとしてこのメソッドに渡します。このメソッドは、データベース操作の管理に使用される ActiveRecordPlugin の作成と設定を担当します。その後、druidPlugin.start メソッドを呼び出して DruidPlugin を起動し、データベース接続プールを初期化します。最後に activeRecordPlugin.start メソッドを呼び出して ActiveRecordPlugin を起動します。このメソッドは、設定に基づいてデータベース操作の関連設定を初期化します。

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

      private ActiveRecordPlugin initDbConnection() {
          DruidPlugin druidPlugin = createDruidPlugin();
          ActiveRecordPlugin activeRecordPlugin = createActiveRecordPlugin(druidPlugin);
      
          druidPlugin.start();
          activeRecordPlugin.start();
      
          return activeRecordPlugin;
      }
      

   8. ConfigInterceptor および ConfigHandler メソッドの定義。

      システムの初期化プロセス中にグローバル設定を行うために使用されます。

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

      @Override
      public void configInterceptor(Interceptors interceptors) {
      }
      
      @Override
      public void configHandler(Handlers handlers) {
      }
      

UserController.java ファイルの紹介

UserController.java ファイルは、getData メソッドを通じてデータベースにデータを挿入してクエリを実行し、クエリ結果をJSON形式でクライアントに返します。JFinalフレームワークが提供する Db クラスを使用してデータベース操作を実行し、カスタムの User クラスを使用してデータマッピングを行うことで、データベースの操作とデータ返却の機能を実現します。

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

1. 他のクラスとインターフェースの参照。

   現在のファイルに以下のインターフェースとクラスが含まれていることを宣言します：

   • Controller クラス：リクエストとレスポンスを処理するために使用されます。
   • Db クラス：データベース操作を実行するために使用されます。
   • Record クラス：データベース操作（データのクエリ、挿入、更新、削除など）を実行するために使用されます。
   • ArrayList クラス：空のリストを作成するために使用されます。
   • User クラス：データベーステーブルをマッピングするために使用されます。
   • List インターフェース：クエリ結果セットを操作するために使用されます。

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

   import com.jfinal.core.Controller;
   import com.jfinal.plugin.activerecord.Db;
   import com.jfinal.plugin.activerecord.Record;
   
   import java.util.ArrayList;
   import java.util.List;
   

2. UserController クラスの定義。

   JFinalフレームワークにコントローラを提供するために使用され、getData メソッドを使用してデータベースに対するデータの挿入およびクエリ操作を実行します。

   1. データの挿入。10個の Record オブジェクトを含むリスト dataList を作成します。各 Record オブジェクトは異なる ID および USERNAME フィールド値を持ちます。次に、Db.batchSave メソッドを使用して、dataList リスト内のレコードを TOMCAT_TEST という名前のデータベーステーブルに一括保存します。

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

              for (int i = 0; i < 10; i++) {
                  Record record = new Record().set("ID", i).set("USERNAME", "tomcat 连接池测试" + i);
                  dataList.add(record);
              }
              Db.batchSave("TOMCAT_TEST", dataList, dataList.size());
      

   2. データのクエリ。Db.find メソッドを通じてSQLクエリを実行し、結果を resultList リストに保存します。拡張 for ループを使用して、resultList リスト内の各 Record オブジェクトを反復処理します。getStr メソッドを通じて Record オブジェクト内の指定されたフィールドの値を取得し、System.out.println メソッドを使用して出力します。

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

          List<Record> resultList = Db.find("SELECT * FROM TOMCAT_TEST");
          for (Record result : resultList) {
              System.out.println(result.getStr("USERNAME"));
          }
      

   3. データの変更。ループを使用して10回反復し、各反復で1つの更新文を実行します。更新文は Db.update メソッドを使用して実行され、条件に基づいて TOMCAT_TEST という名前のデータベーステーブル内のレコードを更新します。

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

          for (int i = 0; i < 10; i++) {
              Db.update("UPDATE TOMCAT_TEST SET USERNAME = 'POOl 连接池测试" + i + "' WHERE ID = " + i);
          }
      

   4. 変更後のデータのクエリ。TOMCAT_TEST という名前のデータベーステーブルをクエリし、結果を modifiedList に保存します。-----修改后----- というプロンプト情報を出力します。modifiedList を反復処理し、各レコードの USERNAME フィールド値を出力します。renderJson メソッドを使用して、応答メッセージ Data retrieved successfully をJSON形式でレンダリングし、クライアントに返します。

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

              List<Record> modifiedList = Db.find("SELECT * FROM TOMCAT_TEST");
              System.out.println("-----修改后-----");
              for (Record modified : modifiedList) {
                  System.out.println(modified.getStr("USERNAME"));
              }
              renderJson("Data retrieved successfully");
      

User.java ファイルの紹介

User.java ファイルは、データベーステーブルとJavaオブジェクトのマッピングを実装するために使用されます。

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

1. Model クラスの参照。

   Model クラスは、データベーステーブルのマッピングとデータの操作に使用されます。

2. User クラスの定義。

   User クラスは、継承した Model クラスが提供するメソッドを通じてデータベース操作を実行します。

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

   import com.jfinal.plugin.activerecord.Model;
   
       public class User extends Model<User> {
           public static final User dao = new User();
   }
   

完全なコードの表示

<?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>tomcat-mysql-client</artifactId>
    <version>1.0-SNAPSHOT</version>
    <!-- Packaging method (default to jar) -->
    <packaging>war</packaging>

    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>
    <dependencies>
        <dependency>
            <groupId>com.jfinal</groupId>
            <artifactId>jfinal</artifactId>
            <version>5.0.6</version>
        </dependency>

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

        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-dbcp2</artifactId>
            <version>2.9.0</version>
        </dependency>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>5.1.40</version>
            </dependency>

    </dependencies>
</project>

    #Apache Commons DBCP2 Connection Pool
    #Database Connection Pool Driver Class Name
    db.app.pool.driverClassName=com.mysql.jdbc.Driver
    #Database URL
    db.app.pool.url=jdbc:mysql:////host:port/schema_name?characterEncoding=UTF-8
    #Database username
    db.app.pool.username=user_name
    #Database password
    db.app.pool.password=******
    #Initial size of connection pool
    db.app.pool.initialSize=3
    #Maximum number of connections in the connection pool
    db.app.pool.maxTotal=10
    #Maximum number of idle connections in the connection pool
    db.app.pool.maxIdle=20
    #Minimum number of idle connections in the connection pool
    db.app.pool.minIdle=5
    #Maximum wait time for obtaining connections (in milliseconds)
    db.app.pool.maxWaitMillis=5000
    #Verify the connection's query statement
    db.app.pool.validationQuery=select 1

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd" id="WebApp_ID" version="3.0">
    <filter>
        <filter-name>jfinal</filter-name>
        <filter-class>com.jfinal.core.JFinalFilter</filter-class>
        <init-param>
            <param-name>configClass</param-name>
            <!-- your jfinal configuration location -->
            <param-value>com.oceanbase.testjfinal.config.UserConfig</param-value>
        </init-param>
    </filter>

    <filter-mapping>
        <filter-name>jfinal</filter-name>
        <url-pattern>/*</url-pattern>
    </filter-mapping>
</web-app>

package com.oceanbase.testtomcat.config;

import com.alibaba.druid.filter.stat.StatFilter;
import com.alibaba.druid.util.JdbcConstants;
import com.alibaba.druid.wall.WallFilter;
import com.jfinal.config.*;
import com.jfinal.kit.PropKit;
import com.jfinal.plugin.activerecord.ActiveRecordPlugin;
import com.jfinal.plugin.activerecord.Db;
import com.jfinal.plugin.activerecord.dialect.MysqlDialect;
import com.jfinal.plugin.druid.DruidPlugin;
import com.jfinal.template.Engine;
import com.oceanbase.testtomcat.controller.UserController;
import com.oceanbase.testtomcat.pojo.User;

public class UserConfig extends JFinalConfig {
    @Override
    public void configConstant(Constants constants) {
        // Read properties configuration
        PropKit.use("application.properties");
    }

    @Override
    public void configRoute(Routes routes) {
        // Set the default access page for project startup, which does not need to be set in the web.
        routes.add("/hello", UserController.class);

    }

    @Override
    public void configEngine(Engine engine) {
    }

    @Override
    public void configPlugin(Plugins plugins) {
        init();
        DruidPlugin druidPlugin = createDruidPlugin();
        plugins.add(druidPlugin);

        ActiveRecordPlugin activeRecordPlugin = createActiveRecordPlugin(druidPlugin);
        activeRecordPlugin.addMapping("TOMCAT_TEST", User.class);
        plugins.add(activeRecordPlugin);
    }

    private DruidPlugin createDruidPlugin() {
        DruidPlugin druidPlugin = new DruidPlugin(
                PropKit.get("db.app.pool.url"),
                PropKit.get("db.app.pool.username"),
                PropKit.get("db.app.pool.password"),
                PropKit.get("db.app.pool.driverClassName")
        );

        druidPlugin.addFilter(new StatFilter());
        WallFilter wallFilter = new WallFilter();
        wallFilter.setDbType(JdbcConstants.OCEANBASE);
        druidPlugin.addFilter(wallFilter);

        druidPlugin.setInitialSize(PropKit.getInt("db.app.pool.initialSize"));
        druidPlugin.setMaxPoolPreparedStatementPerConnectionSize(PropKit.getInt("db.app.pool.maxTotal"));
        druidPlugin.setTimeBetweenConnectErrorMillis(PropKit.getInt("db.app.pool.maxWaitMillis"));
        druidPlugin.setValidationQuery("select 1 from dual");

        return druidPlugin;
    }

    private ActiveRecordPlugin createActiveRecordPlugin(DruidPlugin druidPlugin) {
        ActiveRecordPlugin activeRecordPlugin = new ActiveRecordPlugin(druidPlugin);
        activeRecordPlugin.setDialect(new MysqlDialect());

        return activeRecordPlugin;
    }

    public void init() {
        ActiveRecordPlugin arp = initDbConnection();

        // Check if table exists
        boolean tableExists = Db.queryInt("SELECT COUNT(*) FROM information_schema.TABLES WHERE TABLE_SCHEMA = 'TEST' AND TABLE_NAME = 'TOMCAT_TEST'") > 0;

        // Drop table if it exists
        if (tableExists) {
            Db.update("DROP TABLE TOMCAT_TEST");
        }

        // Create table
        String sql = "CREATE TABLE TOMCAT_TEST (ID int, USERNAME varchar(50))";
        Db.update(sql);

        arp.stop();
    }
    private ActiveRecordPlugin initDbConnection() {
        DruidPlugin druidPlugin = createDruidPlugin();
        ActiveRecordPlugin activeRecordPlugin = createActiveRecordPlugin(druidPlugin);

        druidPlugin.start();
        activeRecordPlugin.start();

        return activeRecordPlugin;
    }

    @Override
    public void configInterceptor(Interceptors interceptors) {
    }

    @Override
    public void configHandler(Handlers handlers) {
    }
}

package com.oceanbase.testtomcat.controller;

import com.jfinal.core.Controller;
import com.jfinal.plugin.activerecord.Db;
import com.jfinal.plugin.activerecord.Record;

import java.util.ArrayList;
import java.util.List;

public class UserController extends Controller {

    public void getData() {
        try {
            List<Record> dataList = new ArrayList<>();
            // 插入数据
            for (int i = 0; i < 10; i++) {
                Record record = new Record().set("ID", i).set("USERNAME", "tomcat 连接池测试" + i);
                dataList.add(record);
            }
            Db.batchSave("TOMCAT_TEST", dataList, dataList.size());
            // 查询数据
            List<Record> resultList = Db.find("SELECT * FROM TOMCAT_TEST");
            for (Record result : resultList) {
                System.out.println(result.getStr("USERNAME"));
            }
            // 修改数据
            for (int i = 0; i < 10; i++) {
                Db.update("UPDATE TOMCAT_TEST SET USERNAME = 'POOl 连接池测试" + i + "' WHERE ID = " + i);
            }
            // 查询修改后的数据
            List<Record> modifiedList = Db.find("SELECT * FROM TOMCAT_TEST");
            System.out.println("-----修改后-----");
            for (Record modified : modifiedList) {
                System.out.println(modified.getStr("USERNAME"));
            }
            renderJson("Data retrieved successfully");
        } catch (Exception e) {
            e.printStackTrace();
            renderJson("Error occurred");
        }
    }
}

package com.oceanbase.testtomcat.pojo;

import com.jfinal.plugin.activerecord.Model;

    public class User extends Model<User> {
        public static final User dao = new User();

}

関連情報

OceanBase Connector/J の詳細については、OceanBase JDBCドライバをご参照ください。