SpringBoot

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

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

前提条件

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

操作手順

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

ステップ１：OceanBaseデータベース接続情報を取得する

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

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

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

   説明

   application.properties ファイルには、このURL情報が必要です。

   jdbc:oceanbase://host:port/schema_name?user=$user_name&password=$password&useSSL=false&useUnicode=true&characterEncoding=utf-8
   

   パラメータの説明：

   • host：OceanBaseデータベースへの接続IPアドレス。ODP接続方式ではODPアドレスを使用し、直接接続方式ではOBServerノードのIPアドレスを使用します。

   • port：OceanBaseデータベースへの接続ポート。ODP接続方式のデフォルトポートは2883で、ODPデプロイ時にカスタマイズ可能です。直接接続方式のデフォルトポートは2881で、OceanBaseデータベースのデプロイ時にカスタマイズ可能です。

   • schema_name：アクセスするスキーマ名です。

   • user_name：-u パラメータで指定します。形式は、ユーザー名@テナント#クラスタ名または ユーザー名@SERVICE:サービス名です。ユーザー@テナント#クラスタ名の形式を使用する場合、デフォルトのテナントは sys、管理者ユーザーは root です。データベースに直接接続する場合、クラスタ名を省略できますが、ODP接続の場合は入力する必要があります。

   • password：アカウントのパスワード。

   • useSSL=false&useUnicode=true&characterEncoding=utf-8：追加の接続プロパティ。

     • useSSL：強制接続時に SSL/TLS を使用するかどうかを指定します。 デフォルト値：false。
     • useUnicode：指定された文字のエンコードおよびデコード形式です。 デフォルト値：true
     • characterEncoding：データベースURLオプションをサポートする文字エンコーディングです。デフォルト値：utf8。

その他のURLパラメータの説明情報については、データベースURLを参照してください。

ステップ2：java-oceanbase-springboot プロジェクトを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-springboot プロジェクトのデータベース接続情報を修正する

ステップ１：OceanBaseデータベース接続情報を取得するに記載されている情報に基づいて、application.properties ファイル内のデータベース接続情報を修正します。

例：

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

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

spring.datasource.driverClassName=com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:oceanbase://10.10.10.1:2881/test?useSSL=false&useUnicode=true&characterEncoding=utf-8
spring.datasource.username=root@mysq001
spring.datasource.password=******

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

実行パス

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

実行結果

test_springboot delete successfully!
test_springboot create successfully!
user = User{id=2, name='update'}
User{id=2, name='update'}
User{id=3, name='insert3'}
User{id=4, name='insert4'}
User{id=5, name='insert5'}
User{id=6, name='insert6'}
User{id=7, name='insert7'}
User{id=8, name='insert8'}
User{id=9, name='insert9'}
User{id=10, name='insert10'}

よくある質問

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データベースとのSSL接続を有効にするには、JDBC URLに以下のパラメータを追加します：

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

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

ユーザー名またはパスワードに特殊文字（例：#）が含まれている場合は、URLエンコーディングを行う必要があります：

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

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

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

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

│--pom.xml
│
├─.idea
├─src
│  ├─main
│  │  ├─java
│  │  │  └─com
│  │  │      └─oceanbase
│  │  │          └─testspringboot
│  │  │              │--TestSpringbootApplication.java
│  │  │              │
│  │  │              ├─dao
│  │  │              │  │--UserDao.java
│  │  │              │  │
│  │  │              │  └─impl
│  │  │              │      └─--UserDaoImpl.java
│  │  │              │
│  │  │              └─entity
│  │  │                  └─--User.java
│  │  │
│  │  └─resources
│  │      └─--application.properties
│  │
│  └─test
│      └─java
│          └─com
│              └─oceanbase
│                  └─testspringboot
│                      └─--TestSpringbootApplicationTests.java
│
└─target

ファイルの説明：

