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

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

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

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

前提条件

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

• Go1.20以上。
• Git 。
• TiDBクラスタ。

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

• (推奨) TiDB Cloud Starterインスタンスを作成する。
• ローカルテスト用のTiDB Self-Managedクラスタをデプロイまたは本番のTiDB Self-Managedクラスタをデプロイ

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に接続してください。

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

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

   make
   

2. Expected-Output.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 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文を書く必要がない限り、 GORMなどのORMフレームワークを使用して開発することをお勧めします。ORMフレームワークは、次のような点で役立ちます。

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

次のステップ

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

お困りですか？

• Discordor Slackコミュニティに質問してください。
• TiDB Cloudのサポートチケットを送信してください
• TiDB Self-Managedのサポートチケットを送信してください