Go语言中如何将MySQL多行数据传递并渲染到HTML模板-Golang-PHP中文网

Go语言中如何将MySQL多行数据传递并渲染到HTML模板

花韻仙語

发布： 2025-09-16 14:09:01

原创

808人浏览过

Go语言中如何将MySQL多行数据传递并渲染到HTML模板

本文详细介绍了在Go语言Web应用中，如何将MySQL数据库查询返回的多行数据高效地传递给HTML模板进行渲染。核心方法是利用Go的切片（slice）数据结构在后端收集所有查询结果，然后将整个切片传递给模板。模板通过{{range .}}指令迭代切片中的每个元素，从而实现多行数据的动态展示，解决了只显示最后一条数据或数据重复渲染的问题。

理解问题：单行数据传递的局限性

在go语言中处理数据库查询结果并将其渲染到html模板时，一个常见的误区是直接在循环内部处理单条数据并尝试渲染，或者只将最后一条数据传递给模板。

考虑以下初始代码片段：

type Entry struct {
    Name, Mes string
}

func mysqlWithTempl(w http.ResponseWriter, r *http.Request) {
    // ... 数据库连接和查询代码 ...

    rows, err := con.Query("select name, message from entry")
    if err != nil {
        // 处理错误
        http.Error(w, "Query failed", http.StatusInternalServerError)
        return
    }
    defer rows.Close() // 确保行关闭

    tRes := Entry{} // 单个Entry结构体

    for rows.Next() {
        var name, message string
        rows.Scan(&name, &message)
        tRes.Name = name
        tRes.Mes = message
        // 如果在这里调用 index.Execute(w, tRes)，会导致每次循环都写入响应，
        // 且只显示当前行数据，多次重复输出响应头。
    }
    // 循环结束后，tRes只保留了最后一条记录的数据
    // index.Execute(w, tRes) // 此时只会渲染最后一条数据
}

登录后复制

这种方法的问题在于，tRes是一个单一的Entry结构体实例。在for rows.Next()循环中，每次迭代都会覆盖tRes中的Name和Mes字段。因此，当循环结束后，tRes中只包含了数据库查询结果的最后一行数据。如果此时将tRes传递给模板，模板就只能显示最后一条记录。若在循环内部调用index.Execute，则会导致响应头重复发送，且每次只渲染当前行的内容，最终在浏览器中可能看到不完整的或错误的结果。

核心解决方案：使用切片传递多行数据

要正确地将多行数据传递给Go模板，我们需要在Go后端将所有查询结果收集到一个切片（slice）中，然后将整个切片作为数据传递给模板。模板再利用其内置的range指令遍历切片中的每个元素。

1. Go 后端处理：收集数据到切片

首先，修改后端处理函数，声明一个Entry结构体类型的切片来存储所有查询结果。

立即学习“go语言免费学习笔记（深入）”；

AiPPT模板广场

AiPPT模板广场-PPT模板-word文档模板-excel表格模板

147

查看详情

package main