• pom.xml：Mavenプロジェクトの設定ファイルは、プロジェクトの依存関係、プラグイン、ビルドなどの情報が含まれます。
• .idea：IDE（統合開発環境）で使用されるディレクトリで、プロジェクト関連の設定情報を格納するために使用されます。
• src：通常、プロジェクトのソースコードを格納するディレクトリを表すために使用されます。
• main： 主要なソースコードとリソースファイルを格納するディレクトリ。
• java： Javaソースコードを格納するディレクトリ。
• com： Javaパッケージを格納するルートディレクトリ。
• oceanbase： プロジェクトを格納するルートディレクトリ。
• testspringboot：Javaパッケージのルートディレクトリで、プロジェクトのすべてのJavaクラスが含まれています。
• TestSpringbootApplication.java：プロジェクトのメインクラスで、mainメソッドが含まれています。
• dao: データアクセスオブジェクト（Data Access Object）パッケージを格納するディレクトリで、データベースや他のデータストレージサービスにアクセスするために使用されます。
• UserDao.java：ユーザーデータアクセスオブジェクトで、ユーザーデータの追加、削除、変更、クエリなどの操作に使用されます。
• impl：DAOインターフェースの実装ディレクトリ。
• UserDaoImpl.java：ユーザーDAOインターフェースの実装クラス。
• entity：エンティティクラスのディレクトリで、データベーステーブルに対応するJavaクラスを格納するために使用されます。
• User.java：ユーザー永続化オブジェクトで、ユーザーデータテーブルのフィールドをマッピングするために使用されます。
• resources: 設定ファイルやSQLファイルなどの、リソースファイルを格納するディレクトリ。
• application.properties：プロジェクトの設定ファイルで、アプリケーションのプロパティとパラメータを設定するために使用されます。
• test： テストコードとリソースファイルを格納するディレクトリ。
• TestSpringbootApplicationTests.java： springbootをテストする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ファイルの場所を https://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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
   </project>
   

3. 親要素の情報を設定します。

   1. <groupId> を使用して、親要素の識別子を org.springframework.boot と指定します。
   2. <artifactId> を使用して、親要素の依存関係を spring-boot-starter-parent と指定します。
   3. <version> を使用して、親要素のバージョン番号を 2.7.11 と指定します。
   4. relativePath を使用して、親要素のパスが空であることを示します。

   コード：

    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.7.11</version>
    <relativePath/> 
   

4. 基本情報を設定します。

   1. <groupId> を使用して、プロジェクトの識別子を com.oceanbase と指定します。
   2. <artifactId> を使用して、プロジェクト依存関係を java-oceanbase-springboot と指定します。
   3. <version> を使用して、プロジェクトのバージョン番号を 0.0.1-SNAPSHOT と指定します。
   4. description を使用して、プロジェクトの情報を Demo project for Spring Boot として紹介します。

   コード：

    <groupId>com.oceanbase</groupId>
    <artifactId>java-oceanbase-springboot</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>java-oceanbase-springboot</name>
    <description>Demo project for Spring Boot</description>
   

5. Javaバージョンを設定します。

   プロジェクトで使用するJavaバージョンを1.8と指定します。

   コード：

     <properties>
         <java.version>1.8</java.version>
     </properties>
   

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

   1. 依存関係が所属する組織を org.springframework.boot、名前を spring-boot-starter と指定します。この依存ライブラリにはSpring Bootがデフォルトでサポートするコンポーネントの依存関係が含まれており、Web、データ処理、セキュリティ、Testなどの機能をサポートします。

      コード：

      <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter</artifactId>
      </dependency>
      

   2. 依存関係が所属する組織を org.springframework.boot、名前を spring-boot-starter-jdbc と指定します。この依存関係により、Spring Bootが提供するJDBC関連機能（接続プール、データソース設定など）を利用できます。

      コード：

      <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-jdbc</artifactId>
      </dependency>
      

   3. 依存関係が所属する組織を org.springframework.boot、名前を spring-boot-starter-test、スコープを test と指定します。この依存関係により、JUnit、Mockito、HamcrestなどのSpring Bootが提供するテストフレームワークとツールを利用できます。

      コード：

      <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-test</artifactId>
          <scope>test</scope>
      </dependency>
      

   4. 依存関係が属する組織を com.oceanbase、名前を oceanbase-client、バージョン番号を 2.4.3 と指定します。この依存関係を使用することで、OceanBaseが提供するクライアント機能（接続、クエリ、トランザクションなど）を利用できます。

      コード：

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

7. Mavenプラグインを設定します。

   依存関係が所属する組織を org.springframework.boot、名前を spring-boot-maven-plugin と指定します。このプラグインはSpring Bootアプリケーションを実行可能なJARパッケージまたはWARパッケージにパッケージ化するために使用され、直接実行できます。

   コード：

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
   

