HibernateによるOceanBase Cloudデータベース接続サンプルプログラム

本記事では、HibernateフレームワークとOceanBase Cloudデータベースを使用して、テーブルの作成、データの挿入、クエリなどの基本的な操作を実現するアプリケーションの構築方法を紹介します。

クリックしてjava-oceanbase-hibernateサンプルプロジェクトをダウンロード

前提条件

• OceanBase Cloudデータベースアカウントに登録し、クラスタインスタンスとMySQL互換モードのテナントを作成していること。詳細については、クラスタインスタンスの作成およびテナントの作成をご参照ください。
• JDK 1.8とMavenをインストール済みであること。
• IntelliJ IDEAをインストール済みであること。

操作手順

1. OceanBase Cloudの接続文字列を取得します。
2. java-oceanbase-hibernate プロジェクトをIDEAにインポートします。
3. java-oceanbase-hibernate プロジェクトのデータベース接続情報を修正します。
4. java-oceanbase-hibernate プロジェクトを実行します。

ステップ１：OceanBase Cloudの接続文字列を取得する

1. OceanBase Cloudコンソールにログインします。インスタンスリストページで、対象インスタンスの情報を展開し、対象テナントで、接続 > 接続文字列を取得 を選択します。

   詳細な操作については、接続文字列の取得をご参照ください。

2. 作成済みのOceanBase Cloudに基づいて、以下のURLの該当する情報を入力します。

   説明

   hibernate.cfg.xml ファイルには、ここのURL情報が必要です。

   jdbc:oceanbase://host:port/schema_name?user=$user_name&password=$password
   

   パラメータ説明：

   • host：OceanBase Cloudの接続アドレスを指定します。例：t********.********.oceanbase.cloud。
   • port：OceanBase Cloudの接続ポートを指定します。デフォルトは3306です。
   • schema_name：アクセスするスキーマ名です。
   • user_name：データベースへのアクセスアカウントを指定します。
   • password：アカウントのパスワードを指定します。

その他のURLパラメータの詳細については、データベースURLをご参照ください。

ステップ2：java-oceanbase-hibernate プロジェクトを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. プロジェクトの状況を確認します。

ステップ3：java-oceanbase-hibernate プロジェクトのデータベース接続情報を修正する

ステップ1：OceanBase Cloudの接続文字列を取得する の情報に基づいて、hibernate.cfg.xml ファイル内のデータベース接続情報を修正します。

例：

• データベースドライバーの名前：com.mysql.cj.jdbc.Driver
• OceanBase Cloudの接続アドレスは t5******.********.oceanbase.cloud です。
• アクセスポートは3306を使用します。
• アクセスするスキーマ名は test です。
• テナントの接続アカウントは mysql001 です。
• パスワードは ****** です。

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

<property name="hibernate.connection.driver_class">com.mysql.cj.jdbc.Driver</property>
<property name="hibernate.connection.url">jdbc:mysql://t5******.********.oceanbase.cloud:3306/test</property>
<property name="hibernate.connection.username">mysql001</property>
<property name="hibernate.connection.password">******</property>

ステップ4：java-oceanbase-hibernate プロジェクトを実行する

実行パス

1. プロジェクト構造の src > test > java から TestHibernate.java ファイルを見つけます。
2. ツールメニューバーで 実行(U) > 実行 > TestHibernate を選択するか、右上の緑色の三角形を直接クリックして実行します。
3. IDEAのコンソールを使用して、プロジェクトのログ情報と出力結果を確認します。

実行結果

User{id=2, name='update'}
User{id=3, name='user_insert3'}
User{id=4, name='user_insert4'}
User{id=5, name='user_insert5'}

よくある質問

1. 接続タイムアウト

接続タイムアウトの問題が発生した場合は、JDBC URLに接続タイムアウトパラメータを設定できます。

jdbc:mysql://host:port/database?connectTimeout=30000&socketTimeout=60000

2. 文字セットの問題

正しい文字エンコーディングを確保するために、JDBC URLに正しい文字セットパラメータを設定します。

jdbc:mysql://host:port/database?characterEncoding=utf8&useUnicode=true

3. SSL接続

OceanBase CloudデータベースとのSSL接続を有効にするには、JDBC URLに以下のパラメータを追加します。

jdbc:mysql://host:port/database?useSSL=true&requireSSL=true

4. アカウントパスワードに含まれる特殊文字

ユーザー名やパスワードに特殊文字（例：#）が含まれている場合は、URLエンコードが必要です。

String encodedPassword = URLEncoder.encode(password, "UTF-8");

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

java-oceanbase-hibernate をクリックしてプロジェクトコードをダウンロードします。これは java-oceanbase-hibernate.zip という圧縮ファイルです。

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

