Golang连接MySQL数据库教程

珍惜时间，勤奋学习！今天给大家带来《Golang操作MySQL数据库入门指南》，正文内容主要涉及到等等，如果你正在学习Golang，或者是对Golang有疑问，欢迎大家关注我！后面我会持续更新相关内容的，希望都能帮到正在学习的大家！

本文介绍了使用 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 标准库已经足够完成大多数基础的数据库操作任务。本文就来聊聊如何用 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)

• 更新和删除时要特别小心 WHERE 条件，防止误删/误改
• 可以先用 SELECT 看看要操作的数据对不对

小贴士

• 不要忘记错误检查：每一步都可能出错，特别是数据库交互部分。
• 使用结构体封装逻辑更清晰：可以把查询、插入等封装成函数或方法。
• 别忽视连接池配置：可以通过 SetMaxOpenConns() 和 SetMaxIdleConns() 控制连接池大小。
• 开发阶段建议开启日志：方便调试 SQL 执行情况。

基本上就这些内容了。虽然看起来有点繁琐，但一旦熟悉之后，database/sql 的模式其实很统一，也不难掌握。只要注意细节，CRUD 操作就能稳稳地跑起来。

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《Golang连接MySQL数据库教程》文章吧，也可关注golang学习网公众号了解相关技术文章。