Go-MySQL-Driver で TiDB に接続する

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

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

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

注記：

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

前提条件

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

• 行く 1.20以上。
• ギット 。
• TiDB クラスター。

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

• (推奨) TiDB サーバーレス クラスターの作成に従って、独自のTiDB Cloudクラスターを作成します。
• ローカルテスト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 クラスターに接続します。

• TiDB Serverless
• TiDB Dedicated
• TiDB Self-Hosted

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

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

   make
   

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

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

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

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

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 Serverless では安全な接続が必要です。したがって、 ${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フレームワークを使用することをお勧めします。これは次の点で役立ちます。

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

次のステップ

• Go-MySQL-Driver の詳しい使い方については、 Go-MySQL-Driver のドキュメントをご覧ください。
• 開発者ガイドのデータを挿入 、 データの更新 、 データを削除する 、 単一テーブル読み取り 、 取引 、 SQLパフォーマンスの最適化などの章で、 TiDB アプリケーション開発のベスト プラクティスを学習します。
• プロフェッショナルTiDB 開発者コースを通じて学び、試験に合格するとTiDB 認定獲得します。

助けが必要？

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