编辑“︁Gin连接PostgreSQL”︁

= Gin连接PostgreSQL =

== 介绍 ==  
Gin是一个高性能的Go语言Web框架，而PostgreSQL是一个功能强大的开源关系型数据库。将Gin与PostgreSQL集成，可以构建高效、可扩展的后端服务。本章节将详细介绍如何在Gin中连接和操作PostgreSQL数据库，涵盖从基础配置到高级查询的完整流程。

== 前置条件 ==  
在开始之前，请确保已安装以下工具：  
* Go语言环境（1.16+）  
* PostgreSQL数据库（12+）  
* Gin框架（通过<code>go get -u github.com/gin-gonic/gin</code>安装）  
* PostgreSQL驱动（如<code>pgx</code>或<code>lib/pq</code>，本章以<code>pgx</code>为例）

== 安装依赖 ==  
使用以下命令安装<code>pgx</code>驱动：  
<syntaxhighlight lang="bash">  
go get github.com/jackc/pgx/v5  
</syntaxhighlight>

== 连接PostgreSQL ==  

=== 基本连接配置 ===  
以下是一个通过Gin连接PostgreSQL的示例代码：  
<syntaxhighlight lang="go">  
package main  

import (  
    "context"  
    "fmt"  
    "github.com/gin-gonic/gin"  
    "github.com/jackc/pgx/v5"  
)  

func main() {  
    // 初始化Gin路由  
    r := gin.Default()  

    // PostgreSQL连接配置  
    connStr := "postgres://username:password@localhost:5432/dbname"  
    conn, err := pgx.Connect(context.Background(), connStr)  
    if err != nil {  
        fmt.Printf("连接数据库失败: %v\n", err)  
        return  
    }  
    defer conn.Close(context.Background())  

    // 测试路由  
    r.GET("/ping", func(c *gin.Context) {  
        var result string  
        err := conn.QueryRow(context.Background(), "SELECT 'PostgreSQL connected'").Scan(&result)  
        if err != nil {  
            c.JSON(500, gin.H{"error": err.Error()})  
            return  
        }  
        c.JSON(200, gin.H{"message": result})  
    })  

    // 启动服务  
    r.Run(":8080")  
}  
</syntaxhighlight>  

=== 参数说明 ===  
* <code>connStr</code>：PostgreSQL连接字符串，格式为<code>postgres://用户名:密码@主机:端口/数据库名</code>。  
* <code>pgx.Connect</code>：建立数据库连接，需传入<code>context.Context</code>。  
* <code>defer conn.Close</code>：确保程序退出时关闭连接。  

== 数据库操作 ==  

=== 查询数据 ===  
以下示例展示如何查询用户表中的数据：  
<syntaxhighlight lang="go">  
r.GET("/users", func(c *gin.Context) {  
    rows, err := conn.Query(context.Background(), "SELECT id, name FROM users")  
    if err != nil {  
        c.JSON(500, gin.H{"error": err.Error()})  
        return  
    }  
    defer rows.Close()  

    var users []gin.H  
    for rows.Next() {  
        var id int  
        var name string  
        err = rows.Scan(&id, &name)  
        if err != nil {  
            c.JSON(500, gin.H{"error": err.Error()})  
            return  
        }  
        users = append(users, gin.H{"id": id, "name": name})  
    }  
    c.JSON(200, gin.H{"users": users})  
})  
</syntaxhighlight>  

=== 插入数据 ===  
<syntaxhighlight lang="go">  
r.POST("/users", func(c *gin.Context) {  
    var newUser struct {  
        Name string `json:"name" binding:"required"`  
    }  
    if err := c.ShouldBindJSON(&newUser); err != nil {  
        c.JSON(400, gin.H{"error": err.Error()})  
        return  
    }  

    _, err := conn.Exec(context.Background(), "INSERT INTO users (name) VALUES ($1)", newUser.Name)  
    if err != nil {  
        c.JSON(500, gin.H{"error": err.Error()})  
        return  
    }  
    c.JSON(201, gin.H{"message": "用户创建成功"})  
})  
</syntaxhighlight>  

== 连接池管理 ==  
为提高性能，建议使用连接池：  
<syntaxhighlight lang="go">  
import "github.com/jackc/pgx/v5/pgxpool"  

func main() {  
    pool, err := pgxpool.New(context.Background(), "postgres://username:password@localhost:5432/dbname")  
    if err != nil {  
        fmt.Printf("创建连接池失败: %v\n", err)  
        return  
    }  
    defer pool.Close()  

    // 使用pool.Query()替代conn.Query()  
}  
</syntaxhighlight>  

== 实际案例：用户管理系统 ==  
以下是一个完整的Gin + PostgreSQL实现用户管理的示例：  
1. 创建用户表：  
<syntaxhighlight lang="sql">  
CREATE TABLE users (  
    id SERIAL PRIMARY KEY,  
    name VARCHAR(100) NOT NULL,  
    email VARCHAR(100) UNIQUE  
);  
</syntaxhighlight>  

2. 实现CRUD接口（代码见上文查询和插入部分）。  

== 故障排查 ==  
* **连接失败**：检查PostgreSQL服务是否运行，用户名/密码是否正确。  
* **查询超时**：调整<code>context.WithTimeout</code>或检查网络延迟。  
* **连接泄漏**：确保使用<code>defer rows.Close()</code>和<code>defer conn.Close()</code>。  

== 总结 ==  
本章详细介绍了Gin与PostgreSQL的集成方法，包括连接配置、CRUD操作和连接池优化。通过实际案例，读者可以快速掌握如何在Gin项目中高效使用PostgreSQL。  

== 延伸阅读 ==  
* 官方文档：[https://pkg.go.dev/github.com/jackc/pgx](https://pkg.go.dev/github.com/jackc/pgx)  
* PostgreSQL高级特性（如JSONB、事务隔离级别）。

[[Category:后端框架]]
[[Category:Gin]]
[[Category:Gin与数据库集成]]