Prepare语句未释放内存致MySQL插入守护进程崩溃求助

从你的描述和代码片段来看，问题的根源主要有两个：错误处理缺失和对Prepared Statement与MySQL驱动行为的误解，下面一步步拆解并给出修复方案：

核心崩溃原因：Nil指针解引用 #

你在代码中直接忽略了insert.Exec()和db.Prepare()的错误返回值：

insert, _ := db.Prepare(...) // 忽略Prepare错误
res, _ := insert.Exec(id, tg) // 忽略Exec错误
insertid, _ := res.LastInsertId() // res为nil时触发panic

当Exec()因为数据库连接问题、SQL错误或其他原因失败时，返回的res是nil。此时调用res.LastInsertId()就会触发invalid memory address or nil pointer dereference的panic——这就是你看到的崩溃原因。

内存持续增长的原因 #

同样因为错误处理缺失，每次Exec()失败后，相关的错误对象、未正确释放的数据库资源会不断积累；再加上你的循环是无限制执行的，这些未清理的资源会持续占用内存，最终导致内存耗尽。

你打印的insert内存地址增长，其实是错误场景下不断生成的错误相关对象，而非Prepare语句本身的问题——正常使用下，单次Prepare的语句是复用的，不会持续占用新内存。

修复后的代码示例 #

下面是修正后的代码，重点补充了错误处理、资源清理和合理的逻辑判断：

package main

import (
    "log"
    "time"
    "database/sql"
    _ "github.com/go-sql-driver/mysql"
)

func main() {
    // 初始化数据库连接（示例）
    db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/dbname")
    if err != nil {
        log.Fatalf("Failed to open database: %v", err)
    }
    defer db.Close()

    // 1. 检查Prepare语句的错误，避免后续使用nil的statement
    insertStmt, err := db.Prepare("INSERT INTO info SET id=?, tg=?, adddate=NOW() ON DUPLICATE KEY UPDATE tgs=1")
    if err != nil {
        log.Fatalf("Failed to prepare statement: %v", err)
    }
    // 确保程序退出时关闭Prepared Statement，释放资源
    defer insertStmt.Close()

    for {
        // 假设id和tg是你每次循环生成的变量
        id := 123
        tg := "some_tag"

        // 2. 必须检查Exec的错误
        res, err := insertStmt.Exec(id, tg)
        if err != nil {
            log.Printf("Execute failed: %v", err)
            // 出错时加短暂延迟，避免疯狂报错占用资源
            time.Sleep(100 * time.Millisecond)
            continue
        }

        // 3. 结合RowsAffected判断是插入还是更新，再决定是否调用LastInsertId
        rowsAffected, err := res.RowsAffected()
        if err != nil {
            log.Printf("Get rows affected failed: %v", err)
            continue
        }

        var insertId int64
        if rowsAffected == 1 {
            // 只有插入成功时，LastInsertId才有意义
            insertId, err = res.LastInsertId()
            if err != nil {
                log.Printf("Get last insert id failed: %v", err)
            } else {
                log.Printf("Inserted record with ID: %d", insertId)
            }
        } else if rowsAffected == 2 {
            // ON DUPLICATE KEY UPDATE时，MySQL驱动会返回2（匹配行+更新行）
            log.Println("Updated existing record")
        }

        // 根据业务需求添加适当延迟，避免压垮数据库
        // time.Sleep(10 * time.Millisecond)
    }
}

额外注意事项 #

• 数据库连接池配置：确保你的sql.DB连接池参数合理（比如SetMaxOpenConns、SetMaxIdleConns），避免连接泄漏或资源耗尽。
• ON DUPLICATE KEY UPDATE的行为：当触发更新时，MySQL驱动的LastInsertId()通常返回0或者无意义的值，所以必须结合RowsAffected()判断操作类型，避免无效调用。
• 错误重试逻辑：如果是临时的数据库连接错误，可以添加有限次数的重试逻辑，而不是直接跳过。

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