首先安装MySQL驱动，然后使用database/sql包连接数据库并执行查询。通过sql.Open()建立连接，db.Ping()测试连通性，QueryRow()查询单行，Query()查询多行并遍历结果，Exec()执行插入等操作，最后用Scan()读取数据并处理错误。完整示例展示了查询用户列表并存入切片输出。
要让Golang项目连接MySQL数据库并执行基本的SQL查询，你需要使用Go的database/sql包搭配一个MySQL驱动。最常用的是
github.com/go-sql-driver/mysql驱动。下面一步步说明如何实现。
安装MySQL驱动
在项目目录下运行以下命令安装MySQL驱动：
go get -u github.com/go-sql-driver/mysql这个驱动实现了
database/sql接口，是连接MySQL的基础。
连接MySQL数据库
使用
sql.Open()函数创建数据库连接。注意这并不会立即建立连接，真正的连接会在第一次需要时建立。
立即学习“go语言免费学习笔记（深入）”；
示例代码：
package mainimport ( "database/sql" "fmt" "log"
_ "github.com/go-sql-driver/mysql"
)
func main() { dsn := "用户名:密码@tcp(localhost:3306)/数据库名" db, err := sql.Open("mysql", dsn) if err != nil { log.Fatal("打开数据库失败:", err) } defer db.Close()
// 测试连接是否成功
if err := db.Ping(); err != nil {
log.Fatal("数据库连接失败:", err)
}
fmt.Println("数据库连接成功")}
说明：
-
用户名:密码@tcp(主机:端口)/数据库名是标准的DSN（Data Source Name）格式。
- 导入驱动时使用
_ "github.com/go-sql-driver/mysql"是为了触发其
init()函数注册驱动。
-
db.Ping()用于验证与数据库的连接是否正常。
执行基本SQL查询
连接成功后，可以使用
Query()、
QueryRow()、
Exec()等方法执行SQL操作。
1. 查询单行数据（QueryRow）
var id int var name string err := db.QueryRow("SELECT id, name FROM users WHERE id = ?", 1).Scan(&id, &name) if err != nil { log.Fatal("查询失败:", err) } fmt.Printf("用户: %d, %s\n", id, name)2. 查询多行数据（Query）
rows, err := db.Query("SELECT id, name FROM users") if err != nil { log.Fatal("查询失败:", err) } defer rows.Close()for rows.Next() { var id int var name string if err := rows.Scan(&id, &name); err != nil { log.Fatal("读取数据失败:", err) } fmt.Printf("ID: %d, Name: %s\n", id, name) }
if err := rows.Err(); err != nil { log.Fatal("遍历行时出错:", err) }
3. 执行插入、更新、删除（Exec）
result, err := db.Exec("INSERT INTO users(name, email) VALUES(?, ?)", "Alice", "alice@example.com") if err != nil { log.Fatal("插入失败:", err) }lastId, err := result.LastInsertId() if err != nil { log.Fatal("获取ID失败:", err) } fmt.Printf("插入成功，ID: %d\n", lastId)
注意：所有SQL操作都应处理错误，尤其是
Scan和
Exec后的返回值。
完整示例：查询用户列表
package mainimport ( "database/sql" "fmt" "log"
_ "github.com/go-sql-driver/mysql"
)
type User struct { ID int Name string }
func main() { dsn := "root:123456@tcp(localhost:3306)/testdb" db, err := sql.Open("mysql", dsn) if err != nil { log.Fatal(err) } defer db.Close()
if err := db.Ping(); err != nil {
log.Fatal(err)
}
rows, err := db.Query("SELECT id, name FROM users")
if err != nil {
log.Fatal(err)
}
defer rows.Close()
var users []User
for rows.Next() {
var u User
if err := rows.Scan(&u.ID, &u.Name); err != nil {
log.Fatal(err)
}
users = append(users, u)
}
for _, u := range users {
fmt.Printf("用户: %d - %s\n", u.ID, u.Name)
}}
基本上就这些。只要配置好DSN，导入驱动，使用
database/sql的标准方法，就能稳定地操作MySQL。实际项目中建议封装数据库操作，使用连接池配置（如
SetMaxOpenConns）提升性能。