import (
    "database/sql"
    "fmt"
    "html/template"
    "log"
    "net/http"

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

// Entry 结构体用于映射数据库表中的一行数据
type Entry struct {
    Name string
    Mes  string // 注意：为了避免与Go关键字冲突，通常建议使用Message而不是Mes
}

var tpl *template.Template // 全局模板变量，用于解析模板

func init() {
    // 解析模板文件，这里假设模板文件名为 index.html
    tpl = template.Must(template.ParseFiles("index.html"))
}

func mysqlWithTempl(w http.ResponseWriter, r *http.Request) {
    // 假设数据库连接信息已配置
    dbName := "testdb"
    dbUserName := "root"
    dbPassword := "your_password" // 请替换为你的数据库密码

    // 打开数据库连接
    con, err := sql.Open("mysql", fmt.Sprintf("%s:%s@tcp(127.0.0.1:3306)/%s", dbUserName, dbPassword, dbName))
    if err != nil {
        log.Printf("Error opening database: %v", err)
        http.Error(w, "Database connection error", http.StatusInternalServerError)
        return
    }
    defer con.Close() // 确保数据库连接关闭

    // 测试数据库连接
    err = con.Ping()
    if err != nil {
        log.Printf("Error connecting to database: %v", err)
        http.Error(w, "Database connection error", http.StatusInternalServerError)
        return
    }

    // 执行查询
    rows, err := con.Query("SELECT name, message FROM entry")
    if err != nil {
        log.Printf("Error querying database: %v", err)
        http.Error(w, "Database query error", http.StatusInternalServerError)
        return
    }
    defer rows.Close() // 确保行关闭

    // 声明一个 Entry 结构体切片来存储所有结果
    var results []Entry

    // 遍历查询结果
    for rows.Next() {
        var e Entry // 临时变量存储当前行数据
        // 将当前行数据扫描到 Entry 结构体字段中
        if err := rows.Scan(&e.Name, &e.Mes); err != nil {
            log.Printf("Error scanning row: %v", err)
            // 可以选择跳过此行或返回错误
            continue
        }
        // 将当前 Entry 追加到 results 切片中
        results = append(results, e)
    }

    // 检查遍历过程中是否有错误
    if err := rows.Err(); err != nil {
        log.Printf("Error during rows iteration: %v", err)
        http.Error(w, "Error processing query results", http.StatusInternalServerError)
        return
    }

    // 将整个 results 切片传递给模板进行渲染
    if err := tpl.Execute(w, results); err != nil {
        log.Printf("Error executing template: %v", err)
        http.Error(w, "Template rendering error", http.StatusInternalServerError)
    }
}

func main() {
    http.HandleFunc("/", mysqlWithTempl)
    log.Println("Server starting on :8080")
    log.Fatal(http.ListenAndServe(":8080", nil))
}

登录后复制

代码说明：

var results []Entry：声明了一个空的Entry切片。
在for rows.Next()循环内部，我们创建了一个临时的Entry实例e，将当前行的数据扫描到e中。
results = append(results, e)：将填充好的e实例追加到results切片中。
循环结束后，results切片将包含所有数据库行的数据。
tpl.Execute(w, results)：将整个results切片作为数据传递给模板。

2. Go 模板渲染：使用 range 迭代切片

当模板接收到一个切片作为数据时，可以使用{{range .}}...{{end}}指令来迭代切片中的每一个元素。在range块内部，.代表当前迭代到的切片元素（即一个Entry结构体实例）。

<!DOCTYPE html>
<html>
    <head>
        <title>数据列表</title>
        <style>
            body { font-family: Arial, sans-serif; margin: 20px; }
            section { border: 1px solid #eee; padding: 15px; margin-bottom: 10px; }
            p { margin: 5px 0; }
            .item-name { font-weight: bold; color: #333; }
            .item-message { color: #666; }
        </style>
    </head>
    <body>
        <h1>数据库查询结果</h1>
        <section id="contents">
            {{if .}} <!-- 检查切片是否为空 -->
                {{range .}} <!-- 遍历传递过来的切片 -->
                    <p>
                        <span class="item-name">{{.Name}}</span>:
                        <span class="item-message">{{.Mes}}</span>
                    </p>
                {{end}}
            {{else}}
                <p>没有找到任何数据。</p>
            {{end}}
        </section>
    </body>
</html>

登录后复制

模板说明：

{{range .}}：这个指令告诉模板引擎遍历传入的数据（在这里是results切片）中的每一个元素。
在{{range .}}和{{end}}之间，.上下文会切换到当前迭代到的切片元素。因此，{{.Name}}和{{.Mes}}会分别访问当前Entry实例的Name和Mes字段。
{{if .}}...{{else}}...{{end}}：这是一个可选的条件判断，用于检查传入的切片是否为空。如果为空，则显示“没有找到任何数据”；否则，执行range循环。

注意事项

错误处理： 在实际应用中，数据库操作（如sql.Open, con.Ping, con.Query, rows.Scan）都可能返回错误。务必进行适当的错误检查和处理，例如使用log.Printf记录错误并向用户返回友好的错误信息（http.Error）。
数据库连接管理： 使用defer con.Close()和defer rows.Close()是最佳实践，确保在函数结束时关闭数据库连接和结果集，防止资源泄露。
模板解析： 建议在程序启动时（例如在init()函数中）一次性解析所有模板文件，而不是在每个请求中重复解析，以提高性能。template.Must()函数用于在模板解析失败时直接panic，这在程序初始化阶段是可接受的。
SQL注入： 在本示例中，查询是硬编码的，但如果查询字符串包含用户输入，务必使用参数化查询（con.Query("SELECT ... WHERE name = ?", userName)）来防止SQL注入攻击。
结构体字段命名： Go语言中，结构体字段首字母大写表示可导出（public），才能在模板中访问。Entry中的Name和Mes（或Message）都是大写的，符合要求。
驱动选择： 本示例使用了github.com/go-sql-driver/mysql驱动。根据实际使用的数据库类型，需要导入相应的驱动。