application.propertiesコードの紹介

application.properties ファイルは、Spring Bootアプリケーションのデータソースを設定し、OceanBaseデータベースへの接続に必要なドライバークラス名、URL、ユーザー名、パスワードを指定します。これらの設定により、アプリケーションはOceanBaseデータベースに接続して、操作を実行できます。

• spring.datasource.driverClassName を使用して、データベースドライバープログラムを com.oceanbase.jdbc.Driver と指定します。OceanBaseデータベースとの接続を確立するために使用されます。

• spring.datasource.url を使用して、データベース接続用のURLを指定します。

• spring.datasource.username を使用して、データベース接続用のユーザー名を指定します。

• spring.datasource.password を使用して、データベース接続用のパスワードを指定します。

  コード：

  spring.datasource.driverClassName=com.mysql.cj.jdbc.Driver
  spring.datasource.url=jdbc:oceanbase://host:port/schema_name?useSSL=false&useUnicode=true&characterEncoding=utf-8
  spring.datasource.username=user_name
  spring.datasource.password=******
  

UserDaoImpl.javaファイルの紹介

UserDaoImpl.java ファイルは、JdbcTemplate オブジェクトを使用してSQLステートメントを実行し、Userテーブルの挿入、削除、更新、クエリの操作を実装します。

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

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

   このファイルが所属するパッケージ名を com.oceanbase.testspringboot.dao.impl として宣言します。以下のインターフェースとクラスが含まれます：

   • UserDao インターフェース：UserDaoインターフェースで定義されたメソッドを実装するために使用されます。
   • User クラス：ユーザーデータの転送とストレージに使用されます。
   • Autowired アノテーション：JdbcTemplateオブジェクトをこのクラスに注入し、SQLステートメントを実行するために使用されます。
   • BeanPropertyRowMapper クラス：データベースのクエリ結果をJavaオブジェクトにマッピングするために使用されます。
   • JdbcTemplate クラス：SQLステートメントの実行とデータベースアクセスの処理に使用されます。
   • Repository アノテーション：Springのリポジトリコンポーネントをマークします。データアクセスに使用されます。
   • List インターフェース：クエリ結果セットを操作するために使用されます。

   コード：

   import com.oceanbase.testspringboot.dao.UserDao;
   import com.oceanbase.testspringboot.entity.User;
   import org.springframework.beans.factory.annotation.Autowired;
   import org.springframework.jdbc.core.BeanPropertyRowMapper;
   import org.springframework.jdbc.core.JdbcTemplate;
   import org.springframework.stereotype.Repository;
   import java.util.List;
   

2. UserDaoImpl クラスを定義します。

   Repository アノテーションを使用して、このクラスの Bean 名を userDao と指定します。JdbcTemplate オブジェクトを使用してSQLステートメントを実行し、User テーブルに対する挿入、削除、更新、クエリの操作を実装します。

   1. ユーザー情報を挿入します。

      JdbcTemplate オブジェクトの insert メソッドを呼び出して、ユーザーのIDと名前をデータベースの test_springboot テーブルに挿入し、挿入操作の結果に応じて対応するブール値を返します。

      コード：

      @Autowired
          private JdbcTemplate jdbcTemplate; //Jdbc connection tool class
          @Override
          public boolean insertUser(User user) {
              String sql = "insert into test_springboot(id,name)values(?,?)";
              Object[] params = {user.getId(), user.getName()};
              return jdbcTemplate.update(sql, params) > 0;
          }
      

   2. ユーザー情報を削除します。

      JdbcTemplate オブジェクトの delete メソッドを呼び出して、ユーザーのIDに基づいてデータベース内のユーザー情報を削除し、削除操作の結果に応じて対応するブール値を返します。

      コード：

      @Override
      public boolean deleteById(Long id) {
          String sql = "delete from test_springboot where id=?";
          Object[] params = {id};
          return jdbcTemplate.update(sql, params) > 0;
      }
      

   3. ユーザー情報を更新します。

      JdbcTemplate オブジェクトの update メソッドを呼び出して、ユーザーの名前をデータベースのtest_springbootテーブル内の指定されたIDのレコードに更新し、更新操作の結果に応じて対応するブール値を返します。

      コード：

      @Override
      public boolean updateUser(User user) {
          String sql = "update test_springboot set name=? where id=?";
          Object[] params = {user.getName(), user.getId()};
          return jdbcTemplate.update(sql, params) > 0;
      }
      

   4. ユーザー情報のクエリを実行します。

      JdbcTemplate オブジェクトを使用してSQLクエリステートメントを実行し、test_springboot という名前のテーブルに対して指定されたIDのユーザーレコードのクエリを実行します。BeanPropertyRowMapper を使用して、結果のマッピングを行います。クエリ結果のオブジェクトを返します。

      コード：

      @Override
      public User selectUserById(Long id) {
          String sql = "select * from test_springboot where id=?";
          Object[] params = new Object[]{id};
          return jdbcTemplate.queryForObject(
                  sql,
                  params,
                  new BeanPropertyRowMapper<>(User.class));
      }
      

   5. すべてのユーザー情報のクエリを実行します。

      JdbcTemplate オブジェクトの query メソッドを呼び出して、データベース内のすべてのユーザー情報のクエリを実行します。クエリ結果をUserタイプのオブジェクトリストにマッピングして返します。

      コード：

      @Override
      public List<User> selectAllUsers() {
          String sql = "select * from test_springboot";
          return jdbcTemplate.query(sql, new BeanPropertyRowMapper<User>(User.class));
      }
      

