使用 Golang 连接 TiDB Cloud Lake

官方 Go 驱动提供了标准的 database/sql 接口，可与现有 Go 应用无缝集成。

安装

go get github.com/tidbcloud/lake-go

Connection String：有关 DSN 格式和示例，请参见驱动概览。

主要特性

• ✅ 标准接口：完全兼容 database/sql
• ✅ 连接池：内置连接管理
• ✅ 批量操作：通过事务高效执行批量插入
• ✅ 类型安全：提供全面的 Go 类型映射

数据类型映射

基本用法

import (
    "database/sql"
    "fmt"
    "log"

    _ "github.com/tidbcloud/lake-go"
)

// Connect to TiDB Cloud Lake
db, err := sql.Open("lake", "<your-dsn>")
if err != nil {
    log.Fatal(err)
}
defer db.Close()

// DDL: Create table
_, err = db.Exec("CREATE TABLE users (id INT, name STRING)")
if err != nil {
    log.Fatal(err)
}

// Write: Insert data
_, err = db.Exec("INSERT INTO users VALUES (?, ?)", 1, "Alice")
if err != nil {
    log.Fatal(err)
}

// Query: Select data
var id int
var name string
err = db.QueryRow("SELECT id, name FROM users WHERE id = ?", 1).Scan(&id, &name)
if err != nil {
    log.Fatal(err)
}

fmt.Printf("User: %d, %s\n", id, name)

资源

• GitHub 仓库：lake-go
• 示例：GitHub Examples