答案：本文通过Golang与MySQL实现用户管理的CRUD操作，涵盖环境搭建、数据模型定义、数据库连接、增删改查接口编写及路由注册，使用net/http和gorilla/mux构建RESTful API，最后启动服务并建议生产环境优化。
在Go语言中实现基础的CRUD（创建、读取、更新、删除）操作是开发后端服务的核心技能之一。本文将通过一个简单的用户管理示例，使用Golang + MySQL来演示完整的CRUD流程，帮助你快速上手实战开发。
环境准备与依赖安装
开始前，确保你已安装Go和MySQL数据库。然后创建项目目录并初始化模块：
mkdir go-crud-example && cd go-crud-examplego mod init go-crud-example
接着安装MySQL驱动：
go get -u github.com/go-sql-driver/mysql这个驱动允许Go程序连接和操作MySQL数据库。
立即学习“go语言免费学习笔记（深入）”；
定义数据模型与数据库连接
创建一个User结构体来映射数据库表字段：
type User struct {ID int 'json:"id"'
Name string 'json:"name"'
Email string 'json:"email"'
}
然后编写数据库连接函数：
func ConnectDB() *sql.DB {
db, err := sql.Open("mysql", "root:password@tcp(127.0.0.1:3306)/testdb")
if err != nil {
log.Fatal(err)
}
if err := db.Ping(); err != nil {
log.Fatal(err)
}
return db
}
确保你的MySQL中已创建testdb数据库，并建好users表：
CREATE TABLE users (id INT AUTO_INCREMENT PRIMARY KEY,
name VARCHAR(100),
email VARCHAR(100)
);
实现CRUD接口逻辑
接下来为每个操作编写处理函数。
Create（创建） func createUser(w http.ResponseWriter, r *http.Request) {var user User
if err := json.NewDecoder(r.Body).Decode(&user); err != nil {
http.Error(w, "Invalid request payload", http.StatusBadRequest)
return
}
db := ConnectDB()
defer db.Close()
stmt, _ := db.Prepare("INSERT INTO users(name, email) VALUES(?, ?)")
result, _ := stmt.Exec(user.Name, user.Email)
id, _ := result.LastInsertId()
user.ID = int(id)
w.Header().Set("Content-Type", "application/json")
json.NewEncoder(w).Encode(user)
} Read（读取） func getUsers(w http.ResponseWriter, r *http.Request) {
db := ConnectDB()
defer db.Close()
rows, _ := db.Query("SELECT id, name, email FROM users")
defer rows.Close()
var users []User
for rows.Next() {
var u User
rows.Scan(&u.ID, &u.Name, &u.Email)
users = append(users, u)
}
w.Header().Set("Content-Type", "application/json")
json.NewEncoder(w).Encode(users)
} Update（更新） func updateUser(w http.ResponseWriter, r *http.Request) {
vars := mux.Vars(r)
id := vars["id"]
var user User
json.NewDecoder(r.Body).Decode(&user)
db := ConnectDB()
defer db.Close()
stmt, _ := db.Prepare("UPDATE users SET name=?, email=? WHERE id=?")
stmt.Exec(user.Name, user.Email, id)
w.WriteHeader(http.StatusOK)
} Delete（删除） func deleteUser(w http.ResponseWriter, r *http.Request) {
vars := mux.Vars(r)
id := vars["id"]
db := ConnectDB()
defer db.Close()
stmt, _ := db.Prepare("DELETE FROM users WHERE id=?")
stmt.Exec(id)
w.WriteHeader(http.StatusNoContent)
}
注册路由并启动服务
使用gorilla/mux作为路由器：
go get -u github.com/gorilla/mux在main函数中注册路由：
func main() {r := mux.NewRouter()
r.HandleFunc("/users", getUsers).Methods("GET")
r.HandleFunc("/users", createUser).Methods("POST")
r.HandleFunc("/users/{id}", updateUser).Methods("PUT")
r.HandleFunc("/users/{id}", deleteUser).Methods("DELETE")
fmt.Println("Server running on :8080")
http.ListenAndServe(":8080", r)
}
运行程序后，可通过curl或Postman测试各个接口。
基本上就这些。这套结构清晰、代码简洁的实现方式适合学习和小型项目起步。注意生产环境中需加入错误处理、SQL注入防护、连接池配置和中间件日志等机制。
