在golang中操作数据库最常用的方式是使用database/sql标准库，其核心在于理解连接池、查询、执行和预编译等要点。1. 建立连接时需导入驱动并调用sql.open创建连接池，同时设置最大打开数与空闲数；2. 查询数据可使用queryrow或query分别处理单行或多行结果，并注意调用scan进行字段匹配及关闭rows；3. 写入与更新通过exec方法执行，返回受影响行数，插入时可获取lastinsertid，但需注意数据库兼容性；4. 使用prepare预编译sql语句以提升性能与安全性，适合批量操作。掌握这些核心功能即可灵活管理各种数据库。
在Golang中操作数据库，最常用的方式是使用标准库中的
database/sql
。它本身并不直接提供数据库操作功能，而是定义了一套接口，由具体的数据库驱动来实现。掌握它的核心功能，就能灵活地连接、查询和管理各种数据库。
连接数据库：准备好你的“通行证”
要操作数据库，首先要建立连接。这一步就像拿到进入数据库的钥匙。
以MySQL为例，你需要先导入驱动（比如
github.com/go-sql-driver/mysql
），然后使用
sql.Open
函数创建一个连接池：
立即学习“go语言免费学习笔记（深入）”；
db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/dbname") if err != nil { log.Fatal(err) }
这里要注意两点：
-
sql.Open
并不会立即建立连接，而是在第一次需要的时候才会真正去连。
- 它返回的是一个连接池，不是单个连接。你不需要自己维护多个连接。
建议设置连接池的最大打开数和最大空闲数，避免资源耗尽：
db.SetMaxOpenConns(10) db.SetMaxIdleConns(5)
查询数据：获取你需要的信息
查询是最常见的操作之一。
database/sql
提供了两种主要方法：
QueryRow
用于获取一行结果，
Query
用于多行。
例如，查询用户信息：
var name string err := db.QueryRow("SELECT name FROM users WHERE id = ?", 1).Scan(&name) if err != nil { if err == sql.ErrNoRows { // 没有找到记录 } else { log.Fatal(err) } }
如果是多条记录：
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.Println(id, name) }
几点提示：
- 记得调用
rows.Close()
，否则会泄露连接。
- 使用
Scan
时要注意字段顺序和类型的匹配。
写入与更新：插入和修改数据
写入操作包括插入（INSERT）、更新（UPDATE）和删除（DELETE）。这些操作通常使用
Exec
方法执行，并返回受影响的行数。
举个插入的例子：
result, err := db.Exec("INSERT INTO users(name, age) VALUES(?, ?)", "Tom", 25) if err != nil { log.Fatal(err) } lastID, _ := result.LastInsertId() fmt.Println("Last inserted ID:", lastID)
更新操作类似：
res, err := db.Exec("UPDATE users SET age = ? WHERE id = ?", 30, 1) if err != nil { log.Fatal(err) } rowsAffected, _ := res.RowsAffected() fmt.Println("Rows affected:", rowsAffected)
注意：
- 不同数据库对
LastInsertId
的支持可能不同。
- 执行写操作时要处理事务或确保原子性，防止数据不一致。
使用预编译语句提升性能和安全性
如果你多次执行相同的SQL语句，可以使用
Prepare
来预编译，提高效率并防止SQL注入。
示例：
stmt, err := db.Prepare("INSERT INTO users(name, age) VALUES(?, ?)") if err != nil { log.Fatal(err) } defer stmt.Close() _, err = stmt.Exec("Alice", 28) _, err = stmt.Exec("Bob", 32)
这种方式特别适合批量操作，也能让代码更清晰安全。
基本上就这些。
database/sql
虽然抽象层次较高，但结构清晰，配合具体驱动使用起来非常灵活。只要理解连接池、查询、执行和预编译这几个核心点，日常开发中就够用了。
评论（已关闭）
评论已关闭