sqldriver directory: cd sqldriver The structure of this directory is as follows: . ￿── Makefile ￿── dao.go ￿── go.mod ￿── go.sum ￿── sql ￿ ￿── dbinit.sql ￿── sql.go ￿── sqldriver.go You can find MySQL source instance db, err := sql.Open �→ ("mysql", dsn) to connect to TiDB. Then, you can use dao.go to read, edit, add, and delete data. package main import ( "database/sql" "fmt" _ "github.c Commit() } func (tx *TiDBSqlTx) Rollback() error { defer tx.conn.Close() return tx.Tx.Rollback() } dao.go defines a set of data manipulation methods to provide the ability to write data. This is also the

} 使用 go-sql-driver/mysql 时，首先进入目录 sqldriver： cd sqldriver 目录结构如下所示： . ├ ─ ─ Makefile ├ ─ ─ dao.go ├ ─ ─ go.mod ├ ─ ─ go.sum ├ ─ ─ sql │ └ ─ ─ dbinit.sql ├ ─ ─ sql.go └ ─ ─ sqldriver.go 这个示例程序的主体。因为 TiDB 与 MySQL 协议兼容，因此，需要初始化一个 MySQL 协议的数据源 db, err := sql.Open("mysql", dsn)，以此连接到 TiDB。并在其后，调用 dao.go 中的一系列方 法，用来管理数据对象，进行增删改查等操作。 package main import ( "database/sql" "fmt" _ "github.com/go-sql-driver/mysql" func (tx *TiDBSqlTx) Rollback() error { 114 defer tx.conn.Close() return tx.Tx.Rollback() } 在 dao.go 中定义一系列数据的操作方法，用来对提供数据的写入能力。这也是本例子中和核心部分。 package main import ( "database/sql" "fmt" "math/rand"