使用go-ora RefCursor遇连接错误，能否复用sql.Open创建的连接池？

完全可以复用sql.Open("oracle", dsn)创建的连接池，不需要为每个请求重新创建连接。你遇到的can't query RefCursor: driver: bad connection错误，通常是代码中资源处理不当或连接池配置缺失导致的，而非连接池复用本身的问题。

错误原因分析 #

• RefCursor绑定/关闭不当：未通过sql.Out正确声明输出参数，或连接归还池之前未确保游标关闭，导致连接状态异常。
• 重复Prepare语句：循环内重复调用db.Prepare会频繁创建销毁语句对象，浪费资源且易引发连接复用冲突。
• 连接池配置缺失：未设置合理的连接存活时间、最大连接数等参数，Oracle主动断开闲置连接后，连接池仍复用无效连接。
• 未检查游标遍历错误：refCursor.Next()循环结束后未检查refCursor.Err()，遗漏的遍历错误会导致后续请求使用异常连接。

修复方案与优化代码 #

1. 配置合理的连接池参数

在sql.Open后添加连接池配置，避免无效连接复用：

func main() {
    dsn := "oracle://username:password@hostname:port/service_name"
    db, err := sql.Open("oracle", dsn)
    if err != nil {
        log.Fatalf("Failed to connect to the database: %v", err)
    }
    defer db.Close()

    // 配置连接池参数
    db.SetMaxOpenConns(10)       // 最大打开连接数
    db.SetMaxIdleConns(5)        // 最大空闲连接数
    db.SetConnMaxLifetime(time.Hour) // 连接最长存活时间
    db.SetConnMaxIdleTime(30 * time.Minute) // 连接最大空闲时间

    for i := 0; i < 5; i++ {
        if err := callStoredProcedure(db); err != nil {
            log.Printf("Failed to call stored procedure: %v", err)
        }
    }
}

2. 正确处理RefCursor参数与资源

使用sql.Out声明输出参数，确保游标非nil时再关闭，并检查遍历错误：

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

func callStoredProcedure(db *sql.DB) error {
    var refCursor *sql.Rows
    // 替换为你的存储过程调用语句
    query := "BEGIN your_procedure_name(:1); END;"

    stmt, err := db.Prepare(query)
    if err != nil {
        return fmt.Errorf("failed to prepare statement: %w", err)
    }
    defer stmt.Close()

    // 使用sql.Out正确绑定RefCursor输出参数
    _, err = stmt.Exec(sql.Out{Dest: &refCursor})
    if err != nil {
        return fmt.Errorf("failed to execute statement: %w", err)
    }
    // 确保游标非nil时再关闭，避免panic
    if refCursor != nil {
        defer refCursor.Close()
    }

    // 遍历游标并处理数据
    for refCursor.Next() {
        // 根据实际存储过程返回字段调整Scan参数
        var id int
        var content string
        if err := refCursor.Scan(&id, &content); err != nil {
            return fmt.Errorf("failed to scan row: %w", err)
        }
        // 业务逻辑处理...
    }
    // 检查遍历过程中的错误
    if err := refCursor.Err(); err != nil {
        return fmt.Errorf("cursor iteration error: %w", err)
    }

    return nil
}

3. 复用Prepared Statement

若多次调用相同存储过程，建议在程序初始化时Prepare一次语句，避免重复创建：

var globalStmt *sql.Stmt

func init() {
    // 需确保db已提前初始化完成
    var err error
    globalStmt, err = db.Prepare("BEGIN your_procedure_name(:1); END;")
    if err != nil {
        log.Fatalf("Failed to prepare global statement: %v", err)
    }
}

func callStoredProcedure(db *sql.DB) error {
    var refCursor *sql.Rows
    _, err := globalStmt.Exec(sql.Out{Dest: &refCursor})
    // 后续游标处理逻辑同上...
}

总结 #

连接池复用是完全可行的，关键在于正确处理RefCursor的生命周期、配置合理的连接池参数，以及避免不必要的资源重复创建。按上述优化后，bad connection的问题应该能得到解决。

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