当前位置：首页 > 文章列表 > Golang > Go教程 > Golang操作MySQL：CRUD入门教程

Golang操作MySQL：CRUD入门教程

2025-07-02 19:41:50 0浏览收藏

小伙伴们对Golang编程感兴趣吗？是否正在学习相关知识点？如果是，那么本文《Golang操作MySQL数据库：CRUD基础教程》，就很适合你，本篇文章讲解的知识点主要包括。在之后的文章中也会多多分享相关知识点，希望对大家的知识积累有所帮助！

本文介绍了使用 Golang 的 database/sql 标准库实现 MySQL 数据库的 CRUD 操作。1. 首先需要安装 MySQL 驱动并建立连接，使用 sql.Open() 创建连接并用 Ping() 测试连通性；2. 查询数据时通过 Query() 执行 SELECT 语句，并使用 rows.Next() 和 Scan() 遍历结果集；3. 插入数据使用 Exec() 方法配合占位符防止 SQL 注入，并通过 Result 获取插入 ID 和影响行数；4. 更新和删除操作同样使用 Exec()，通过 RowsAffected() 获取受影响行数以确保操作准确；5. 最后提醒了错误处理、结构体封装、连接池配置及日志开启等开发注意事项。

Golang初学者如何操作MySQL数据库介绍database/sql的基本CRUD

在学习 Golang 的过程中，操作 MySQL 是一个非常常见的需求。对于初学者来说，database/sql 标准库已经足够完成大多数基础的数据库操作任务。本文就来聊聊如何用 database/sql 实现基本的 CRUD（增删改查）操作。

安装驱动并连接数据库

Go 本身不包含特定数据库的实现，需要引入对应的驱动。MySQL 常见的驱动是 github.com/go-sql-driver/mysql。

安装命令：

go get -u github.com/go-sql-driver/mysql

然后使用 sql.Open() 来建立连接：

import (
    "database/sql"
    _ "github.com/go-sql-driver/mysql"
)

func main() {
    db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/dbname")
    if err != nil {
        panic(err)
    }
    defer db.Close()
}

sql.Open() 第一个参数是驱动名，第二个是 DSN（数据源名称）
连接池默认是懒加载的，调用 Ping() 可以立即测试是否连得上：

err = db.Ping()
if err != nil {
    panic(err)
}

查询数据（Read）

查询是最常用的操作之一。使用 Query() 方法执行 SELECT 语句：

rows, err := db.Query("SELECT id, name FROM users")
if err != nil {
    panic(err)
}
defer rows.Close()

var id int
var name string

for rows.Next() {
    err := rows.Scan(&id, &name)
    if err != nil {
        panic(err)
    }
    fmt.Println(id, name)
}

使用 rows.Next() 遍历每一行
用 Scan() 把字段值赋给变量
别忘了关闭 rows，避免资源泄露

注意：如果只需要一行结果，可以使用 QueryRow()，它会自动处理单行数据。

插入数据（Create）

插入数据使用 Exec() 方法，它返回一个 Result 接口，可以获取影响的行数和最后插入 ID：

result, err := db.Exec("INSERT INTO users (name) VALUES (?)", "Tom")
if err != nil {
    panic(err)
}

lastID, _ := result.LastInsertId()
rowCnt, _ := result.RowsAffected()

fmt.Printf("Last inserted ID: %d, Rows affected: %d\n", lastID, rowCnt)

使用占位符 ? 防止 SQL 注入
支持传多个参数，比如 "INSERT INTO table (a, b) VALUES (?, ?)", val1, val2
如果你需要批量插入，可以考虑拼接语句或使用事务

更新与删除（Update & Delete）

更新和删除操作也使用 Exec() 方法，它们不会返回数据行，只关心影响了多少行记录。

更新数据

result, err := db.Exec("UPDATE users SET name = ? WHERE id = ?", "Jerry", 1)
if err != nil {
    panic(err)
}

cnt, _ := result.RowsAffected()
fmt.Printf("Updated %d rows\n", cnt)

删除数据

result, err := db.Exec("DELETE FROM users WHERE id = ?", 1)
if err != nil {
    panic(err)
}

cnt, _ := result.RowsAffected()
fmt.Printf("Deleted %d rows\n", cnt)