Go语言 database/sql 包：如何高效查询并处理多个数据库字段

package main

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

func main() {
    db, err := sql.Open("mysql", "root:Password1@/wiki1")
    if err != nil {
        fmt.Println(err)
        return
    }
    defer db.Close()

    st, err := db.Prepare("SELECT title FROM page WHERE title=?") // 仅查询了title字段
    if err != nil {
        fmt.Println(err)
        return // 添加return以防止nil st的后续使用
    }
    defer st.Close() // 准备好的语句也需要关闭

    rows, err := st.Query("title1")
    if err != nil {
        fmt.Println(err)
        return
    }
    defer rows.Close() // 确保行结果集被关闭

    for rows.Next() {
        var title, body string // 声明了body，但没有扫描
        if err := rows.Scan(&title); err != nil { // 仅扫描了title
            fmt.Println(err)
        }
        fmt.Printf("%s\n", title)
    }
    if err := rows.Err(); err != nil {
        fmt.Println(err)
    }
}

SELECT title FROM page WHERE title=?

SELECT body, title FROM page WHERE title=?

var title, body string
if err := rows.Scan(&title); err != nil {
    fmt.Println(err)
}

var body, title string // 变量声明顺序不强制与扫描顺序一致，但为了可读性，建议保持一致
if err := rows.Scan(&body, &title); err != nil { // 注意这里是&body在前，与SELECT语句的顺序匹配
    fmt.Println(err)
}

fmt.Printf("标题: %s\n内容: %s\n", title, body)

package main

import (
    "database/sql"
    "fmt"
    _ "github.com/go-sql-driver/mysql" // 导入MySQL驱动
)

func main() {
    // 1. 连接数据库
    // 替换为你的MySQL连接字符串：root:密码@tcp(主机:端口)/数据库名
    db, err := sql.Open("mysql", "root:Password1@tcp(127.0.0.1:3306)/wiki1")
    if err != nil {
        fmt.Printf("数据库连接失败: %v\n", err)
        return
    }
    defer db.Close() // 确保数据库连接在函数结束时关闭

    // 尝试ping数据库以验证连接是否有效
    err = db.Ping()
    if err != nil {
        fmt.Printf("无法连接到数据库: %v\n", err)
        return
    }
    fmt.Println("成功连接到数据库！")

    // 2. 准备SQL查询语句，指定要获取的所有字段
    // 注意：SELECT子句中字段的顺序 (body, title) 决定了rows.Scan的参数顺序
    st, err := db.Prepare("SELECT body, title FROM page WHERE title=?")
    if err != nil {
        fmt.Printf("准备查询语句失败: %v\n", err)
        return
    }
    defer st.Close() // 确保预处理语句在函数结束时关闭

    // 3. 执行查询
    queryTitle := "title1" // 示例查询条件
    rows, err := st.Query(queryTitle)
    if err != nil {
        fmt.Printf("执行查询失败: %v\n", err)
        return
    }
    defer rows.Close() // 确保行结果集在函数结束时关闭

    // 4. 遍历查询结果并扫描字段
    found := false
    for rows.Next() {
        var body string
        var title string // 声明用于接收字段值的变量

        // 扫描结果到变量中，顺序必须与SELECT子句中的字段顺序一致
        if err := rows.Scan(&body, &title); err != nil {
            fmt.Printf("扫描行数据失败: %v\n", err)
            // 根据错误类型决定是继续还是中断
            continue
        }

        // 5. 打印或使用获取到的字段值
        fmt.Printf("查询结果 - 标题: %s, 内容: %s\n", title, body)
        found = true
    }

    // 检查是否有遍历rows时发生的错误
    if err := rows.Err(); err != nil {
        fmt.Printf("遍历行结果集时发生错误: %v\n", err)
    }

    if !found {
        fmt.Printf("未找到标题为 '%s' 的记录。\n", queryTitle)
    }
}