Golang中如何操作数据库掌握database/sql库的核心功能-Golang-PHP中文网

Golang中如何操作数据库掌握database/sql库的核心功能

P粉602998670

发布： 2025-08-12 08:24:02

原创

694人浏览过

在golang中操作数据库最常用的方式是使用database/sql标准库，其核心在于理解连接池、查询、执行和预编译等要点。1. 建立连接时需导入驱动并调用sql.open创建连接池，同时设置最大打开数与空闲数；2. 查询数据可使用queryrow或query分别处理单行或多行结果，并注意调用scan进行字段匹配及关闭rows；3. 写入与更新通过exec方法执行，返回受影响行数，插入时可获取lastinsertid，但需注意数据库兼容性；4. 使用prepare预编译sql语句以提升性能与安全性，适合批量操作。掌握这些核心功能即可灵活管理各种数据库。

Golang中如何操作数据库掌握database/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)
    }
}

登录后复制

如果是多条记录：

库宝AI

库宝AI是一款功能多样的智能伙伴助手，涵盖AI写作辅助、智能设计、图像生成、智能对话等多个方面。

109

查看详情

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)

登录后复制

这种方式特别适合批量操作，也能让代码更清晰安全。

基本上就这些。