Go语言通过database/sql包操作数据库简洁高效，需先安装驱动如go-sql-driver/mysql并导入。使用sql.Open("mysql", DSN)连接数据库，DSN格式为用户:密码@协议(地址:端口)/数据库名，再调用db.Ping()测试连接。执行插入用db.Exec("INSERT...")获取结果和ID，查询单行用db.QueryRow().Scan()绑定变量，多行查询用db.Query()遍历rows。为防SQL注入且提升性能，应使用db.Prepare()创建预处理语句。事务通过db.Begin()开启，tx.Exec()执行操作，成功则tx.Commit()提交，失败需tx.Rollback()回滚。务必处理error并defer关闭db、rows、stmt等资源。掌握这些核心方法即可覆盖多数数据库场景。
Go语言通过database/sql包操作数据库非常简洁高效。它提供了一套标准接口，配合对应的驱动（如MySQL、PostgreSQL、SQLite等），可以实现数据库的连接、查询、插入、更新和事务处理。下面以MySQL为例，详细介绍如何使用database/sql进行数据库操作。
1. 安装驱动并导入包
Go的'database/sql'是标准库，但不包含具体数据库驱动，需要额外引入。以MySQL为例，常用驱动是github.com/go-sql-driver/mysql。
安装命令：
go get -u github.com/go-sql-driver/mysql
在代码中导入：
立即学习“go语言免费学习笔记（深入）”；
import (
"database/sql"
_ "github.com/go-sql-driver/mysql"
)
注意：下划线表示初始化驱动，让sql.Open能识别"mysql"类型。
2. 连接数据库
使用sql.Open创建数据库连接对象，传入驱动名和数据源名称（DSN）。
db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/dbname")
if err != nil {
log.Fatal(err)
}
defer db.Close()
// 测试连接
err = db.Ping()
if err != nil {
log.Fatal(err)
}
常见DSN格式：用户名:密码@协议(地址:端口)/数据库名。可添加参数如charset=utf8mb4&parseTime=True。
3. 执行SQL操作
连接成功后，就可以执行各类SQL语句。
-
插入数据：
result, err := db.Exec("INSERT INTO users(name, age) VALUES(?, ?)", "Alice", 25) if err != nil { log.Fatal(err) } id, _ := result.LastInsertId() fmt.Printf("插入ID: %d\n", id) -
查询单行：使用QueryRow
var name string var age int err := db.QueryRow("SELECT name, age FROM users WHERE id = ?", 1).Scan(&name, &age) if err != nil { log.Fatal(err) } fmt.Printf("姓名: %s, 年龄: %d\n", name, age) -
查询多行：使用Query
rows, err := db.Query("SELECT id, name, age FROM users") if err != nil { log.Fatal(err) } defer rows.Close() for rows.Next() { var id int var name string var age int rows.Scan(&id, &name, &age) fmt.Printf("ID: %d, 姓名: %s, 年龄: %d\n", id, name, age) }
4. 使用预处理语句防止SQL注入
频繁执行相同SQL时，建议使用Prepare提升性能并增强安全性。
stmt, err := db.Prepare("INSERT INTO users(name, age) VALUES(?, ?)")
if err != nil {
log.Fatal(err)
}
defer stmt.Close()
_, err = stmt.Exec("Bob", 30)
_, err = stmt.Exec("Charlie", 35)
5. 事务处理
使用Begin开启事务，Commit提交，Rollback回滚。
tx, err := db.Begin()
if err != nil {
log.Fatal(err)
}
_, err = tx.Exec("INSERT INTO users(name, age) VALUES(?, ?)", "David", 28)
if err != nil {
tx.Rollback()
log.Fatal(err)
}
err = tx.Commit()
if err != nil {
log.Fatal(err)
}
基本上就这些。掌握Open、Exec、Query、Prepare和事务，就能应对大多数数据库操作场景。关键是记得处理error和关闭资源。不复杂但容易忽略细节。