│--pom.xml
│
├─.idea
├─src
│  ├─main
│  │  ├─java
│  │  │  └─com
│  │  │      └─oceanbase
│  │  │          ├─dao
│  │  │          │   └─--UserDao.java
│  │  │          │
│  │  │          └─pojo
│  │  │              └─--User.java
│  │  │
│  │  └─resources
│  │      │--hibernate.cfg.xml
│  │      │
│  │      └─com
│  │          └─oceanbase
│  │              └─pojo
│  │                  └─--User.hbm.xml
│  │
│  └─test
│      └─java
│          └─--TestHibernate.java
│
└─target

ファイルの説明：

• pom.xml：Mavenプロジェクトの設定ファイルで、プロジェクトの依存関係、プラグイン、ビルドなどの情報が含まれます。
• .idea：IDE（統合開発環境）で使用されるディレクトリで、プロジェクト関連の設定情報を格納します。
• src：プロジェクトのソースコードを格納するディレクトリです。
• main: 主要なソースコードとリソースファイルを格納するディレクトリ。
• java: Javaソースコードを格納するディレクトリ。
• com: Javaパッケージのルートディレクトリ。
• oceanbase: プロジェクトのルートディレクトリ。
• dao: データアクセスオブジェクト（Data Access Object）パッケージを格納するディレクトリで、データベースやその他のデータストレージサービスへのアクセスに使用されます。
• UserDao.java：ユーザーデータアクセスオブジェクトで、ユーザーデータの追加、削除、変更、検索などの操作に使用されます。
• User.java：ユーザー永続化オブジェクトで、ユーザーデータテーブルのフィールドをマッピングするために使用されます。
• pojo: 永続化オブジェクト（Plain Old Java Object）で、データベーステーブルに対応するJavaクラスを格納します。データベーステーブルやその他のデータストレージ構造のマッピングに使用されます。
• resources: リソースファイルを格納するディレクトリで、設定ファイルやSQLファイルなどが含まれます。
• hibernate.cfg.xml: Hibernateの設定ファイルで、Hibernateの基本パラメータやデータソースの設定などの情報を定義します。
• User.hbm.xml: ユーザー永続化オブジェクトのマッピングファイルで、ユーザー永続化オブジェクトとユーザーデータテーブル間のマッピング関係を定義します。
• test: テストコードとリソースファイルを格納するディレクトリ。
• TestHibernate.java: Hibernateのテスト用Javaクラスです。
• 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> を使用して、プロジェクトの依存関係を java-oceanbase-hibernate と指定します。
   3. <version> を使用して、プロジェクトのバージョン番号を 1.0-SNAPSHOT と指定します。

   コード：

    <groupId>com.oceanbase</groupId>
    <artifactId>java-oceanbase-hibernate</artifactId>
    <version>1.0-SNAPSHOT</version>
   

4. <build> を使用して、プロジェクトのビルドプロセスを定義します。

   1. <plugins> を使用して、プロジェクトで設定するプラグインを指定します。
   2. <plugin> を使用して、プロジェクトで1つのプラグインを設定します。
   3. <groupId> を使用して、プロジェクト識別子を org.apache.maven.plugins と指定します。
   4. <artifactId> を使用して、プロジェクトの依存関係を maven-compiler-plugin と指定します。
   5. <configuration> を使用して、設定するプラグインのパラメータを指定します。
   6. <source> を使用して、コンパイラのソースコードバージョンを8と指定します。
   7. <target> を使用して、コンパイラのターゲットコードバージョンを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. <dependencies> を使用して、プロジェクトが依存するコンポーネントを定義します。

   1. 依存関係の所属組織を com.oceanbase、名前を oceanbase-client、バージョン番号を 2.4.2 と指定します。

      コード：

          <dependencies>
          <dependency>
              <groupId>com.oceanbase</groupId>
              <artifactId>oceanbase-client</artifactId>
              <version>2.4.2</version>
          </dependency>
          </dependencies>
      

   2. 依存関係のテストフレームワークを junit、名前を junit、バージョン番号を 4.13 と指定します。

      コード：

          <dependencies>
          <dependency>
              <groupId>junit</groupId>
              <artifactId>junit</artifactId>
              <version>4.13</version>
          </dependency>
          </dependencies>
      

   3. 依存関係のフレームワークを org.hibernate、コアライブラリを hibernate-core、バージョン番号を 5.2.17.Final と指定します。

      コード：

      <dependencies>
        <dependency>
            <groupId>org.hibernate</groupId>
            <artifactId>hibernate-core</artifactId>
            <version>5.2.17.Final</version>
        </dependency>
      </dependencies>
      

   4. 依存関係のフレームワークを org.hibernate、データソースライブラリを hibernate-c3p0、バージョン番号を 5.2.17.Final と指定します。

      コード：

      <dependencies>
        <dependency>
            <groupId>org.hibernate</groupId>
            <artifactId>hibernate-c3p0</artifactId>
            <version>5.2.17.Final</version>
        </dependency>
      </dependencies>
      

User.hbm.xmlのコード紹介

