答案：本文通过用户管理项目演示Go语言操作MySQL实现CRUD。首先搭建环境并创建数据库表，定义User结构体和数据库连接；接着编写CreateUser、GetUser、UpdateUser、DeleteUser函数完成增删改查；最后在main函数中依次调用测试各操作，验证流程正确性。强调错误处理与SQL注入防护，适合初学者掌握database/sql基础用法。
在Go语言开发中，数据库的增删改查（CRUD）是大多数后端服务的核心功能。本文带你通过一个简单的用户管理项目，实战实现Golang对MySQL数据库的CRUD操作。整个流程清晰、实用，适合初学者快速上手。
项目准备与环境搭建
开始前，确保你已安装Go环境和MySQL数据库。创建一个新的模块目录：
mkdir go-crud-demo cd go-crud-demo go mod init go-crud-demo
安装必要的依赖包，使用database/sql标准库配合mysql-driver驱动：
go get -u github.com/go-sql-driver/mysql
接着，在MySQL中创建测试数据库和表：
立即学习“go语言免费学习笔记（深入）”；
CREATE DATABASE gocrud;
USE gocrud;
CREATE TABLE users (
id INT AUTO_INCREMENT PRIMARY KEY,
name VARCHAR(100) NOT NULL,
email VARCHAR(100) UNIQUE NOT NULL
);
定义数据模型与数据库连接
在项目根目录创建main.go，先定义User结构体，用于映射数据库记录：
type User struct {
ID int `json:"id"`
Name string `json:"name"`
Email string `json:"email"`
}
初始化数据库连接，使用sql.Open并设置连接池参数：
var db *sql.DB
func initDB() {
var err error
dsn := "root:your_password@tcp(127.0.0.1:3306)/gocrud"
db, err = sql.Open("mysql", dsn)
if err != nil {
log.Fatal(err)
}
if err = db.Ping(); err != nil {
log.Fatal(err)
}
log.Println("数据库连接成功")
}
实现CRUD核心逻辑
在main.go中编写四个主要函数：
func createUser(name, email string) (int64, error) {
result, err := db.Exec("INSERT INTO users (name, email) VALUES (?, ?)", name, email)
if err != nil {
return 0, err
}
return result.LastInsertId()
}
GetUser：根据ID查询用户
func getUser(id int) (*User, error) {
user := &User{}
row := db.QueryRow("SELECT id, name, email FROM users WHERE id = ?", id)
if err := row.Scan(&user.ID, &user.Name, &user.Email); err != nil {
return nil, err
}
return user, nil
}
UpdateUser：更新用户信息
func updateUser(id int, name, email string) error {
_, err := db.Exec("UPDATE users SET name = ?, email = ? WHERE id = ?", name, email, id)
return err
}
DeleteUser：删除指定用户
func deleteUser(id int) error {
_, err := db.Exec("DELETE FROM users WHERE id = ?", id)
return err
}
主函数调用示例
在main函数中调用上述方法进行测试：
func main() {
initDB()
defer db.Close()
// Create
id, err := createUser("Alice", "alice@example.com")
if err != nil {
log.Fatal(err)
}
log.Printf("创建用户，ID: %d\n", id)
// Read
user, err := getUser(int(id))
if err != nil {
log.Fatal(err)
}
log.Printf("查询用户: %+v\n", user)
// Update
err = updateUser(int(id), "Alice Wang", "alice.wang@example.com")
if err != nil {
log.Fatal(err)
}
log.Println("用户更新成功")
// 再次查询确认
user, _ = getUser(int(id))
log.Printf("更新后用户: %+v\n", user)
// Delete
err = deleteUser(int(id))
if err != nil {
log.Fatal(err)
}
log.Println("用户删除成功")
}
运行程序：go run main.go，观察日志输出，确认每一步操作都按预期执行。
基本上就这些。这个小项目展示了Golang操作数据库的基本模式。实际开发中可结合HTTP接口、GORM等ORM工具进一步封装，但理解原生database/sql的使用是打好基础的关键。不复杂但容易忽略的是错误处理和SQL注入防范，生产环境务必校验输入并使用预编译语句。
