JDBC で TiDB に接続する

TiDB は MySQL 互換のデータベースであり、JDBC (Java Database Connectivity) はJavaのデータ アクセス API です。1 MySQL コネクタ/J MySQL の JDBC 実装です。

このチュートリアルでは、TiDB と JDBC を使用して次のタスクを実行する方法を学習します。

• 環境を設定します。
• JDBC を使用して TiDB クラスターに接続します。
• アプリケーションをビルドして実行します。オプションで、基本的な CRUD 操作用のサンプルコードスニペットを見つけることができます。

注記：

このチュートリアルは、 TiDB Cloud Serverless、 TiDB Cloud Dedicated、および TiDB Self-Managed で機能します。

前提条件

このチュートリアルを完了するには、次のものが必要です。

• Java Development Kit (JDK) 17以上。ビジネスおよび個人の要件に基づいてオープンJDKまたはオラクルを選択できます。
• メイヴン 3.8以上。
• ギット 。
• TiDB クラスター。

注記：

セキュリティ上の理由から、インターネット経由で接続する場合は、 VERIFY_IDENTITY使用して TiDB クラスターへの TLS 接続を確立することをお勧めします。TiDB TiDB Cloud Serverless とTiDB Cloud Dedicated はどちらもサブジェクト別名 (SAN) 証明書を使用するため、MySQL Connector/J バージョンは8.0.22以上である必要があります。

TiDB クラスターがない場合は、次のように作成できます。

• (推奨) TiDB Cloud Serverless クラスターの作成に従って、独自のTiDB Cloudクラスターを作成します。
• ローカルテストTiDBクラスタをデプロイまたは本番のTiDBクラスタをデプロイに従ってローカル クラスターを作成します。

サンプルアプリを実行してTiDBに接続する

このセクションでは、サンプル アプリケーション コードを実行して TiDB に接続する方法を示します。

ステップ1: サンプルアプリのリポジトリをクローンする

サンプル コード リポジトリを複製するには、ターミナル ウィンドウで次のコマンドを実行します。

git clone https://github.com/tidb-samples/tidb-java-jdbc-quickstart.git
cd tidb-java-jdbc-quickstart

ステップ2: 接続情報を構成する

選択した TiDB デプロイメント オプションに応じて、TiDB クラスターに接続します。

• TiDB Cloud Serverless
• TiDB Cloud Dedicated
• TiDB Self-Managed

ステップ3: コードを実行して結果を確認する

1. サンプル コードを実行するには、次のコマンドを実行します。

   make
   

2. 予想される出力.txtをチェックして、出力が一致するかどうかを確認します。

サンプルコードスニペット

次のサンプル コード スニペットを参照して、独自のアプリケーション開発を完了することができます。

完全なサンプル コードとその実行方法については、 tidb サンプル/tidb-java-jdbc-クイックスタートリポジトリを参照してください。

TiDBに接続する

public MysqlDataSource getMysqlDataSource() throws SQLException {
    MysqlDataSource mysqlDataSource = new MysqlDataSource();

    mysqlDataSource.setServerName(${tidb_host});
    mysqlDataSource.setPortNumber(${tidb_port});
    mysqlDataSource.setUser(${tidb_user});
    mysqlDataSource.setPassword(${tidb_password});
    mysqlDataSource.setDatabaseName(${tidb_db_name});
    if (${tidb_use_ssl}) {
        mysqlDataSource.setSslMode(PropertyDefinitions.SslMode.VERIFY_IDENTITY.name());
        mysqlDataSource.setEnabledTLSProtocols("TLSv1.2,TLSv1.3");
    }

    return mysqlDataSource;
}

この関数を使用する場合は、 ${tidb_host} 、 ${tidb_port} 、 ${tidb_user} 、 ${tidb_password} 、 ${tidb_db_name}を TiDB クラスターの実際の値に置き換える必要があります。

データを挿入

public void createPlayer(PlayerBean player) throws SQLException {
    MysqlDataSource mysqlDataSource = getMysqlDataSource();
    try (Connection connection = mysqlDataSource.getConnection()) {
        PreparedStatement preparedStatement = connection.prepareStatement("INSERT INTO player (id, coins, goods) VALUES (?, ?, ?)");
        preparedStatement.setString(1, player.getId());
        preparedStatement.setInt(2, player.getCoins());
        preparedStatement.setInt(3, player.getGoods());

        preparedStatement.execute();
    }
}

詳細についてはデータを挿入を参照してください。

クエリデータ

public void getPlayer(String id) throws SQLException {
    MysqlDataSource mysqlDataSource = getMysqlDataSourceByEnv();
    try (Connection connection = mysqlDataSource.getConnection()) {
        PreparedStatement preparedStatement = connection.prepareStatement("SELECT * FROM player WHERE id = ?");
        preparedStatement.setString(1, id);
        preparedStatement.execute();

        ResultSet res = preparedStatement.executeQuery();
        if(res.next()) {
            PlayerBean player = new PlayerBean(res.getString("id"), res.getInt("coins"), res.getInt("goods"));
            System.out.println(player);
        }
    }
}

詳細についてはクエリデータを参照してください。

データの更新

public void updatePlayer(String id, int amount, int price) throws SQLException {
    MysqlDataSource mysqlDataSource = getMysqlDataSourceByEnv();
    try (Connection connection = mysqlDataSource.getConnection()) {
        PreparedStatement transfer = connection.prepareStatement("UPDATE player SET goods = goods + ?, coins = coins + ? WHERE id=?");
        transfer.setInt(1, -amount);
        transfer.setInt(2, price);
        transfer.setString(3, id);
        transfer.execute();
    }
}

詳細についてはデータの更新を参照してください。

データを削除する

public void deletePlayer(String id) throws SQLException {
    MysqlDataSource mysqlDataSource = getMysqlDataSourceByEnv();
    try (Connection connection = mysqlDataSource.getConnection()) {
        PreparedStatement deleteStatement = connection.prepareStatement("DELETE FROM player WHERE id=?");
        deleteStatement.setString(1, id);
        deleteStatement.execute();
    }
}

詳細についてはデータを削除するを参照してください。

役に立つメモ

ドライバーまたは ORM フレームワークを使用していますか?

Javaドライバーはデータベースへの低レベルのアクセスを提供しますが、開発者は次の作業を行う必要があります。

• データベース接続を手動で確立および解放します。
• データベース トランザクションを手動で管理します。
• データ行をデータ オブジェクトに手動でマップします。

複雑な SQL 文を書く必要がない限り、開発には休止状態 、 マイバティス 、 スプリングデータ JPAなどのORMフレームワークを使用することをお勧めします。次のことに役立ちます。

• 接続とトランザクションを管理するために定型コード減らします。
• 多数の SQL ステートメントの代わりにデータ オブジェクトを使用してデータを操作します。

次のステップ

• MySQL Connector/J の使用方法をMySQL Connector/J のドキュメントから詳しく学びます。
• 開発者ガイドのデータを挿入 、 データの更新 、 データを削除する 、 単一テーブル読み取り 、 取引 、 SQLパフォーマンスの最適化などの章で、 TiDB アプリケーション開発のベスト プラクティスを学習します。
• プロフェッショナルTiDB 開発者コースを通じて学び、試験に合格するとTiDB 認定獲得します。
• Java開発者向けコースを通じて学習します: Javaから TiDB を操作する .

ヘルプが必要ですか?

TiDB コミュニティ 、またはサポートチケットを作成するについて質問します。