User.hbm.xml ファイルは、Hibernateのマッピングファイルであり、Javaオブジェクトをデータベースのテーブルにマッピングするために使用されます。

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

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

   このファイルがXMLファイルであり、使用するXMLバージョンが 1.0、文字エンコーディング方式が UTF-8 であることを宣言します。同時に、HibernateマッピングファイルのDTDバージョンと場所を指定し、DTDドキュメントタイプを hibernate-mapping、バージョンを3.0、言語をEN、ファイルのURLを http://www.hibernate.org/dtd/hibernate-mapping-3.0.dtd と指定します。

   コード：

   <?xml version="1.0" encoding="UTF-8"?>
   <!DOCTYPE hibernate-mapping PUBLIC
           "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
           "http://www.hibernate.org/dtd/hibernate-mapping-3.0.dtd">
   

2. マッピングファイルの設定。

   User という名前のエンティティクラスを test_hibernate_mysql という名前のデータベーステーブルにマッピングするHibernateマッピングファイルを定義します。

   1. package 属性を使用して、マッピングファイル内のJavaパッケージを com.oceanbase.pojo と指定します。
   2. class タグを使用してデータテーブル内のデータをマッピングし、name 属性でJavaクラス名を User、table 属性でデータベーステーブル名を test_hibernate_mysql と指定します。
   3. id を使用して主キープロパティを定義し、name 属性でJavaクラス User のメンバー変数を id、column 属性でデータベースフィールド名を USER_ID と指定します。
   4. generator を使用して主キー生成戦略を定義し、class 属性で主キージェネレーターのタイプを sequence、param 要素でデータベース内のシーケンス名を SQ_USER と指定します。name 属性でこのプロパティがデータベーステーブル内の USER_NAME 列に対応することを指定し、データ型を文字列と指定します。

   コード：

   <hibernate-mapping package="com.oceanbase.pojo">
   <class name="User" table="test_hibernate_mysql">
       <!-- Configure primary key generation strategy -->
       <id name="id" column="USER_ID">
           <generator class="sequence">
               <param name="sequence">SQ_USER</param>
           </generator>
       </id>
       <!-- Configuration Tables and Properties -->
       <property name="name" column="USER_NAME" type="string"/>
   </class>
   </hibernate-mapping>
   

hibernate.cfg.xmlのコード紹介

hibernate.cfg.xml ファイルはHibernateの設定ファイルであり、Hibernateの実行環境とデータベース接続パラメータを設定するために使用されます。

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

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

   このファイルがXMLファイルであり、使用しているXMLバージョンが 1.0、文字エンコーディング方式が UTF-8 であることを宣言します。同時に、Hibernate設定ファイルのDTDバージョンと場所を指定し、DTDドキュメントタイプを hibernate-configuration、バージョンを3.0、言語をEN、ファイルのURLを http://www.hibernate.org/dtd/hibernate-configuration-3.0.dtd と指定します。

   コード：

   <?xml version="1.0" encoding="utf-8"?>
   <!DOCTYPE hibernate-configuration PUBLIC
           "-//Hibernate/Hibernate Configuration DTD 3.0//EN"
           "http://www.hibernate.org/dtd/hibernate-configuration-3.0.dtd">
   

2. configuration パラメータの設定。

<hibernate-configuration> ルート要素内の <session-factory> 要素を使用して、Hibernateのセッションファクトリを設定します。これはセッションオブジェクトの作成と管理に使用されます。セッションファクトリには、データベース接続用のドライバークラス名、URL、ユーザー名とパスワード、接続プール関連パラメータ、データベース方言、SQL出力とフォーマット、データベーステーブルの自動作成、現在のセッションコンテキスト、バッチ処理、二次キャッシュなどの設定が含まれます。

1. データベース情報の設定。

  Hibernateとデータベース接続のパラメータを設定します。これには、データベース接続用のドライバークラス名、URL、ユーザー名、パスワードが含まれます。

  *   `hibernate.connection.driver_class` を使用して、データベースドライバーを `com.mysql.cj.jdbc.Driver` と指定します。これはOceanBase Cloudデータベースへの接続を確立するために使用されます。
  *   `hibernate.connection.url` 要素を使用して、データベースのURLを指定します。これには、データベースのアドレス、ポート番号、データベース名などの情報が含まれます。
  *   `hibernate.connection.username` 要素を使用して、データベース接続用のユーザー名を指定します。
  *   `hibernate.connection.password` 要素を使用して、データベース接続用のパスワードを指定します。

  **コード：**

  ```xml
      <property name="hibernate.connection.driver_class">com.mysql.cj.jdbc.Driver</property>
      <property name="hibernate.connection.url">jdbc:oceanbase://host:port/schema_name</property>
      <property name="hibernate.connection.username">user_name</property>
      <property name="hibernate.connection.password">******</property>
  ```

