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

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

P粉602998670

发布： 2025-07-23 10:10:02

原创

847人浏览过

本文介绍了使用 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语言免费学习笔记（深入）”；

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

登录后复制

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

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

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

查看详情

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)

登录后复制