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

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

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

前提条件

• OceanBaseデータベースがインストール済みであること。
• JDK 1.8とMavenがインストール済みであること。
• IntelliJ IDEAがインストール済みであること。

手順

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

ステップ１：OceanBaseデータベースの接続文字列を取得する

1. OceanBaseデータベースのデプロイ担当者または管理者から、該当するデータベース接続文字列を取得します。

   obclient -hxx.xx.xx.xx -P2883 -uroot@sys#cluster -p**** -A
   

2. デプロイ済みのOceanBaseデータベースに基づいて、以下のURLの該当する情報を入力します。

   説明

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

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

   パラメータ説明：

   • host：OceanBaseデータベースへの接続IPアドレス。ODP接続方式ではODPアドレスを使用し、直接接続方式ではOBServerノードのIPアドレスを使用します。
   • port：OceanBaseデータベースへの接続ポート。ODP接続方式のデフォルトポートは2883で、ODPデプロイ時にカスタマイズ可能です。直接接続方式のデフォルトポートは2881で、OceanBaseデータベースのデプロイ時にカスタマイズ可能です。
   • schema_name：アクセスするスキーマ名。
   • user_name：テナントの接続アカウント。ODP接続方式では、ユーザー名@テナント名#クラスタ名またはクラスタ名:テナント名:ユーザー名の2種類の一般的な形式があります。直接接続方式の形式はユーザー名@テナント名です。
   • 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データベースの接続文字列を取得する の情報に基づいて、hibernate.cfg.xml ファイル内のデータベース接続情報を修正します。

例：

• データベースドライバーの名前：com.oceanbase.jdbc.Driver
• OBServerノードのIPアドレスは 10.10.10.1 です。
• アクセスポートは2881を使用します。
• アクセスするスキーマ名は sys です。
• テナントの接続アカウントは sys@xyoracle です。xyoracle はOceanBaseデータベースで作成されたOracleモードのユーザーテナントであり、sys はテナント xyoracle のユーザー名です。
• パスワードは ****** です。

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

<property name="hibernate.connection.driver_class">com.oceanbase.jdbc.Driver</property>
<property name="hibernate.connection.url">jdbc:oceanbase://10.10.10.1:2881/sys</property>
<property name="hibernate.connection.username">sys@xyoracle</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'}

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

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モデルバージョンを設定します。

3. xmlns を使用して、POMの名前空間を http://maven.apache.org/POM/4.0.0 と指定します。

4. xmlns:xsi を使用して、XML名前空間を http://www.w3.org/2001/XMLSchema-instance と指定します。

5. xsi:schemaLocation を使用して、POMの名前空間を http://maven.apache.org/POM/4.0.0 と指定し、POMのXSDファイルの場所を http://maven.apache.org/xsd/maven-4.0.0.xsd と指定します。

6. <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. 基本情報を設定します。

4. <groupId> を使用して、プロジェクト識別子を com.oceanbase と指定します。

5. <artifactId> を使用して、プロジェクトの依存関係を java-oceanbase-hibernate と指定します。

6. <version> を使用して、プロジェクトのバージョン番号を 1.0-SNAPSHOT と指定します。

コード：

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

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

5. <plugins> を使用して、プロジェクトで設定するプラグインを指定します。

6. <plugin> を使用して、プロジェクトで1つのプラグインを設定します。

7. <groupId> を使用して、プロジェクト識別子を org.apache.maven.plugins と指定します。

8. <artifactId> を使用して、プロジェクトの依存関係を maven-compiler-plugin と指定します。

9. <configuration> を使用して、設定するプラグインのパラメータを指定します。

10. <source> を使用して、コンパイラのソースコードバージョンを8と指定します。

11. <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> を使用して、プロジェクトが依存するコンポーネントを定義します。

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

   コード：

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

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

   コード：

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

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

   コード：

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

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

  **コード：**

    ```java
    <dependencies>
      <dependency>
          <groupId>org.mybatis</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_oracle という名前のデータベーステーブルにマッピングするHibernateマッピングファイルを定義します。

   1. package 属性を使用して、マッピングファイル内のJavaパッケージを com.oceanbase.pojo と指定します。
   2. class タグを使用してデータテーブル内のデータをマッピングし、name 属性でJavaクラス名を User、table 属性でデータベーステーブル名を test_hibernate_oracle と指定します。
   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_oracle">
           <id name="id" column="USER_ID">
               <generator class="sequence">
                   <param name="sequence">SQ_USER</param>
               </generator>
           </id>
           <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.oceanbase.jdbc.Driver` と指定します。OceanBaseデータベースとの接続を確立するために使用されます。
  *   `hibernate.connection.url` 要素を使用して、データベースのURLを指定します。データベースのアドレス、ポート番号、データベース名などの情報が含まれます。
  *   `hibernate.connection.username` 要素を使用して、データベース接続用のユーザー名を指定します。
  *   `hibernate.connection.password` 要素を使用して、データベース接続用のパスワードを指定します。

  **コード：**

  ```xml
      <property name="hibernate.connection.driver_class">com.oceanbase.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 を使用して、使用するデータベース方言をOracle 12cと指定します。特定のデータベースとの互換性を確保するために使用されます。
• 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 を読み込むことを指定します。

  **コード：**

  ```xml
    <property name="dialect">org.hibernate.dialect.Oracle12cDialect</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_oracle、テーブルエイリアスは u、検索フィールド名は name です。Session オブジェクトの createQuery メソッドを使用して Query オブジェクトを作成し、HQLステートメントとエンティティクラスをパラメータとして渡します。Query オブジェクトの setParameter メソッドを使用してクエリパラメータを設定します。ここで、0 はパラメータの位置を表し、name はパラメータの値を表します。Query オブジェクトの list メソッドを使用してクエリを実行し、検索結果を User オブジェクトのリストに変換します。

   コード：

   public List<User> selectUserbyName(String name) {
       String sql = "FROM test_hibernate_oracle 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_oracle";
       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_oracle と指定します。

   コード：

   @Entity
   @Table(name = "test_hibernate_oracle")
   

3. User クラスの定義。

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

   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 オブジェクトの作成に使用します。 1つのコンストラクタメソッドはパラメータなしで、Hibernateクエリ操作に使用されます。もう1つのコンストラクタメソッドはパラメータありで、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>com.oceanbase</groupId>
            <artifactId>oceanbase-client</artifactId>
            <version>2.4.2</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_oracle">
        <!-- 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.oceanbase.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>
        <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.Oracle12cDialect</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_oracle 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_oracle";
        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_oracle")
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ドライバを参照してください。