如何在Vapor中重新连接MySQL数据库？求有效解决方案

核心问题分析 #

你当前方案失效的根源是手动存储单个数据库连接，违背了Vapor连接池的自动管理逻辑：

• 你在configure.swift中把单个连接存入公共类，当该连接断开后，后续查询始终使用这个失效的连接
• 两种重连方法看似获取了新连接，但公共类里的self.db并未更新为新连接，导致查询循环触发断开错误，控制台反复打印"Connected"却无实际效果

修复步骤 #

1. 移除公共类存储单个连接的逻辑 #

删除Database.initialize(database)这类存储单个连接的代码，直接使用Vapor提供的Database实例（从app.db获取或依赖注入），连接池会自动处理连接的创建、复用与重连：

// configure.swift 正确初始化方式
let mysqlConfig = MySQLConfiguration(
    hostname: "你的数据库地址",
    port: 3306,
    username: "用户名",
    password: "密码",
    database: "数据库名",
    tlsConfiguration: .forClient(certificateVerification: .none),
    // 配置连接池参数，启用自动重连
    connectionPoolConfiguration: .init(
        maxConnections: 10,
        idleTimeout: .minutes(5),
        connectionTimeout: .seconds(10)
    )
)
app.databases.use(.mysql(configuration: mysqlConfig), as: .mysql)

// 无需手动获取并存储连接，Vapor连接池会自动管理

2. 修改查询逻辑，依赖连接池而非固定连接 #

将查询函数改为使用连接池提供的动态连接，而非存储的单个失效连接：

class QueryService {
    private let db: Database
    
    // 通过依赖注入获取Database实例
    init(db: Database) {
        self.db = db
    }
    
    func executeQuery(_ query: String) async throws -> [MySQLRow]? {
        do {
            let rows = try await db.raw(query).all(decoding: MySQLRow.self)
            return rows.isEmpty ? nil : rows
        } catch let error as NSError {
            if error.code == 11 { // 捕获断开错误
                // 利用连接池自动重连特性，直接重试（可添加重试次数限制）
                try Task.sleep(nanoseconds: 1_000_000_000) // 等待1秒后重试
                return try await executeQuery(query)
            } else {
                throw error
            }
        }
    }
}

3. 验证Vapor MySQL驱动的自动重连配置 #

确保使用的vapor/mysql驱动版本支持连接池自动重连（通常v4及以上版本默认支持），如果仍有问题，可在MySQL配置中显式开启重连：

// 在MySQLConfiguration中添加额外参数
let mysqlConfig = MySQLConfiguration(
    // 其他配置...
    additionalConfiguration: {
        $0.enableAutomaticReconnect = true
    }
)

关键说明 #

Vapor的数据库连接池设计目标就是自动管理连接生命周期，包括断开后的重连。手动存储单个连接会绕过这一机制，导致连接失效后无法自动恢复。正确的做法是始终通过Database实例（从连接池获取）执行查询，无需手动处理连接的创建与重连。

内容的提问来源于stack exchange，提问作者AppNameExMin