2. 接続プール情報の設定。

  Hibernateが使用する接続プールの関連パラメータを設定します。接続プールをC3P0と指定します。パラメータの設定には、接続プールの最大接続数と最小接続数、タイムアウト時間、接続の最大アイドル時間、キャッシュされるStatementオブジェクトの数、接続のアイドルテスト時間、一度に取得する接続数、接続の検証方法が含まれます。

    <main id="notice" type='explain'>
    <h4>説明</h4>
    <p>以下のパラメータは参考用です。サポートされているパラメータの完全なリストではありません。他のパラメータを設定する必要がある場合は、関連ドキュメントを参照して詳細なパラメータ情報を入手してください。</p>
    </main>

  *   `hibernate.connection.provider_class` を使用して、接続プールをC3P0と指定します。これはデータベース接続の作成と解放を管理するために使用されます。
  *   `hibernate.c3p0.max_size` を使用して、接続プールの最大接続数を60と指定します。
  *   `hibernate.c3p0.min_size` を使用して、接続プールの最小接続数を30と指定します。
  *   `hibernate.c3p0.checkoutTimeout` を使用して、接続プールが接続を取得するタイムアウト時間を30000ミリ秒と指定します。
  *   `hibernate.c3p0.timeout` を使用して、接続プールの最大アイドル時間を2000ミリ秒と指定します。この時間を超えると接続は閉じられます。
  *   `hibernate.c3p0.max_statements` を使用して、接続プールでキャッシュされる最大SQLステートメント数を100と指定します。
  *   `hibernate.c3p0.idle_test_period` を使用して、接続プール内のアイドル接続の検出周期を3000ミリ秒と指定します。
  *   `hibernate.c3p0.acquire_increment` を使用して、接続プールが動的に増加する際の接続数の増分を3と指定します。
  *   `hibernate.c3p0.validate` を使用して、接続プール接続時の検証をtrueと指定します。

  **コード：**

  ```xml
  <property name="hibernate.connection.provider_class">org.hibernate.c3p0.internal.C3P0ConnectionProvider</property>
  <property name="hibernate.c3p0.max_size">60</property>
  <property name="hibernate.c3p0.min_size">30</property>
  <property name="hibernate.c3p0.checkoutTimeout">30000</property>
  <property name="hibernate.c3p0.timeout">20000</property>
  <property name="hibernate.c3p0.max_statements">100</property>
  <property name="hibernate.c3p0.idle_test_period">3000</property>
  <property name="hibernate.c3p0.acquire_increment">3</property>
  <property name="hibernate.c3p0.validate">true</property>
  ```

3. SQLインタラクション情報を設定します。 Hibernateとデータベース接続に関する情報を設定します。データベースの方言、SQLの出力とフォーマット、テーブルの自動作成、現在のセッションコンテキスト、バッチ処理サイズ、キャッシュの使用、マッピングファイルの読み込みが含まれます。

   • dialect を使用して、特定のデータベースとの互換性を確保するために、使用するデータベース方言をMySQL 5.7と指定します。
   • hibernate.show_sql を使用して、Hibernateが生成したSQLステートメントをコンソールに出力するかどうかを設定します。
   • hibernate.format_sql を使用して、出力されるSQLステートメントをフォーマットするかどうかを設定します。
   • hbm2ddl.auto を使用して、テーブルの自動作成を設定します。
   • current_session_context_class を使用して、スレッドレベルの現在のセッションコンテキストを使用することを指定します。
   • hibernate.jdbc.batch_size を使用して、バッチ処理のサイズを設定します。
   • hibernate.cache.use_second_level_cache を使用して、二次キャッシュを有効にするかどうかを設定します。
   • マッピングファイルとして com/oceanbase/pojo/User.hbm.xml を読み込むことを指定します。

   コード：

     <property name="dialect">org.hibernate.dialect.MySQL57Dialect</property>
     <property name="hibernate.show_sql">true</property>
     <property name="hibernate.format_sql">true</property>
     <property name="hbm2ddl.auto">create</property>
     <property name="current_session_context_class">thread</property>
     <property name="hibernate.jdbc.batch_size">10</property>
     <property name="hibernate.cache.use_second_level_cache">false</property>
     <mapping resource="com/oceanbase/pojo/User.hbm.xml"/>
   

UserDao.javaコードの紹介

UserDao.java ファイルは、ユーザーデータアクセスオブジェクト（DAO）クラスを通じて、Sessionオブジェクトを使用してユーザーデータの追加、削除、変更、検索操作を実装します。

UserDao.java ファイルのコードには、主に以下の部分が含まれます：

