Golang操作数据库，database/sql核心功能详解

在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函数创建一个连接池：

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虽然抽象层次较高，但结构清晰，配合具体驱动使用起来非常灵活。只要理解连接池、查询、执行和预编译这几个核心点，日常开发中就够用了。