PingKai Logo下载

使用 GORM 连接到 TiDB

TiDB 是一个兼容 MySQL 的数据库。GORM 是当前比较流行的开源 Golang ORM 框架并且适配了 TiDB 的 AUTO_RANDOM 等特性。同时,TiDB 为 GORM 的默认支持数据库

本文档将展示如何使用 TiDB 和 GORM 来完成以下任务:

  • 配置你的环境。
  • 使用 GORM 连接到 TiDB。
  • 构建并运行你的应用程序。你也可以参考示例代码片段,完成基本的 CRUD 操作。

前置需求

运行代码并连接到 TiDB

本小节演示如何运行示例应用程序的代码,并连接到 TiDB。

第 1 步:克隆示例代码仓库到本地

运行以下命令,将示例代码仓库克隆到本地:

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

第 2 步:配置连接信息

根据不同的 TiDB 部署方式,使用不同的方法连接到 TiDB。

  1. 在 TiDB Cloud 的 My TiDB 页面中,选择你的 TiDB Cloud Starter 或 Essential 实例,进入实例的 Overview 页面。

  2. 点击右上角的 Connect 按钮,将会弹出连接对话框。

  3. 确认对话框中的配置和你的运行环境一致。

    • Connection TypePublic
    • Branch 选择 main
    • Connect With 选择 General
    • Operating System 为你的运行环境。
  4. 如果你还没有设置密码,点击 Generate Password 生成一个随机密码。

  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 要求使用 TLS (SSL) connection,因此 USE_SSL 的值应为 true

  7. 保存 .env 文件。

第 3 步:运行代码并查看结果

  1. 运行下述命令,执行示例代码:

    make
  2. 查看 Expected-Output.txt,并与你的程序输出进行比较。结果近似即为连接成功。

示例代码片段

你可参考以下关键代码片段,完成自己的应用开发。

完整代码及其运行方式,见代码仓库 tidb-golang-gorm-quickstart

连接到 TiDB

func createDB() *gorm.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 := gorm.Open(mysql.Open(dsn), &gorm.Config{
        Logger: logger.Default.LogMode(logger.Info),
    })
    if err != nil {
        panic(err)
    }

    return db
}

在使用该函数时,你需要将 ${tidb_host}${tidb_port}${tidb_user}${tidb_password}${tidb_db_name} 等替换为你的 TiDB 的实际值。因为 TiDB Cloud Starter 要求使用 TLS (SSL) connection,因此在连接到 TiDB Cloud Starter 时 ${use_ssl} 的值应为 true

插入数据

db.Create(&Player{ID: "id", Coins: 1, Goods: 1})

更多信息参考插入数据

查询数据

var queryPlayer Player
db.Find(&queryPlayer, "id = ?", "id")

更多信息参考查询数据

更新数据


db.Save(&Player{ID: "id", Coins: 100, Goods: 1})

更多信息参考更新数据

删除数据

db.Delete(&Player{ID: "id"})

更多信息参考删除数据

下一步

需要帮助?