Go语言中从MySQL获取多行数据并渲染到HTML模板-Golang-PHP中文网

Go语言中从MySQL获取多行数据并渲染到HTML模板

本文详细介绍了如何在Go语言Web应用中，从MySQL数据库查询多行数据并将其有效地传递给HTML模板进行渲染。核心方法是利用Go的切片（slice）来聚合所有查询结果，并通过Go模板引擎的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, err.Error(), http.StatusInternalServerError)
        return
    }
    defer rows.Close() // 确保rows被关闭

    tRes := Entry{} // 定义一个Entry结构体实例

    for rows.Next() {
        var name, message string
        rows.Scan(&name, &message)
        tRes.Name = name    // 每次循环都会覆盖前一次的值
        tRes.Mes = message // 每次循环都会覆盖前一次的值
    }
    // 循环结束后，tRes中只保留了最后一条记录的数据
    index.Execute(w, tRes) // 仅用最后一条记录渲染模板
}

登录后复制

上述代码的问题在于：

tRes 是一个单一的Entry结构体实例。在for rows.Next()循环中，每次迭代都会将当前行的name和message赋值给tRes.Name和tRes.Mes，这导致tRes的值在每次循环中都被覆盖。
循环结束后，tRes中只保留了数据库查询结果的最后一条记录。
index.Execute(w, tRes) 在循环外部被调用，因此它只能接收到并渲染这最后一条记录的数据。

如果尝试在循环内部调用index.Execute(w, tRes)，则会导致每次迭代都向http.ResponseWriter写入内容，虽然每次都能渲染一条记录，但这些内容是独立且重复地追加到响应中的，并非作为一个整体结构化地渲染。

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

要正确地将多行数据传递给模板并进行渲染，我们需要将所有查询结果聚合到一个Go切片（slice）中，然后将这个切片作为数据源传递给模板。模板引擎将利用range动作遍历切片中的每个元素。

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

1. 数据准备：构建数据切片

首先，修改Go处理函数，使其将每一行查询结果存储到一个Entry结构体实例中，然后将这个实例追加到一个Entry类型的切片中。

AiPPT模板广场

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

147

查看详情

package main

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

    _ "github.com/go-sql-driver/mysql" // 导入MySQL驱动，根据实际使用的驱动调整
)

// Entry 结构体用于映射数据库中的行数据
type Entry struct {
    Name string
    Mes  string // 注意：为了避免与Go内置关键字冲突，将Mes改为Message或保持Mes但注意其含义
}

var index = template.Must(template.ParseFiles("index.html"))

func mysqlWithTempl(w http.ResponseWriter, r *http.Request) {
    // 假设数据库连接参数已定义
    dbName := "testdb"
    dbUserName := "root"
    dbPassword := "password"
    dbHost := "127.0.0.1"
    dbPort := "3306"

    // 打开数据库连接
    // 示例使用"mysql"驱动，连接字符串格式为 user:password@tcp(host:port)/dbname
    con, err := sql.Open("mysql", dbUserName+":"+dbPassword+"@tcp("+dbHost+":"+dbPort+")/"+dbName)
    if err != nil {
        log.Printf("Error opening database: %v", err)
        http.Error(w, "Failed to connect to database", http.StatusInternalServerError)
        return
    }
    defer con.Close() // 确保数据库连接被关闭

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

    // 创建一个Entry切片来存储所有查询结果
    var results []Entry

    // 遍历结果集
    for rows.Next() {
        var name, message string
        // 将当前行的数据扫描到变量中
        if err := rows.Scan(&name, &message); err != nil {
            log.Printf("Error scanning row: %v", err)
            // 可以选择跳过此行或返回错误
            continue
        }
        // 创建一个新的Entry实例并填充数据
        entry := Entry{Name: name, Mes: message}
        // 将Entry实例添加到切片中
        results = append(results, entry)
    }

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

    // 将包含所有结果的切片传递给模板
    if err := index.Execute(w, results); err != nil {
        log.Printf("Error executing template: %v", err)
        http.Error(w, "Failed to render page", http.StatusInternalServerError)
        return
    }
}

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

登录后复制

2. 模板渲染：遍历切片数据

当模板接收到一个切片作为数据源时，可以使用Go模板引擎的{{range .}}...{{end}}动作来遍历切片中的每一个元素。在range块内部，{{.}}代表当前迭代的元素（即一个Entry结构体），因此可以通过{{.Name}}和{{.Mes}}访问其字段。

创建或修改index.html文件如下：

<!DOCTYPE html>
<html>
    <head>
        <title>Test</title>
        <style>
            body { font-family: sans-serif; }
            section#contents p { border-bottom: 1px solid #eee; padding-bottom: 5px; margin-bottom: 10px; }
        </style>
    </head>
    <body>
        <h1>数据库查询结果</h1>
        <section id="contents">
            {{/* 使用range循环遍历传入的切片 */}}
            {{range .}}
                <p> 消息: {{.Mes}} | 名称: {{.Name}} </p>
            {{else}}
                <p>没有找到任何数据。</p>
            {{end}}
        </section>
    </body>
</html>

登录后复制

在上述模板中：

{{range .}}：表示开始遍历传入的上下文数据（此处为results切片）。
在range块内部，{{.}}代表当前迭代到的Entry结构体实例。
{{.Mes}}和{{.Name}}：分别访问当前Entry实例的Mes和Name字段。
{{else}}块：可选，当切片为空时显示的内容。
{{end}}：结束range块。

通过这种方式，模板将为切片中的每个Entry实例生成一个<p>标签，从而正确地显示所有查询结果。

注意事项与最佳实践

错误处理： 在数据库操作（如sql.Open, con.Query, rows.Scan）和模板渲染（index.Execute）的每一步都必须进行严格的错误检查和处理。本文示例中已加入基本的错误日志记录和HTTP错误响应。
资源关闭： 使用defer con.Close()确保数据库连接在使用完毕后被关闭。同样，defer rows.Close()确保查询结果集被及时释放，这对于避免资源泄露至关重要。
SQL注入防护： 本例中的查询是硬编码的，如果查询条件来源于用户输入，务必使用参数化查询（con.Query("SELECT ... WHERE column = ?", user_input)）来防止SQL注入攻击。
结构体字段与数据库列映射： 确保Go结构体中的字段名（或通过json:"..."、db:"..."等标签指定的名称）与数据库表中的列名保持一致，或者在SELECT语句中为列指定别名以匹配结构体字段。
模板加载： template.Must(template.ParseFiles(...))用于在应用启动时加载并解析模板。如果模板文件不存在或有语法错误，程序会直接panic，这有助于在开发早期发现问题。对于生产环境，可以考虑更健壮的模板加载策略，例如热重载或预编译。
html/template vs text/template： html/template包会自动对输出内容进行HTML转义，以防止跨站脚本攻击（XSS）。如果不需要HTML转义（例如生成纯文本），可以使用text/template。在Web应用中，通常推荐使用html/template。
数据库驱动： 示例中使用了github.com/go-sql-driver/mysql驱动。根据实际使用的数据库类型（如PostgreSQL、SQLite等），需要导入相应的驱动包。

总结

通过将数据库查询结果聚合到Go切片中，并结合Go模板引擎的range动作，我们可以高效且安全地将多行动态数据渲染到HTML页面。这种模式是Go Web开发中处理列表数据展示的标准方法，理解并掌握它对于构建功能完善的Web应用至关重要。始终牢记错误处理、资源管理和安全防护，以确保应用的健壮性和可靠性。

以上就是Go语言中从MySQL获取多行数据并渲染到HTML模板的详细内容，更多请关注php中文网其它相关文章！