编辑“︁Gin连接MySQL”︁（章节）

= Gin连接MySQL =

'''Gin连接MySQL'''是指在使用[[Gin框架]]开发Web应用时，如何配置和建立与[[MySQL]]数据库的连接。这是构建动态Web应用的关键步骤，允许应用程序存储、检索和管理持久化数据。本指南将详细介绍从基础配置到高级集成的完整流程，适合初学者和需要深入理解此技术的开发者。

== 概述 ==
Gin是一个高性能的Go语言Web框架，而MySQL是最流行的关系型数据库之一。通过集成两者，开发者可以构建数据驱动的RESTful API或全栈应用。连接过程通常涉及：
* 数据库驱动选择（如`go-sql-driver/mysql`）
* 连接池配置
* ORM集成（可选，如GORM）
* 错误处理和性能优化

== 前置要求 ==
在开始之前，请确保：
* 已安装Go 1.13+和MySQL 5.7+
* 了解基本的SQL语法和HTTP路由概念
* 本地或远程可访问的MySQL实例

== 基础连接配置 ==
=== 安装MySQL驱动 ===
使用官方推荐的Go MySQL驱动：
<syntaxhighlight lang="bash">
go get -u github.com/go-sql-driver/mysql
</syntaxhighlight>

=== 创建连接 ===
以下是建立基础连接的代码示例：
<syntaxhighlight lang="go">
package main

import (
	"database/sql"
	"fmt"
	"log"

	_ "github.com/go-sql-driver/mysql"
	"github.com/gin-gonic/gin"
)

func main() {
	// 数据库连接配置
	dsn := "username:password@tcp(127.0.0.1:3306)/dbname?charset=utf8mb4&parseTime=True&loc=Local"
	
	// 打开连接
	db, err := sql.Open("mysql", dsn)
	if err != nil {
		log.Fatal(err)
	}
	defer db.Close()

	// 验证连接
	err = db.Ping()
	if err != nil {
		log.Fatal(err)
	}

	fmt.Println("成功连接到MySQL数据库")

	// 初始化Gin路由
	r := gin.Default()
	
	// 示例路由
	r.GET("/ping", func(c *gin.Context) {
		c.JSON(200, gin.H{
			"message": "pong",
			"db_status": "connected",
		})
	})

	r.Run(":8080")
}
</syntaxhighlight>

'''参数说明：'''
* '''dsn格式'''：`username:password@protocol(address)/dbname?param=value`
* 重要参数：
  * `charset=utf8mb4`：支持完整Unicode字符集
  * `parseTime=True`：将数据库时间类型解析为Go的time.Time
  * `loc=Local`：时区设置

== 连接池优化 ==
生产环境必须配置连接池：
<syntaxhighlight lang="go">
// 设置连接池参数
db.SetMaxOpenConns(25)       // 最大打开连接数
db.SetMaxIdleConns(5)        // 最大空闲连接数
db.SetConnMaxLifetime(5 * time.Minute) // 连接最大存活时间
</syntaxhighlight>

== 集成到Gin应用 ==
最佳实践是将数据库实例注入到路由处理器中：

=== 结构体封装 ===
<syntaxhighlight lang="go">
type App struct {
	DB     *sql.DB
	Router *gin.Engine
}

func (a *App) Initialize() {
	dsn := "user:pass@tcp(localhost:3306)/dbname"
	var err error
	a.DB, err = sql.Open("mysql", dsn)
	if err != nil {
		log.Fatal(err)
	}

	a.Router = gin.Default()
	a.initializeRoutes()
}

func (a *App) initializeRoutes() {
	a.Router.GET("/users", a.getUsers)
}

// 示例处理器
func (a *App) getUsers(c *gin.Context) {
	rows, err := a.DB.Query("SELECT id, name FROM users LIMIT 10")
	if err != nil {
		c.JSON(500, gin.H{"error": err.Error()})
		return
	}
	defer rows.Close()

	// 处理查询结果...
}
</syntaxhighlight>

