如何在 Go 中安全获取 MySQL 的 LAST_INSERT

如何在 Go 中安全获取 MySQL 的 LAST_INSERT_ID？

在 go 中使用 database/sql 操作 mysql 时，调用 stmt.close() 不会影响连接级的 last_insert_id 线程安全性；但因连接池机制，跨语句无事务保障将导致 id 获取不可靠。正确做法是使用事务（tx）并优先采用 result.lastinsertid() 直接获取插入 id。

在 go 中使用 database/sql 操作 mysql 时，调用 stmt.close() 不会影响连接级的 last_insert_id 线程安全性；但因连接池机制，跨语句无事务保障将导致 id 获取不可靠。正确做法是使用事务（tx）并优先采用 result.lastinsertid() 直接获取插入 id。

MySQL 的 LAST_INSERT_ID() 是会话（connection）级别的函数，其返回值严格绑定于当前数据库连接，因此天然具备“单连接内线程安全”特性——多个 goroutine 只要不共享同一连接，就不会相互干扰。然而，Go 的 *sql.DB 是一个连接池抽象，每次 db.Prepare() 或 db.Query() 都可能从池中获取任意空闲连接，而非复用前一次操作所用的连接。这意味着你代码中看似顺序执行的四条语句：

stmt, _ := db.Prepare("INSERT INTO msg (message) VALUES(?)")
stmt.Exec(msg)
stmt.Close() // ← 此处仅关闭 statement，不关闭连接

stmt, _ = db.Prepare("SELECT LAST_INSERT_ID()") // ← 极可能命中另一条连接！
stmt.QueryRow().Scan(&msgid)

很可能在第二步 SELECT LAST_INSERT_ID() 时被分配到完全不同的连接，从而读取到其他并发操作产生的 ID，造成逻辑错误（如用户关联了错误的日志 ID）。

✅ 正确解法：使用显式事务（*sql.Tx）
事务能确保所有操作在同一个底层数据库连接上执行，既保证了 LAST_INSERT_ID() 的上下文连续性，又提供了原子性保障：

tx, err := db.Begin()
if err != nil {
    log.Fatal(err)
}
defer func() {
    if err != nil {
        tx.Rollback()
    }
}()

// 插入日志并直接获取 ID（推荐方式）
stmt, err := tx.Prepare("INSERT INTO msg (message) VALUES(?)")
if err != nil {
    log.Fatal(err)
}
res, err := stmt.Exec(msg)
stmt.Close()
if err != nil {
    log.Fatal(err)
}

msgid, err := res.LastInsertId() // ✅ 安全、高效、无需额外查询
if err != nil {
    log.Fatal(err)
}

// 插入用户并关联 msg_id
stmt, err = tx.Prepare("INSERT INTO user (msg_id) VALUES(?)")
if err != nil {
    log.Fatal(err)
}
_, err = stmt.Exec(msgid)
stmt.Close()
if err != nil {
    log.Fatal(err)
}

// 提交事务
err = tx.Commit()
if err != nil {
    log.Fatal(err)
}

⚠️ 注意事项：

Mysql Skill 1.0.0 (3)

MySQL 数据库管理技能，能够通过自然语言查询和管理数据库，支持 SELECT/INSERT/UPDATE/DELETE、表管理、备份恢复等操作。当用户提及 MySQL、数据库查询、建表或数据备份时使用此技能。

下载

永远不要忽略错误：示例中省略了部分 err 检查，生产环境必须逐层校验；
stmt.Close() 仅释放 statement 资源，对连接无影响；真正关闭连接池应调用 db.Close()（通常仅在程序退出时调用）；
若业务允许，可进一步简化：tx.Exec() 后直接调用 Result.LastInsertId()，无需 Prepare（尤其适用于单次执行场景）；
避免在事务外依赖 SELECT LAST_INSERT_ID() —— 即使手动 db.Conn() 获取连接，也需自行管理生命周期，复杂度远高于使用 tx。