JDBC を使用して TiDB に接続する

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

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

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

注記:

このチュートリアルは、TiDB サーバーレス、TiDB 専用、および 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 Serverless
  • TiDB Dedicated
  • TiDB Self-Hosted
  1. クラスターページに移動し、ターゲット クラスターの名前をクリックして、その概要ページに移動します。

  2. 右上隅にある「接続」をクリックします。接続ダイアログが表示されます。

  3. 接続ダイアログの設定が動作環境と一致していることを確認してください。

    • エンドポイント タイプはPublicに設定されます

    • ブランチはmainに設定されています

    • [接続先]Generalに設定されています

    • オペレーティング システムが環境に一致します。

    ヒント:

    プログラムが Windows Subsystem for Linux (WSL) で実行されている場合は、対応する Linux ディストリビューションに切り替えます。

  4. 「パスワードの生成」をクリックして、ランダムなパスワードを作成します。

    ヒント:

    以前にパスワードを作成したことがある場合は、元のパスワードを使用するか、 「パスワードのリセット」をクリックして新しいパスワードを生成できます。

  5. 次のコマンドを実行してenv.sh.exampleをコピーし、名前をenv.shに変更します。

    cp env.sh.example env.sh
  6. 対応する接続​​文字列をコピーしてenv.shファイルに貼り付けます。結果の例は次のとおりです。

    export TIDB_HOST='{host}' # e.g. gateway01.ap-northeast-1.prod.aws.tidbcloud.com export TIDB_PORT='4000' export TIDB_USER='{user}' # e.g. xxxxxx.root export TIDB_PASSWORD='{password}' export TIDB_DB_NAME='test' export USE_SSL='true'

    プレースホルダー{} 、接続ダイアログから取得した接続パラメーターに必ず置き換えてください。

    TiDB サーバーレスには安全な接続が必要です。したがって、 USE_SSLtrueの値を設定する必要があります。

  7. env.shファイルを保存します。

  1. クラスターページに移動し、ターゲット クラスターの名前をクリックして、その概要ページに移動します。

  2. 右上隅にある「接続」をクリックします。接続ダイアログが表示されます。

  3. 「どこからでもアクセスを許可」をクリックし、 「TiDB クラスター CA のダウンロード」をクリックして CA 証明書をダウンロードします。

    接続文字列の取得方法の詳細については、 TiDB専用標準接続を参照してください。

  4. 次のコマンドを実行してenv.sh.exampleをコピーし、名前をenv.shに変更します。

    cp env.sh.example env.sh
  5. 対応する接続​​文字列をコピーしてenv.shファイルに貼り付けます。結果の例は次のとおりです。

    export TIDB_HOST='{host}' # e.g. tidb.xxxx.clusters.tidb-cloud.com export TIDB_PORT='4000' export TIDB_USER='{user}' # e.g. root export TIDB_PASSWORD='{password}' export TIDB_DB_NAME='test' export USE_SSL='false'

    プレースホルダー{} 、接続ダイアログから取得した接続パラメーターに必ず置き換えてください。

  6. env.shファイルを保存します。

  1. 次のコマンドを実行してenv.sh.exampleをコピーし、名前をenv.shに変更します。

    cp env.sh.example env.sh
  2. 対応する接続​​文字列をコピーしてenv.shファイルに貼り付けます。結果の例は次のとおりです。

    export TIDB_HOST='{host}' export TIDB_PORT='4000' export TIDB_USER='root' export TIDB_PASSWORD='{password}' export TIDB_DB_NAME='test' export USE_SSL='false'

    必ずプレースホルダー{}接続パラメーターに置き換えて、 USE_SSLfalseに設定してください。 TiDB をローカルで実行している場合、デフォルトのホスト アドレスは127.0.0.1で、パスワードは空です。

  3. env.shファイルを保存します。

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

  1. 次のコマンドを実行してサンプル コードを実行します。

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

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

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

完全なサンプル コードとその実行方法については、 tidb-samples/tidb-java-jdbc-quickstartリポジトリを確認してください。

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 ステートメントを作成する必要がない限り、開発には休止状態マイバティス 、またはSpring Data JPAなどのORMフレームワークを使用することをお勧めします。それはあなたに役立ちます:

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

次のステップ

助けが必要?

不和またはサポートチケットを作成するについて質問してください。

このページは役に立ちましたか?