如何在Golang中实现基础的CRUD操作_Golang CRUD操作实战-Golang-PHP中文网

如何在Golang中实现基础的CRUD操作_Golang CRUD操作实战

P粉602998670

发布： 2025-11-17 15:45:39

原创

490人浏览过

答案：本文通过Golang与MySQL实现用户管理的CRUD操作，涵盖环境搭建、数据模型定义、数据库连接、增删改查接口编写及路由注册，使用net/http和gorilla/mux构建RESTful API，最后启动服务并建议生产环境优化。

如何在golang中实现基础的crud操作_golang crud操作实战

在Go语言中实现基础的CRUD（创建、读取、更新、删除）操作是开发后端服务的核心技能之一。本文将通过一个简单的用户管理示例，使用Golang + MySQL来演示完整的CRUD流程，帮助你快速上手实战开发。

环境准备与依赖安装

开始前，确保你已安装Go和MySQL数据库。然后创建项目目录并初始化模块：

mkdir go-crud-example && cd go-crud-example
go 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"'
}

然后编写数据库连接函数：

PPT.CN,PPTCN,PPT.CN是什么,PPT.CN官网,PPT.CN如何使用

一键操作，智能生成专业级PPT

查看详情

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注入防护、连接池配置和中间件日志等机制。

以上就是如何在Golang中实现基础的CRUD操作_Golang CRUD操作实战的详细内容，更多请关注php中文网其它相关文章！