== 事务处理 ==
对于需要原子性操作的情况：
<syntaxhighlight lang="go">
func transferMoney(c *gin.Context, db *sql.DB, from, to int, amount float64) error {
	tx, err := db.Begin()
	if err != nil {
		return err
	}

	// 执行转账操作
	if _, err = tx.Exec("UPDATE accounts SET balance = balance - ? WHERE id = ?", amount, from); err != nil {
		tx.Rollback()
		return err
	}

	if _, err = tx.Exec("UPDATE accounts SET balance = balance + ? WHERE id = ?", amount, to); err != nil {
		tx.Rollback()
		return err
	}

	return tx.Commit()
}
</syntaxhighlight>

== 错误处理 ==
常见错误类型及处理方式：
{| class="wikitable"
|-
! 错误类型 !! 可能原因 !! 解决方案
|-
| `ERROR 1045` || 认证失败 || 检查用户名/密码
|-
| `ERROR 2002` || 连接拒绝 || 检查MySQL服务是否运行
|-
| `ERROR 1049` || 未知数据库 || 确认数据库存在或创建数据库
|}

== 性能监控 ==
使用Prometheus监控MySQL性能指标：
<syntaxhighlight lang="go">
import "github.com/prometheus/client_golang/prometheus"

var (
	dbQueryCount = prometheus.NewCounterVec(
		prometheus.CounterOpts{
			Name: "db_queries_total",
			Help: "Number of DB queries",
		},
		[]string{"query_type"},
	)
)

func init() {
	prometheus.MustRegister(dbQueryCount)
}
</syntaxhighlight>

== 安全注意事项 ==
* 永远不要拼接SQL查询（使用预处理语句）
* 限制数据库用户权限
* 加密敏感配置信息
* 定期轮换数据库凭证

== 进阶主题 ==
=== 使用GORM集成 ===
<syntaxhighlight lang="go">
import "gorm.io/gorm"

func connectWithGORM() *gorm.DB {
	dsn := "user:pass@tcp(localhost:3306)/dbname?charset=utf8mb4&parseTime=True&loc=Local"
	db, err := gorm.Open(mysql.Open(dsn), &gorm.Config{})
	if err != nil {
		log.Fatal(err)
	}
	return db
}
</syntaxhighlight>

=== 读写分离 ===
<mermaid>
graph LR
    A[主数据库] -->|写入| B[应用服务器]
    C[从数据库1] -->|读取| B
    D[从数据库2] -->|读取| B
</mermaid>

实现方案：
<syntaxhighlight lang="go">
type DBCluster struct {
	Master *sql.DB
	Slaves []*sql.DB
}

func (d *DBCluster) GetReadDB() *sql.DB {
	// 简单的轮询负载均衡
	return d.Slaves[time.Now().Unix()%int64(len(d.Slaves))]
}
</syntaxhighlight>

== 实际案例 ==
'''电商应用商品查询API'''：
<syntaxhighlight lang="go">
func (a *App) getProduct(c *gin.Context) {
	id := c.Param("id")
	
	var product struct {
		ID          int     `json:"id"`
		Name        string  `json:"name"`
		Price       float64 `json:"price"`
		Description string  `json:"description"`
	}

	err := a.DB.QueryRow(`
		SELECT id, name, price, description 
		FROM products 
		WHERE id = ? AND status = 'active'
	`, id).Scan(
		&product.ID,
		&product.Name,
		&product.Price,
		&product.Description,
	)

	if err != nil {
		if err == sql.ErrNoRows {
			c.JSON(404, gin.H{"error": "product not found"})
		} else {
			c.JSON(500, gin.H{"error": err.Error()})
		}
		return
	}

	c.JSON(200, product)
}
</syntaxhighlight>

== 常见问题 ==
'''Q: 如何处理连接超时？'''
A: 在DSN中添加`timeout`参数，如：
<syntaxhighlight lang="text">
dsn := "user:pass@tcp(localhost:3306)/dbname?timeout=30s"
</syntaxhighlight>

'''Q: 为什么需要`defer rows.Close()`？'''
A: 防止资源泄漏，确保查询结果集被正确释放。

== 总结 ==
本文详细介绍了Gin框架连接MySQL数据库的完整流程，从基础连接到高级优化。关键点包括：
* 正确配置DSN连接字符串
* 合理设置连接池参数
* 使用预处理语句防止SQL注入
* 事务处理保证数据一致性
* 监控和错误处理的最佳实践

通过掌握这些技术，开发者可以构建高效、可靠的数据库驱动型Web应用。

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