在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)
}
}如果是多条记录:
PHP是一种功能强大的网络程序设计语言,而且易学易用,移植性和可扩展性也都非常优秀,本书将为读者详细介绍PHP编程。 全书分为预备篇、开始篇和加速篇三大部分,共9章。预备篇主要介绍一些学习PHP语言的预备知识以及PHP运行平台的架设;开始篇则较为详细地向读者介绍PKP语言的基本语法和常用函数,以及用PHP如何对MySQL数据库进行操作;加速篇则通过对典型实例的介绍来使读者全面掌握PHP。 本书
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虽然抽象层次较高,但结构清晰,配合具体驱动使用起来非常灵活。只要理解连接池、查询、执行和预编译这几个核心点,日常开发中就够用了。