1. 他のクラスとインターフェースのインポート。

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

   • User クラス：ユーザーオブジェクトを操作するために使用されます。
   • Session クラス：データベースとのやり取りに使用されます。
   • SessionFactory クラス：Sessionインスタンスを作成するために使用されます。
   • Transaction クラス：データベーストランザクションを管理するために使用されます。
   • Configuration クラス：Hibernateの設定ファイルを読み込むために使用されます。
   • Query クラス：クエリ操作を実行するために使用されます。
   • List インターフェース：クエリ結果の集合を操作するために使用されます。

   コード：

   import com.oceanbase.pojo.User;
   import org.hibernate.Session;
   import org.hibernate.SessionFactory;
   import org.hibernate.Transaction;
   import org.hibernate.cfg.Configuration;
   import org.hibernate.query.Query;
   import java.util.List;
   

2. UserDao クラスの定義。

UserDao のJavaクラスは、データアクセスオブジェクトとして、ユーザーオブジェクトの永続化操作に使用されます。このクラスは、データベースとのやり取りに関連する一連のメソッドをカプセル化し、ユーザーオブジェクトの追加、削除、変更、検索などの操作を行います。UserDao クラスのメソッドを呼び出すことで、データベースと簡単にやり取りし、永続化操作を実現できます。

1. UserDao クラスのインスタンスを初期化します。

   オブジェクト初期化ブロックを使用して、クラスのインスタンス化プロセスで Session オブジェクトを初期化します。

   まず、Configuration オブジェクトを作成し、configure メソッドを呼び出してHibernateの設定ファイル（hibernate.cfg.xml）を読み込みます。次に、buildSessionFactory メソッドを呼び出して SessionFactory オブジェクトを作成します。最後に、openSession メソッドを呼び出して Session オブジェクトを作成し、session 変数に代入します。

   コード：

   private Session session;
   {
       Configuration cfg = new Configuration().configure();
       // Create SessionFactory
       SessionFactory sessionFactory = cfg.buildSessionFactory();
       session = sessionFactory.openSession();
   } //Read the hibernate.cfg.xml file
   

2. IDを指定して対応するユーザー情報を検索します。

   selectUserById メソッドを使用して、指定されたIDパラメータに対応するユーザー情報を検索します。

   session の get メソッドを使用し、渡された User.class と ID パラメータに基づいて、データベースから対応するIDのUserレコードを取得し、user 変数に格納します。

   コード：

   public User selectUserById(int ID) {
       User user = session.get(User.class, ID);
       return user;
   }
   

3. ユーザー名に基づいてユーザー情報を検索します。

   selectUserbyName メソッドを使用して、ユーザー名に基づいてユーザー情報を検索します。 まず、指定された名前のユーザーデータを検索するためのHQL（Hibernate Query Language）ステートメントを定義します。テーブル名は test_hibernate_mysql、テーブルエイリアスは u、検索フィールド名は name です。Session オブジェクトの createQuery メソッドを使用して Query オブジェクトを作成し、HQLステートメントとエンティティクラスをパラメータとして渡します。Query オブジェクトの setParameter メソッドを使用してクエリパラメータを設定します。ここで、0 はパラメータの位置を表し、name はパラメータの値を表します。Query オブジェクトの list メソッドを使用してクエリを実行し、クエリ結果を User オブジェクトのリストに変換します。

   コード：

   public List<User> selectUserbyName(String name) {
     String sql = "FROM test_hibernate_mysql u WHERE u.name =?";
     Query<User> query = session.createQuery(sql, User.class);
     query.setParameter(0, name);
     List<User> users = query.list();
     return users;
   }
   

4. すべてのユーザーデータを照会します。

   selectUser メソッドにより、すべてのユーザーデータを照会するメソッドが実装されています。 すべてのユーザーデータを照会するためのSQLステートメントを定義します。Session オブジェクトの createNativeQuery メソッドを使用して Query オブジェクトを作成し、SQLステートメントをパラメータとして渡します。次に、addEntity メソッドを使用してエンティティクラス User をクエリに追加し、クエリ結果を User オブジェクトのリストに変換します。Query オブジェクトの getResultList メソッドを使用してクエリを実行し、クエリ結果をUserオブジェクトのリストに変換します。

   コード：

   public List<User> selectUser() {
       String sql = "SELECT * FROM test_hibernate_mysql";
       Query<User> query = session.createNativeQuery(sql).addEntity(User.class);
       List<User> users = query.getResultList();
       return users;
   }
   

5. ユーザーデータを挿入します。

   insertUser メソッドにより、ユーザー情報を挿入します。 User 型のパラメータ user を指定し、挿入するユーザーオブジェクトを渡します。Hibernate Sessionの beginTransaction メソッドを呼び出してトランザクションオブジェクトを作成し、変数 beginTransaction に格納します。save メソッドを使用してユーザーオブジェクトをデータベースに保存します。Session の getTransaction メソッドを呼び出して現在のトランザクションを取得し、commit メソッドを呼び出してトランザクションをコミットします。これにより、前の操作がデータベースに永続化され、挿入操作の結果が返されます。

   コード：

   public int insertUser(User user) {
       // open transaction
       Transaction beginTransaction = session.beginTransaction();
       session.save(user);
       session.getTransaction().commit();
       return 1;
   }
   

