📣
TiDB Cloud Premium はパブリックプレビュー中です。エンタープライズワークロード向けの無制限のスケーリング、即時の弾力性、高度なセキュリティを提供します。このページは自動翻訳されたものです。原文はこちらからご覧ください。

Go-MySQL-Driverを使用してTiDBに接続する



TiDBはMySQL互換データベースであり、 Go-MySQL-Driverデータベース/SQLインターフェース用のMySQL実装です。

このチュートリアルでは、TiDBとGo-MySQL-Driverを使用して以下のタスクを実行する方法を学ぶことができます。

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

注記:

このチュートリアルは、 TiDB Cloud Starter、 TiDB Cloud Essential、 TiDB Cloud Premium、 TiDB Cloud Dedicated、およびTiDB Self-Managedに対応しています。

前提条件

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

  • 行く1.20以上。
  • Git
  • TiDBクラスタ。

TiDBクラスタをお持ちでない場合は、以下の手順で作成できます。

TiDBに接続するには、サンプルアプリを実行してください。

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

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

サンプルコードリポジトリをクローンするには、ターミナルウィンドウで以下のコマンドを実行してください。

git clone https://github.com/tidb-samples/tidb-golang-sql-driver-quickstart.git cd tidb-golang-sql-driver-quickstart

ステップ2:接続情報を設定する

