Go语言中database/sql包的游标使用详解（零基础掌握Go数据库游标操作）

什么是“游标”？

在数据库术语中，“游标”（Cursor）是一种用于遍历查询结果集的机制。它允许你一行一行地处理数据，而不是一次性加载全部结果（这对大数据量查询尤为重要）。

虽然 Go 的 database/sql 没有提供名为 Cursor 的类型，但 *sql.Rows 对象实际上就扮演了游标的角色。

基本使用流程

使用 database/sql 实现“游标”功能通常包括以下步骤：

1. 打开数据库连接
2. 执行查询，获取 *sql.Rows
3. 使用 rows.Next() 循环遍历每一行
4. 用 rows.Scan() 将当前行数据映射到变量
5. 处理完后关闭 rows（非常重要！）

完整代码示例

下面是一个使用 SQLite 数据库演示游标操作的完整例子（你也可以替换为 MySQL 或 PostgreSQL）：

package mainimport (	"database/sql"	"fmt"	_ "github.com/mattn/go-sqlite3" // SQLite 驱动)type User struct {	ID   int	Name string	Age  int}func main() {	// 1. 打开数据库连接	db, err := sql.Open("sqlite3", ":memory:")	if err != nil {		panic(err)	}	defer db.Close()	// 2. 创建表并插入测试数据	_, err = db.Exec(`CREATE TABLE users (id INTEGER PRIMARY KEY, name TEXT, age INTEGER)`)	if err != nil {		panic(err)	}	_, err = db.Exec(`INSERT INTO users (name, age) VALUES (?, ?), (?, ?)`, 		"Alice", 30, "Bob", 25)	if err != nil {		panic(err)	}	// 3. 执行查询，获取 Rows（即“游标”）	rows, err := db.Query("SELECT id, name, age FROM users")	if err != nil {		panic(err)	}	defer rows.Close() // ⚠️ 必须关闭！防止连接泄漏	// 4. 使用 Next() 和 Scan() 遍历结果	var users []User	for rows.Next() {		var u User		err := rows.Scan(&u.ID, &u.Name, &u.Age)		if err != nil {			panic(err)		}		users = append(users, u)	}	// 5. 检查遍历过程中是否有错误	if err = rows.Err(); err != nil {		panic(err)	}	// 6. 输出结果	for _, user := range users {		fmt.Printf("ID: %d, Name: %s, Age: %d\n", user.ID, user.Name, user.Age)	}}  

关键注意事项

• 必须调用 rows.Close()：否则会导致数据库连接无法释放，最终耗尽连接池。
• 使用 defer rows.Close() 是推荐做法，但要注意作用域——确保在 rows 被赋值后再 defer。
• 遍历完成后应调用 rows.Err() 检查是否有底层错误。
• 不要在循环外重复使用同一个变量地址进行 Scan，除非你清楚自己在做什么（容易造成数据覆盖）。

为什么说这是“游标”？

虽然 Go 没有暴露底层游标 API，但 Rows 内部维护了一个指向当前行的指针，每次调用 Next() 就相当于移动游标到下一行。这种方式既安全又高效，特别适合处理大量数据，避免内存溢出。

总结

通过本文，你应该已经掌握了在 Go语言 中如何使用 database/sql 包实现类似“游标”的功能。记住：核心就是 Query → Next → Scan → Close 四步法。

无论你是进行 Go数据库操作，还是需要高效处理查询结果，理解这一机制都至关重要。希望这篇教程能帮助你轻松上手 database/sql 游标使用！

—— 掌握 Go 语言数据库编程，从理解游标开始 ——