6. ユーザーデータを削除します。

   deleteUserById メソッドにより、データベースから指定されたIDに対応するユーザーレコードを削除します。 整数型パラメータ id を指定し、削除するユーザーIDを渡します。Hibernate Sessionの beginTransaction メソッドを呼び出して新しいトランザクションを開始します。get メソッドを使用して、指定されたユーザー ID とエンティティクラスタイプ (User.class) に対応するユーザーオブジェクトを取得します。delete メソッドを使用してユーザーオブジェクトを削除します。Session の getTransaction メソッドを呼び出して現在のトランザクションを取得し、commit メソッドを呼び出してトランザクションをコミットします。これにより、ユーザー情報の削除がデータベースに永続化され、削除操作の結果が返されます。

   コード：

   public int deleteUserById(int id) {
       // open transaction
       session.beginTransaction();
       User user = session.get(User.class, id);
       session.delete(user);
       session.getTransaction().commit();
       return 1;
   }
   

7. ユーザーデータを変更します。

   updateUserById メソッドにより、対応するユーザー情報を更新します。 User 型のパラメータ user を指定し、更新するユーザーデータを指定します。Sessionオブジェクトの beginTransaction メソッドを使用してトランザクションを開始します。Session オブジェクトの get メソッドを使用して、ユーザーIDに対応する User オブジェクトを取得します。Session オブジェクトの merge メソッドを使用して、渡された User オブジェクトと取得した User オブジェクトをマージし、渡されたユーザーデータをデータベースに更新します。Session オブジェクトの getTransaction メソッドを使用して現在のトランザクションを取得し、commit メソッドを呼び出してトランザクションをコミットします。これにより、変更操作の結果が返されます。

   コード：

   public int updateUserById(User user) {
       // open transaction
       session.beginTransaction();
       User user1 = session.get(User.class, user.getId());
       session.merge(user);
       session.getTransaction().commit();
       return 1;
   }
   

User.java コードの紹介

User.java ファイルは、ユーザーデータアクセスオブジェクト（DAO）クラスを通じて、Sessionオブジェクトを使用してユーザーデータの追加、削除、変更、検索操作を実装しています。

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

1. 他のクラスのインポート。

   このファイルがJPAアノテーションを使用して関連クラスとデータベーステーブルのマッピング関係を設定していることを宣言します：

   • Column アノテーション：エンティティクラスのプロパティとデータベーステーブルの列との対応関係を識別するために使用されます。
   • Entity アノテーション：データベース内のテーブルをマッピングするために使用されます。
   • GeneratedValue アノテーション：このプロパティの値が自動生成されることを示すために使用されます。
   • GenerationType アノテーション：主キーの生成戦略を指定するために使用されます。
   • Id アノテーション：一意の識別プロパティを指定するために使用されます。
   • Table アノテーション：エンティティクラスに対応するテーブル名を示すために使用されます。

   コード：

   import javax.persistence.Column;
   import javax.persistence.Entity;
   import javax.persistence.GeneratedValue;
   import javax.persistence.GenerationType;
   import javax.persistence.Id;
   import javax.persistence.Table;
   

2. データベース内のテーブルをマッピングします。

   データベーステーブルのエンティティクラスをマッピングし、エンティティクラスに対応するテーブル名を test_hibernate_mysql と指定します。

   コード：

   @Entity
   @Table(name = "test_hibernate_mysql")
   

3. User クラスを定義します。

   データベース内の test_hibernate_mysql という名前のテーブルとマッピングするために使用されます。

   1. id と name の2つのプロパティを定義します。 アノテーションを使用して、User クラスの id と name プロパティとデータベーステーブルの列との対応関係を識別します。 @Id アノテーションで id プロパティを主キーとして識別し、@GeneratedValue アノテーションで主キーの生成戦略をシーケンスと指定します。@Column アノテーションでプロパティとデータベーステーブルの列とのマッピング関係を指定します。id プロパティはユーザー ID の格納に使用され、name プロパティはユーザー名の格納に使用されます。

      コード：

      @Id
      @GeneratedValue(strategy = GenerationType.SEQUENCE)
      @Column(name = "user_id")
      private int id;
      
      @Column(name = "user_name")
      private String name;
      

   2. User オブジェクトを作成します。

      User クラスの2つのコンストラクタメソッドを定義し、User オブジェクトの作成に使用します。 Hibernateのクエリ操作に使用されるパラメータなしのコンストラクタメソッドを定義します。id と name プロパティを初期化するために使用されるパラメータありのコンストラクタメソッドを定義します。

      コード：

      public User() {
      }
      
      public User(int id, String name) {
          this.id = id;
          this.name = name;
      }
      

   3. id と name の値を取得および設定します。

      User クラスの4つのメソッドを定義し、id と name プロパティの値を取得および設定するために使用します。 getId メソッドは id 値を取得するために使用され、setId メソッドは id 値を設定するために使用されます。getName メソッドはユーザー名 name の値を取得するために使用されます。setName メソッドはユーザー名 name の値を設定するために使用されます。

      コード：

      public int getId() {
          return id;
      }
      
      public void setId(int id) {
          this.id = id;
      }
      
      public String getName() {
          return name;
      }
      
      public void setName(String name) {
          this.name = name;
      }
      

   4. User オブジェクトの文字列表現を返します。

      User クラスの toString メソッドをオーバーライドし、User オブジェクトの文字列表現を返すようにします。 @Override を定義して、親クラスの同名メソッドをオーバーライドします。toString メソッドを定義し、User オブジェクトの文字列表現を返すために使用します。文字列連結を用いて、id と name プロパティの値を文字列としてフォーマットし、呼び出し元の User に返します。

      コード：

      @Override
      public String toString() {
          return "User{" +
                  "id=" + id +
                  ", name='" + name + '\'' +
                  '}';
      }
      