選択したTiDBのデプロイオプションに応じて、TiDBに接続してください。

    1. 私のTiDBページに移動し、対象のTiDB Cloud StarterまたはEssentialインスタンスの名前をクリックして、概要ページに移動します。

    2. 右上隅の「接続」をクリックしてください。接続ダイアログが表示されます。

    3. 接続ダイアログの設定がご使用のオペレーティング環境と一致していることを確認してください。

      • 接続タイプPublicに設定されています。

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

      • Connect With はGeneralに設定されています。

      • お使いの環境に合ったオペレーティングシステムを選択してください。

      ヒント:

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

    4. 「パスワードを生成」をクリックすると、ランダムなパスワードが生成されます。

      ヒント:

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

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

      cp .env.example .env
    6. 対応する接続​​文字列.envファイルにコピー&ペーストしてください。例は以下のとおりです。

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

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

      TiDB Cloud Starter は安全な接続を必要とします。そのため、 USE_SSLの値をtrueに設定する必要があります。

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

    1. 私のTiDBページに移動し、対象のTiDB Cloud Premiumインスタンスの名前をクリックして概要ページに移動します。

    2. 左側のナビゲーションペインで、 [設定] > [ネットワーク]をクリックします。

    3. ネットワークのページで、 [パブリックエンドポイント**を有効にする]をクリックし、次に[IP アドレスの追加]**をクリックします。

      クライアントのIPアドレスがアクセスリストに追加されていることを確認してください。

    4. 左側のナビゲーションペインで「概要」をクリックすると、インスタンスの概要ページに戻ります。

    5. 右上隅の「接続」をクリックしてください。接続ダイアログが表示されます。

    6. 接続ダイアログで、 「接続タイプ」ドロップダウンリストから「パブリック」を選択します。

      • 公開エンドポイントがまだ有効化中であることを示すメッセージが表示された場合は、処理が完了するまでお待ちください。
      • まだパスワードを設定していない場合は、ダイアログの「ルートパスワードを設定」をクリックしてください。
      • サーバー証明書を確認する必要がある場合、または接続に失敗して認証局(CA)証明書が必要な場合は、 「CA証明書」をクリックしてダウンロードしてください。
      • パブリック接続タイプに加えて、 TiDB Cloud Premium はプライベート エンドポイント接続をサポートします。詳細については、 AWS PrivateLink経由でTiDB Cloud Premiumに接続します。を参照してください。
    7. .env.exampleをコピーして.envに名前を変更するには、次のコマンドを実行します。

      cp .env.example .env
    8. 対応する接続​​文字列.envファイルにコピー&ペーストしてください。例は以下のとおりです。

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

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

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

    1. 私のTiDBページに移動し、対象のTiDB Cloud Dedicatedクラスタの名前をクリックして概要ページに移動します。

    2. 右上隅の「接続」をクリックしてください。接続ダイアログが表示されます。

    3. 接続ダイアログで、「接続タイプ」ドロップダウンリストから「パブリック」を選択し、 「CA証明書」をクリックしてCA証明書をダウンロードします。

      IP アクセス リストを設定していない場合は、最初の接続の前に、 [IP アクセス リストの設定] をクリックするか、「IP アクセス リストを設定する」の手順に従ってIPアクセスリストを設定する

      TiDB Cloud Dedicated は、パブリック接続タイプに加えて、プライベート エンドポイントおよびVPC ピアリング接続タイプもサポートしています。詳細については、 TiDB Cloud Dedicatedクラスタに接続します参照してください。

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

      cp .env.example .env
    5. 対応する接続​​文字列.envファイルにコピー&ペーストしてください。例は以下のとおりです。

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

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

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

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

      cp .env.example .env
    2. 対応する接続​​文字列.envファイルにコピー&ペーストしてください。例は以下のとおりです。

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

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

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

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

    1. サンプルコードを実行するには、以下のコマンドを実行してください。

      make
    2. 期待される出力.txtをチェックして、出力が一致するかどうかを確認してください。

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

    以下のサンプルコードスニペットを参考に、独自のアプリケーション開発を完成させてください。

    完全なサンプルコードと実行方法については、 tidb-samples/tidb-golang-sql-driver-quickstartリポジトリを参照してください。

    TiDBに接続する

    func openDB(driverName string, runnable func(db *sql.DB)) { dsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&tls=%s", ${tidb_user}, ${tidb_password}, ${tidb_host}, ${tidb_port}, ${tidb_db_name}, ${use_ssl}) db, err := sql.Open(driverName, dsn) if err != nil { panic(err) } defer db.Close() runnable(db) }

    この機能を使用する場合は、 ${tidb_host}${tidb_port}${tidb_user}${tidb_password} 、および${tidb_db_name} TiDBの実際の値に置き換える必要があります。TiDB TiDB Cloud StarterとTiDB Cloud Essentialはセキュアな接続を必要とします。そのため、 ${use_ssl}の値をtrueに設定する必要があります。

    データを挿入する

    openDB("mysql", func(db *sql.DB) { insertSQL = "INSERT INTO player (id, coins, goods) VALUES (?, ?, ?)" _, err := db.Exec(insertSQL, "id", 1, 1) if err != nil { panic(err) } })

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

    クエリデータ

    openDB("mysql", func(db *sql.DB) { selectSQL = "SELECT id, coins, goods FROM player WHERE id = ?" rows, err := db.Query(selectSQL, "id") if err != nil { panic(err) } // This line is extremely important! defer rows.Close() id, coins, goods := "", 0, 0 if rows.Next() { err = rows.Scan(&id, &coins, &goods) if err == nil { fmt.Printf("player id: %s, coins: %d, goods: %d\n", id, coins, goods) } } })

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

    データの更新

    openDB("mysql", func(db *sql.DB) { updateSQL = "UPDATE player set goods = goods + ?, coins = coins + ? WHERE id = ?" _, err := db.Exec(updateSQL, 1, -1, "id") if err != nil { panic(err) } })

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

    データを削除する

    openDB("mysql", func(db *sql.DB) { deleteSQL = "DELETE FROM player WHERE id=?" _, err := db.Exec(deleteSQL, "id") if err != nil { panic(err) } })

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

    役立つメモ

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

    Golangドライバはデータベースへの低レベルアクセスを提供するが、開発者には以下のことが必要となる。

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

    複雑なSQL文を書く必要がない限り、 ゴームなどのORMフレームワークを使用して開発することをお勧めします。ORMフレームワークは、次のような点で役立ちます。

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

    次のステップ

    お困りですか?

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