使用Golang操作数据库：数据获取功能失效问题求助

我最近写了几个用于连接MySQL数据库并获取数据的函数，但数据获取功能完全没法正常工作。目前整理出了对应结构体定义和main.go的部分代码片段，麻烦帮忙看看问题出在哪：

package main
import (
    "database/sql"
    "log"
    "net/http"
    "text/template"
    _ "github.com/go-sql-driver/mysql"
)

type maintable struct {
    Id int
    Location string
    Picname string
    Malefemale string
    Name string
    Country string
    Connections int
}

func dbConn() (db *sql.DB) {
    db, err := sql.Open("mysql", "root:@/test_db")
    if err != nil {
        panic(err.Error())
    }
    // 原本还有后续代码，但没贴全
    return db
}

// 其他数据获取相关函数均无法正常返回数据

我梳理了几个大概率的问题点，附修改建议： #

• 数据库连接未实际验证：sql.Open()只是初始化连接池，并不会真正和数据库建立连接。如果你的dbConn()函数里没调用db.Ping()，可能连接根本没成功，后续查询自然失败。
• 结构体字段映射不匹配：Go的sql包默认大小写敏感，如果数据库表字段是小写（比如id、location），而结构体字段是大写开头，必须给结构体加db:"字段名"标签，否则无法正确映射查询结果。
• 查询函数错误处理缺失：如果数据获取函数里没正确处理rows.Scan()的错误，或者忘记关闭rows，会导致数据获取失败甚至资源泄漏。
• 错误处理过于粗暴：用panic()直接崩溃不利于排查问题，应该返回错误给调用者并记录日志。

具体修改方案： #

1. 完善数据库连接函数，添加连接验证

func dbConn() (*sql.DB, error) {
    db, err := sql.Open("mysql", "root:@/test_db")
    if err != nil {
        return nil, err
    }
    // 实际验证连接是否有效
    if err := db.Ping(); err != nil {
        db.Close()
        return nil, err
    }
    return db, nil
}

2. 给结构体添加数据库字段映射标签

type maintable struct {
    Id          int    `db:"id"`
    Location    string `db:"location"`
    Picname     string `db:"picname"`
    Malefemale  string `db:"malefemale"`
    Name        string `db:"name"`
    Country     string `db:"country"`
    Connections int    `db:"connections"`
}

3. 正确实现数据查询函数

func getMainTableData(db *sql.DB) ([]maintable, error) {
    // 确保查询语句和数据库表字段完全匹配
    rows, err := db.Query("SELECT id, location, picname, malefemale, name, country, connections FROM maintable")
    if err != nil {
        return nil, err
    }
    defer rows.Close() // 必须关闭rows，避免资源泄漏

    var dataList []maintable
    for rows.Next() {
        var item maintable
        // Scan参数顺序必须和查询语句字段顺序一致
        err := rows.Scan(&item.Id, &item.Location, &item.Picname, &item.Malefemale, &item.Name, &item.Country, &item.Connections)
        if err != nil {
            return nil, err
        }
        dataList = append(dataList, item)
    }
    // 检查遍历过程中是否出现错误
    if err := rows.Err(); err != nil {
        return nil, err
    }
    return dataList, nil
}

4. 在HTTP Handler中正确使用这些函数

func main() {
    http.HandleFunc("/", dataHandler)
    log.Fatal(http.ListenAndServe(":8080", nil))
}

func dataHandler(w http.ResponseWriter, r *http.Request) {
    db, err := dbConn()
    if err != nil {
        log.Printf("数据库连接失败：%v", err)
        http.Error(w, "服务器内部错误", http.StatusInternalServerError)
        return
    }
    defer db.Close()

    data, err := getMainTableData(db)
    if err != nil {
        log.Printf("获取数据失败：%v", err)
        http.Error(w, "服务器内部错误", http.StatusInternalServerError)
        return
    }

    // 渲染模板（假设存在template.html文件）
    tpl, err := template.ParseFiles("template.html")
    if err != nil {
        log.Printf("解析模板失败：%v", err)
        http.Error(w, "服务器内部错误", http.StatusInternalServerError)
        return
    }
    if err := tpl.Execute(w, data); err != nil {
        log.Printf("渲染模板失败：%v", err)
        http.Error(w, "服务器内部错误", http.StatusInternalServerError)
    }
}

你可以按照这个思路排查修改，如果有具体的错误日志或者未贴全的代码，补充后能更精准定位问题。

内容的提问来源于stack exchange，提问作者Отгонбаяр Ламжав