使用 Golang 连接 MySQL 并执行 CRUD（创建、读取、更新、删除）操作，核心是 database/sql 包配合 MySQL 驱动（如 go-sql-driver/mysql）。它不提供 ORM 功能，但足够轻量、可控且性能好。
安装依赖与建立连接
先通过 go mod 初始化项目并引入 MySQL 驱动：
go mod init example.com/dbdemogo get -u github.com/go-sql-driver/mysql
然后用 sql.Open 创建数据库句柄（注意：此时并未真正连接），再调用 db.Ping() 验证连接是否可用：
"database/sql"
"fmt"
"log"
"time"
_ "github.com/go-sql-driver/mysql"
)
func main() {
dsn := "user:password@tcp(127.0.0.1:3306)/testdb?parseTime=true&loc=Local"
db, err := sql.Open("mysql", dsn)
if err != nil {
log.Fatal(err)
}
defer db.Close()
if err = db.Ping(); err != nil {
log.Fatal("无法连接到 MySQL:", err)
}
fmt.Println("MySQL 连接成功")
}
定义结构体与建表语句
为方便操作，建议定义 Go 结构体对应数据库表。例如用户表：
立即学习“go语言免费学习笔记（深入）”；
id INT AUTO_INCREMENT PRIMARY KEY,
name VARCHAR(50) NOT NULL,
email VARCHAR(100) UNIQUE,
created_at DATETIME DEFAULT CURRENT_TIMESTAMP
);
对应结构体可写为：
type User struct {ID int `db:"id"`
Name string `db:"name"`
Email string `db:"email"`
CreatedAt time.Time `db:"created_at"`
}
注意：db 标签不是必须的，仅在配合第三方库（如 sqlx）做字段映射时有用；原生 database/sql 依赖查询列顺序或显式列名。
执行 CRUD 操作
所有操作都基于 *sql.DB 或 *sql.Tx（事务）进行，推荐使用 Prepare 预处理语句防 SQL 注入：
-
Create（插入）：用
Exec执行 INSERT，获取自增 ID
defer stmt.Close()
result, _ := stmt.Exec("张三", "zhangsan@example.com")
id, _ := result.LastInsertId()
fmt.Printf("插入成功，ID=%d\n", id)
-
Read（查询单条/多条）：用
QueryRow查一行，Query查多行
var user User
err := db.QueryRow("SELECT id,name,email,created_at FROM users WHERE id = ?", 1).Scan(&user.ID, &user.Name, &user.Email, &user.CreatedAt)
if err != nil {
if err == sql.ErrNoRows {
fmt.Println("未找到用户")
} else {
log.Fatal(err)
}
}
// 查询多条
rows, _ := db.Query("SELECT id,name,email,created_at FROM users WHERE email LIKE ?", "%@example.com")
defer rows.Close()
for rows.Next() {
var u User
rows.Scan(&u.ID, &u.Name, &u.Email, &u.CreatedAt)
fmt.Printf("%+v\n", u)
}
-
Update（更新）：同样用
Exec，检查影响行数
affect, _ := result.RowsAffected()
fmt.Printf("更新了 %d 行\n", affect)
- Delete（删除）：同上
affect, _ := result.RowsAffected()
fmt.Printf("删除了 %d 行\n", affect)
处理错误与资源释放
关键点：
- 每个
Query返回的*sql.Rows必须调用rows.Close()，否则可能泄漏连接 -
Exec/QueryRow等方法返回的 error 是操作本身失败（如语法错），而rows.Err()才是遍历过程中的错误 - 连接池由
*sql.DB自动管理，通常只需在程序退出前调用一次db.Close() - 可通过
db.SetMaxOpenConns、db.SetMaxIdleConns、db.SetConnMaxLifetime调优连接池
