Golang数据库CRUD操作项目实战-Golang-PHP中文网

Golang数据库CRUD操作项目实战

P粉602998670

发布： 2025-09-30 10:23:02

原创

326人浏览过

答案：本文通过用户管理项目演示Go语言操作MySQL实现CRUD。首先搭建环境并创建数据库表，定义User结构体和数据库连接；接着编写CreateUser、GetUser、UpdateUser、DeleteUser函数完成增删改查；最后在main函数中依次调用测试各操作，验证流程正确性。强调错误处理与SQL注入防护，适合初学者掌握database/sql基础用法。

golang数据库crud操作项目实战

在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结构体，用于映射数据库记录：

怪兽AI数字人

数字人短视频创作，数字人直播，实时驱动数字人

查看详情

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中编写四个主要函数：

CreateUser：插入新用户

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注入防范，生产环境务必校验输入并使用预编译语句。

以上就是Golang数据库CRUD操作项目实战的详细内容，更多请关注php中文网其它相关文章！