TestHibernate.javaのコード紹介

TestHibernate.java ファイルは、UserDao オブジェクトに対して挿入、削除、更新、およびクエリ操作を実行することで、Hibernateの基本的なデータベース操作機能を示します。

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

1. 他のクラスとインターフェースのインポート。

   このファイルに関連するクラスとインターフェースを宣言します。これには UserDao、User、Session、SessionFactory、Configuration などが含まれます。

   • UserDao クラス：ユーザー関連のデータベース操作を実行するために使用されます。
   • User クラス：ユーザーオブジェクトを操作するために使用されます。
   • Session クラス：データベースとのセッション操作に使用されます。
   • SessionFactory クラス：Sessionオブジェクトを作成するために使用されます。
   • Configuration クラス：Hibernateを設定するために使用されます。
   • SessionImpl クラス：基盤となるJDBC接続を取得するために使用されます。
   • Test アノテーション：テストメソッドをマークするために使用されます。
   • IOException クラス：I/O例外を処理するために使用されます。
   • Connection クラス：JDBC接続を取得するために使用されます。
   • SQLException クラス：SQL例外を処理するために使用されます。
   • List クラス：クエリ結果セットを格納するために使用されます。
   • UUID クラス：一意の識別子を生成するために使用されます。

   コード：

   import com.oceanbase.dao.UserDao;
   import com.oceanbase.pojo.User;
   import org.hibernate.Session;
   import org.hibernate.SessionFactory;
   import org.hibernate.cfg.Configuration;
   import org.hibernate.internal.SessionImpl;
   import org.junit.Test;
   import java.io.IOException;
   import java.sql.Connection;
   import java.sql.SQLException;
   import java.util.List;
   import java.util.UUID;
   

2. testHibernate メソッドの定義。 testHibernate メソッドには、挿入、削除、更新、およびクエリなどの基本操作が含まれます。 UserDao オブジェクトを作成し、ループ処理で5件のユーザーデータを挿入します。insertUser メソッドを呼び出してユーザーデータを挿入します。deleteUserById メソッドを呼び出して、idが1のユーザーデータを削除します。updateUserById メソッドを呼び出して、idが2のユーザーデータを更新します。selectUser メソッドを呼び出して、すべてのユーザーデータをクエリします。クエリ結果をイテレーションしてコンソールに出力します。

   コード：

   public class TestHibernate {
       @Test
       public void testHibernate() throws SQLException, IOException {
           UserDao userDao = new UserDao();
           for (int i = 1; i <= 5; i++) {
               userDao.insertUser(new User(i, "user_insert" + i));
           }
           int deleteUserById = userDao.deleteUserById(1);
           int update = userDao.updateUserById(new User(2, "update"));
           List<User> users = userDao.selectUser();
           users.forEach(System.out::println);
       }
   }
   

全コード表示

<?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>java-oceanbase-hibernate</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>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.13</version>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.27</version>
        </dependency>
        <dependency>
            <groupId>org.hibernate</groupId>
            <artifactId>hibernate-core</artifactId>
            <version>5.2.17.Final</version>
        </dependency>
        <!-- Hibernate c3p0 connection pool-->
        <dependency>
            <groupId>org.hibernate</groupId>
            <artifactId>hibernate-c3p0</artifactId>
            <version>5.2.17.Final</version>
        </dependency>

    </dependencies>

</project>

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE hibernate-mapping PUBLIC
        "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
        "http://www.hibernate.org/dtd/hibernate-mapping-3.0.dtd">
<hibernate-mapping package="com.oceanbase.pojo">
    <class name="User" table="test_hibernate_mysql">
        <!-- Configure primary key generation strategy -->
        <id name="id" column="USER_ID">
            <generator class="sequence">
                <param name="sequence">SQ_USER</param>
            </generator>
        </id>
        <!-- Configuration Tables and Properties -->
        <property name="name" column="USER_NAME" type="string"/>
    </class>
