当前位置：首页 > news >正文

Go语言连接 MySQL 教程：Golang 数据库操作入门

news 2026/5/12 11:57:22

为什么学习 Go 操作 MySQL 很重要

如果说前面的语法、结构体、并发是 Go 的语言基础，那么数据库操作就是把 Go 真正带入实际项目开发的重要一步。大部分 Web 系统、后台服务、管理系统、接口平台，都离不开数据库支持，而 MySQL 又是最常见的关系型数据库之一。

对于 Go 开发者来说，学会连接 MySQL，不只是为了完成简单的数据读写，更重要的是理解服务端程序如何管理数据、组织业务逻辑以及处理异常场景。

Go连接 MySQL 需要准备什么

Go 连接 MySQL，通常会使用标准库 database/sql 配合 MySQL 驱动一起完成。

首先需要安装驱动：

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

然后在代码中导入：

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

这里的下划线导入非常关键，因为它会执行驱动注册，但不会直接使用包名。

Go如何建立 MySQL 数据库连接

建立连接的基本写法如下：

dsn := "root:123456@tcp(127.0.0.1:3306)/testdb?charset=utf8mb4&parseTime=True&loc=Local"db, err := sql.Open("mysql", dsn)
if err != nil {fmt.Println("连接数据库失败：", err)return
}
defer db.Close()

这里的 dsn 就是数据库连接字符串，包含用户名、密码、地址、端口、数据库名以及一些额外参数。

不过要注意，sql.Open() 本身并不会立刻真正建立数据库连接，它更像是初始化连接对象。为了确认数据库是否真的可用，通常还要执行：

err = db.Ping()
if err != nil {fmt.Println("数据库不可用：", err)return
}
fmt.Println("数据库连接成功")

Go如何查询 MySQL 数据

查询数据库时，常见分为单条查询和多条查询。

查询多条数据

例如查询用户列表：

rows, err := db.Query("SELECT id, name, age FROM users")
if err != nil {fmt.Println("查询失败：", err)return
}
defer rows.Close()for rows.Next() {var id intvar name stringvar age interr := rows.Scan(&id, &name, &age)if err != nil {fmt.Println("读取数据失败：", err)return}fmt.Println(id, name, age)
}

这里 rows.Next() 用于遍历结果集，rows.Scan() 用于把每一行的数据读取到变量中。

查询单条数据

var name string
var age interr := db.QueryRow("SELECT name, age FROM users WHERE id = ?", 1).Scan(&name, &age)
if err != nil {fmt.Println("查询失败：", err)return
}
fmt.Println(name, age)

这种方式适合查找单个对象，比如按 ID 查询用户信息。

Go如何执行插入、更新和删除操作

在 Go 中，插入、更新、删除通常使用 Exec() 方法。

插入数据

result, err := db.Exec("INSERT INTO users(name, age) VALUES(?, ?)", "Tom", 20)
if err != nil {fmt.Println("插入失败：", err)return
}

如果需要获取新插入数据的 ID：

id, _ := result.LastInsertId()
fmt.Println("插入成功，ID：", id)

更新数据

result, err := db.Exec("UPDATE users SET age = ? WHERE id = ?", 25, 1)
if err != nil {fmt.Println("更新失败：", err)return
}

删除数据

result, err := db.Exec("DELETE FROM users WHERE id = ?", 1)
if err != nil {fmt.Println("删除失败：", err)return
}

如果要查看影响了多少行，可以使用：

rowsAffected, _ := result.RowsAffected()
fmt.Println("影响行数：", rowsAffected)

Go操作 MySQL 时为什么推荐预处理

在实际项目中，如果某条 SQL 会被频繁执行，或者希望让代码更清晰，可以使用预处理语句。

例如：

stmt, err := db.Prepare("INSERT INTO users(name, age) VALUES(?, ?)")
if err != nil {fmt.Println("预处理失败：", err)return
}
defer stmt.Close()_, err = stmt.Exec("Alice", 22)
if err != nil {fmt.Println("执行失败：", err)
}

预处理不仅有助于提高一定的执行效率，也能让参数传递更加规范。