UserDao.javaファイルの紹介

UserDao.java ファイルは、UserDaoインターフェースを使用してユーザーデータの操作メソッドを定義します。

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

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

   このファイルが所属するパッケージ名を package com.oceanbase.testspringboot.dao として宣言します。以下のインターフェースとクラスが含まれます：

   • User クラス：ユーザーデータの転送とストレージに使用されます。
   • List インターフェース：クエリ結果セットを操作するために使用されます。

   コード：

   import com.oceanbase.testspringboot.entity.User;
   import java.util.List;
   

2. UserDao インターフェースを定義します。

   UserDao インターフェースを使用して、ユーザーデータの操作メソッドを定義します。ユーザー情報の挿入、ユーザー情報の削除、ユーザー情報の更新、ユーザーIDによるユーザー情報のクエリ、すべてのユーザー情報のクエリなどのメソッドが含まれます。

   コード：

   public interface UserDao {
       boolean insertUser(User user);
       boolean deleteById(Long id);
       boolean updateUser(User user);
       User selectUserById(Long id);
       List<User> selectAllUsers();
   }
   

User.javaファイルの紹介

User.java ファイルは、ユーザーオブジェクトを表す User クラスを定義します。

1. User オブジェクトを宣言します。 User クラスが id と name の2つのプライベートフィールドを含み、パラメータなしのコンストラクタメソッドを提供することを宣言します。id と name フィールドの値を設定および取得することにより、ユーザー情報を操作します。

   コード：

   private Long id;
   private String name;
   
   public User() {
   }
   

