Go语言中database/sql的用法介绍

下面是“Go语言中database/sql的用法介绍”的完整攻略。

一、什么是database/sql

database/sql是Go语言的标准库之一，提供了连接和操作各种SQL数据库的API。通过database/sql，开发者可以使用相同的API连接MySQL、PostgreSQL、SQLite等多种关系型数据库，开发可移植性更高的应用程序。

二、database/sql用法介绍

1. 连接数据库

连接数据库是操作数据库的第一步，而database/sql提供了一个Open函数用于连接各种类型的数据库。Open函数需要两个参数：数据库的驱动名和数据源名，其中数据源名的具体内容取决于不同的数据库。例如连接MySQL，可以使用以下代码：

import (
    "database/sql"
    _ "github.com/go-sql-driver/mysql"
)

db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/dbname")
if err != nil {
    // 处理错误
}
defer db.Close()

2. 查询数据

成功连接数据库后，就可以使用Query函数查询数据了。Query函数需要一个SQL语句作为参数，并返回一个*Rows类型的结果集。例如查询MySQL中的users表并打印所有数据：

rows, err := db.Query("SELECT * FROM users")
if err != nil {
    // 处理错误
}
defer rows.Close()

for rows.Next() {
    var id int
    var name string
    err := rows.Scan(&id, &name)
    if err != nil {
        // 处理错误
    }
    fmt.Printf("id: %d, name: %s\n", id, name)
}

if err := rows.Err(); err != nil {
    // 处理错误
}

3. 插入数据

使用Exec函数可以向数据库中插入数据。Exec函数需要一个SQL语句作为参数，并返回一个Result类型的结果集。例如向MySQL的users表中插入一条数据：

result, err := db.Exec("INSERT INTO users(name) VALUES('xiaoming')")
if err != nil {
    // 处理错误
}

lastInsertId, err := result.LastInsertId()
if err != nil {
    // 处理错误
}

rowsAffected, err := result.RowsAffected()
if err != nil {
    // 处理错误
}

fmt.Printf("last insert id: %d, rows affected: %d\n", lastInsertId, rowsAffected)

三、示例说明

1. 连接MySQL

以下示例演示了如何使用database/sql连接MySQL数据库：

import (
    "database/sql"
    _ "github.com/go-sql-driver/mysql"
)

db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/dbname")
if err != nil {
    // 处理错误
}
defer db.Close()

2. 查询PostgreSQL

以下示例演示了如何使用database/sql查询PostgreSQL中的数据：

import (
    "database/sql"
    _ "github.com/lib/pq"
)

db, err := sql.Open("postgres", "postgresql://user:password@host:port/dbname?sslmode=disable")
if err != nil {
    // 处理错误
}
defer db.Close()

rows, err := db.Query("SELECT * FROM users")
if err != nil {
    // 处理错误
}
defer rows.Close()

for rows.Next() {
    // 处理数据
}

if err := rows.Err(); err != nil {
    // 处理错误
}