</hibernate-mapping>

<?xml version="1.0" encoding="utf-8"?>
<!DOCTYPE hibernate-configuration PUBLIC
        "-//Hibernate/Hibernate Configuration DTD 3.0//EN"
        "http://www.hibernate.org/dtd/hibernate-configuration-3.0.dtd">
<hibernate-configuration>

    <session-factory>
        <property name="hibernate.connection.driver_class">com.mysql.cj.jdbc.Driver</property>
        <property name="hibernate.connection.url">jdbc:mysql://host:port/schema_name</property>
        <property name="hibernate.connection.username">user_name</property>
        <property name="hibernate.connection.password">******</property>
        <property name="hibernate.connection.provider_class">org.hibernate.c3p0.internal.C3P0ConnectionProvider</property>
        <property name="hibernate.c3p0.max_size">60</property>
        <property name="hibernate.c3p0.min_size">30</property>

        <property name="hibernate.c3p0.checkoutTimeout">30000</property>
        <property name="hibernate.c3p0.timeout">20000</property>

        <property name="hibernate.c3p0.max_statements">100</property>
        <property name="hibernate.c3p0.idle_test_period">3000</property>
        <property name="hibernate.c3p0.acquire_increment">3</property>
        <property name="hibernate.c3p0.validate">true</property>

        <property name="dialect">org.hibernate.dialect.MySQL57Dialect</property>
        <property name="hibernate.show_sql">true</property>
        <property name="hibernate.format_sql">true</property>
        <property name="hbm2ddl.auto">create</property>
        <property name="current_session_context_class">thread</property>
        <property name="hibernate.jdbc.batch_size">10</property>
        <property name="hibernate.cache.use_second_level_cache">false</property>
        <mapping resource="com/oceanbase/pojo/User.hbm.xml"/>
    </session-factory>
</hibernate-configuration>

package com.oceanbase.dao;

import com.oceanbase.pojo.User;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.Transaction;
import org.hibernate.cfg.Configuration;
import org.hibernate.query.Query;

import java.util.List;


public class UserDao {
    private Session session;
    {
        Configuration cfg = new Configuration().configure();
        // Create SessionFactory
        SessionFactory sessionFactory = cfg.buildSessionFactory();
        session = sessionFactory.openSession();
    } //Read the hibernate.cfg.xml file
//    private Session session = HibernateUtil.getSession();

    public User selectUserById(int ID) {
        User user = session.get(User.class, ID);
        return user;
    }

    public List<User> selectUserbyName(String name) {
        String sql = "FROM test_hibernate_mysql u WHERE u.name =?";
        Query<User> query = session.createQuery(sql, User.class);
        query.setParameter(0, name);
        List<User> users = query.list();
        return users;
    }

    public List<User> selectUser() {
        String sql = "SELECT * FROM test_hibernate_mysql";
        Query<User> query = session.createNativeQuery(sql).addEntity(User.class);
        List<User> users = query.getResultList();
        return users;
    }

    public int insertUser(User user) {
        // open transaction
        Transaction beginTransaction = session.beginTransaction();
        session.save(user);
        session.getTransaction().commit();
        return 1;
    }

    public int deleteUserById(int id) {
        // open transaction
        session.beginTransaction();
        User user = session.get(User.class, id);
        session.delete(user);
        session.getTransaction().commit();
        return 1;
    }

    public int updateUserById(User user) {
        // open transaction
        session.beginTransaction();
        User user1 = session.get(User.class, user.getId());
        session.merge(user);
        session.getTransaction().commit();
        return 1;
    }

}

package com.oceanbase.pojo;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
import javax.persistence.Table;


@Entity
@Table(name = "test_hibernate_mysql")
public class User {
    @Id
    @GeneratedValue(strategy = GenerationType.SEQUENCE)
    @Column(name = "user_id")
    private int id;

    @Column(name = "user_name")
    private String name;

    public User() {
    }

    public User(int id, String name) {
        this.id = id;
        this.name = name;
    }

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    @Override
    public String toString() {
        return "User{" +
                "id=" + id +
                ", name='" + name + '\'' +
                '}';
    }
}

import com.oceanbase.dao.UserDao;
import com.oceanbase.pojo.User;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.cfg.Configuration;
import org.hibernate.internal.SessionImpl;
import org.junit.Test;

import java.io.IOException;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import java.util.UUID;


public class TestHibernate {
    @Test
    public void testHibernate() throws SQLException, IOException {
        UserDao userDao = new UserDao();
        for (int i = 1; i <= 5; i++) {
            userDao.insertUser(new User(i, "user_insert" + i));
        }
        int deleteUserById = userDao.deleteUserById(1);
        int update = userDao.updateUserById(new User(2, "update"));
        List<User> users = userDao.selectUser();
        users.forEach(System.out::println);
    }
}

関連ドキュメント

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