2. User オブジェクトを作成します。 User クラスのパラメータ付きコンストラクタメソッドを定義します。これは、指定された id と name を持つ User オブジェクトの作成に使用します。

   コード：

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

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

   コード：

   public Long getId() {
       return id;
   }
   
   public void setId(Long 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 プロパティの値を1つの文字列としてフォーマットし、呼び出し元の User に返します。

   コード：

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

TestSpringbootApplication.javaファイルの紹介

TestSpringbootApplication.java ファイルは、UserDao インターフェースを使用してSpring Bootアプリケーションを起動します。

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

1. クラスとインターフェースを定義します。

   このファイルが所属するパッケージ名を com.oceanbase.testspringboot として宣言します。以下のインターフェースとクラスが含まれます：

   • SpringApplication クラス：Spring Bootアプリケーションを起動するために使用されます。
   • @SpringBootApplication アノテーション：このクラスがSpring Bootアプリケーションのエントリポイントであることを示します。

   コード：

   import org.springframework.boot.SpringApplication;
   import org.springframework.boot.autoconfigure.SpringBootApplication;
   

2. TestSpringbootApplication クラスを定義します。

   SpringBootApplicationアノテーションを使用して、このクラスがSpring Bootアプリケーションのエントリクラスであることをマークします。SpringApplicationクラスのrunメソッドを呼び出すことで、Spring Bootアプリケーションを起動できます。

   コード：

   @SpringBootApplication
   public class TestSpringbootApplication {
   
       public static void main(String[] args) {
           SpringApplication.run(TestSpringbootApplication.class, args);
       }
   }
   

TestSpringbootApplicationTests.javaファイルの紹介

TestSpringbootApplicationTests.java ファイルは、UserDao インターフェースを使用してSpring Bootアプリケーションを起動します。

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

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

   このファイルが所属するパッケージ名を com.oceanbase.testspringboot として宣言します。以下のインターフェースとクラスが含まれます：

   • UserDao インターフェース：UserDaoインターフェースで定義されたメソッドを実装するために使用されます。
   • User クラス：ユーザーデータの転送とストレージに使用されます。
   • Test アノテーション：テストメソッドをマークするために使用されます。
   • Autowired アノテーション：JdbcTemplateオブジェクトをこのクラスに注入し、SQLステートメントを実行するために使用されます。
   • SpringBootTest アノテーション：このクラスがSpring Bootのテストクラスであることをマークするために使用されます。
   • JdbcTemplate クラス：SQLステートメントの実行とデータベースアクセスの処理に使用されます。
   • List インターフェース：クエリ結果セットを操作するために使用されます。

   コード：

   import com.oceanbase.testspringboot.dao.UserDao;
   import com.oceanbase.testspringboot.entity.User;
   import org.junit.jupiter.api.Test;
   import org.springframework.beans.factory.annotation.Autowired;
   import org.springframework.boot.test.context.SpringBootTest;
   import org.springframework.jdbc.core.JdbcTemplate;
   import java.util.List;
   
   

2. TestSpringbootApplicationTests クラスを定義します。

   SpringBootTest アノテーションを使用して、Spring Bootアプリケーション内の機能をテストすることをマークします。UserDao と JdbcTemplate オブジェクトを使用して、ユーザーデータの追加、削除、更新、クエリの操作を行い、結果を出力します。

   1. オブジェクトを定義します。

      Autowired アノテーションを使用して、UserDao と JdbcTemplate オブジェクトを自動注入します。

      コード：

      @Autowired
      private UserDao userDao;
      @Autowired
      private JdbcTemplate jdbcTemplate; 
      

   2. contextLoads メソッドを定義します。

      contextLoads メソッドは、テストメソッドの具体的な実装として使用されます。

      1. test_springboot テーブルを削除します。

         jdbcTemplate.execute メソッドを使用して、SQLステートメント drop table test_springboot を実行し、test_springboot という名前のテーブルを削除します。

         コード：

         try {
               jdbcTemplate.execute("drop table test_springboot");
               System.out.println("test_springboot delete successfully!");
             } 
         

      2. test_springboot テーブルを作成します。

         jdbcTemplate.execute メソッドを使用して、SQLステートメント create table test_springboot (id int primary key, name varchar(50)) を実行し、id と name の2つのフィールドを含む test_springboot という名前のテーブルを作成します。

         コード：

         catch (Exception ignore) {
         
                 } finally {
                     jdbcTemplate.execute("create table test_springboot (" +
                             "id int primary key," +
                             "name varchar(50))");
                     System.out.println("test_springboot create successfully!");
                 }
         

      3. データを挿入します。

         userDao.insertUser メソッドを使用して、test_springboot テーブルに10件のユーザーデータを挿入します。id は1から10まで、name は "insert" + i とします。

         コード：

         for (int i = 1; i <= 10; i++) {
             userDao.insertUser(new User((long) i, "insert" + i));
         }
         

      4. データを削除します。

         userDao.deleteById メソッドを使用して、id が1のユーザーデータを削除します。

         コード：

           userDao.deleteById(1L);
         

      5. データを更新します。

         userDao.updateUser メソッドを使用して、id が2のユーザーデータの name を update に更新します。

         コード：

         userDao.updateUser(new User(2L, "update"));
         

      6. データのクエリを実行します。

         userDao.selectUserById メソッドを使用して、id が2のユーザーデータのクエリを実行し、結果を出力します。

         コード：

         User user = userDao.selectUserById(2L);
         System.out.println("user = " + user);
         

      7. すべてのデータのクエリを実行します。

         userDao.selectAllUsers メソッドを使用して、test_springboot テーブルのすべてのユーザーデータのクエリを実行し、結果を出力します。

         コード：

         List<User> userList = userDao.selectAllUsers();
         userList.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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.7.11</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.oceanbase</groupId>
    <artifactId>java-oceanbase-springboot</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>java-oceanbase-springboot</name>
    <description>Demo project for Spring Boot</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>com.oceanbase</groupId>
            <artifactId>oceanbase-client</artifactId>
            <version>2.4.3</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

  spring.datasource.driverClassName=com.mysql.cj.jdbc.Driver
  spring.datasource.url=jdbc:oceanbase://host:port/schema_name?useSSL=false&useUnicode=true&characterEncoding=utf-8
  spring.datasource.username=user_name
  spring.datasource.password=******

package com.oceanbase.testspringboot.dao.impl;

import com.oceanbase.testspringboot.dao.UserDao;
import com.oceanbase.testspringboot.entity.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;

import java.util.List;

@Repository("userDao")
public class UserDaoImpl implements UserDao {
    @Autowired
    private JdbcTemplate jdbcTemplate; //Jdbc connection tool class

    @Override
    public boolean insertUser(User user) {
        String sql = "insert into test_springboot(id,name)values(?,?)";
        Object[] params = {user.getId(), user.getName()};
        return jdbcTemplate.update(sql, params) > 0;
    }

    @Override
    public boolean deleteById(Long id) {
        String sql = "delete from test_springboot where id=?";
        Object[] params = {id};
        return jdbcTemplate.update(sql, params) > 0;
    }

    @Override
    public boolean updateUser(User user) {
        String sql = "update test_springboot set name=? where id=?";
        Object[] params = {user.getName(), user.getId()};
        return jdbcTemplate.update(sql, params) > 0;
    }

    @Override
    public User selectUserById(Long id) {
        String sql = "select * from test_springboot where id=?";
        Object[] params = new Object[]{id};
        return jdbcTemplate.queryForObject(
                sql,
                params,
                new BeanPropertyRowMapper<>(User.class));
    }

    @Override
    public List<User> selectAllUsers() {
        String sql = "select * from test_springboot";
        return jdbcTemplate.query(sql, new BeanPropertyRowMapper<User>(User.class));
    }
}

package com.oceanbase.testspringboot.dao;

import com.oceanbase.testspringboot.entity.User;

import java.util.List;


public interface UserDao {
    boolean insertUser(User user);

    boolean deleteById(Long id);

    boolean updateUser(User user);

    User selectUserById(Long id);

    List<User> selectAllUsers();
}

package com.oceanbase.testspringboot.entity;


public class User {
    private Long id;
    private String name;

    public User() {
    }

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

    public Long getId() {
        return id;
    }

    public void setId(Long 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 + '\'' +
                '}';
    }
}

package com.oceanbase.testspringboot;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class TestSpringbootApplication {

    public static void main(String[] args) {
        SpringApplication.run(TestSpringbootApplication.class, args);
    }
}

package com.oceanbase.testspringboot;

import com.oceanbase.testspringboot.dao.UserDao;
import com.oceanbase.testspringboot.entity.User;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.jdbc.core.JdbcTemplate;

import java.util.List;

@SpringBootTest
class TestSpringbootApplicationTests {
    @Autowired
    private UserDao userDao;
    @Autowired
    private JdbcTemplate jdbcTemplate; //Jdbc connection tool class

    @Test
    void contextLoads() {
        try {
            // Use the execute() method to execute SQL statements and delete the user table test_springboot
            jdbcTemplate.execute("drop table test_springboot");
            System.out.println("test_springboot delete successfully!");
        } catch (Exception ignore) {

        } finally {
            // Use the execute() method to execute SQL statements and create user table tests_ user
            jdbcTemplate.execute("create table test_springboot (" +
                    "id int primary key," +
                    "name varchar(50))");
            System.out.println("test_springboot create successfully!");
        }
        //UserDao userDao=new UserDaoImpl();

        //ApplicationContext ioc=new ApplicationContext("/appli");`
        //add
        for (int i = 1; i <= 10; i++) {
            userDao.insertUser(new User((long) i, "insert" + i));
        }
        //delete
        userDao.deleteById(1L);
        //update
        userDao.updateUser(new User(2L, "update"));
        //selectUserById
        User user = userDao.selectUserById(2L);
        System.out.println("user = " + user);
        //query all users
        List<User> userList = userDao.selectAllUsers();
        userList.forEach(System.out::println);
    }

}

関連ドキュメント

その他のOceanBase Connector/Jの情報については、OceanBase JDBCドライバーを参照してください。