本文讲解如何在go中批量向mysql插入数据时避免“max_prepared_statements”错误，核心在于复用预处理语句（prepare），而非在循环内重复调用prepare，并确保能安全获取lastinsertid。
本文讲解如何在go中批量向mysql插入数据时避免“max_prepared_statements”错误，核心在于复用预处理语句（prepare），而非在循环内重复调用prepare，并确保能安全获取lastinsertid。
在Go中使用database/sql操作MySQL时，若需为大量记录（如27万行）逐条插入并获取每条记录的自增主键ID，关键误区是将db.Prepare()置于循环内部——这会导致每次迭代都创建一个新预处理语句，迅速耗尽MySQL服务端的max_prepared_statements限制（默认16382），即使调高该参数也无法根本解决资源泄漏问题。
✅ 正确做法：Prepare一次，Exec多次
预处理语句（*sql.Stmt）是线程安全且可复用的对象，应在外层初始化一次，再在循环中反复调用其Exec()方法：
// ✅ 正确：Prepare仅执行一次，在循环外
stmt, err := db.Prepare("INSERT INTO info (title, minimage, downloadfile, rating, peoplewatched, likes) VALUES (?, ?, ?, ?, ?, ?)")
if err != nil {
log.Fatal("Prepare failed:", err)
}
defer stmt.Close() // 记得关闭，释放服务端资源
// 循环中仅调用 Exec
for _, item := range data {
res, err := stmt.Exec(item.Title, item.MinImage, item.DownloadFile, item.Rating, item.PeopleWatched, item.Likes)
if err != nil {
log.Printf("Exec failed for %s: %v", item.Title, err)
continue
}
id, err := res.LastInsertId()
if err != nil {
log.Printf("Failed to get LastInsertId: %v", err)
continue
}
fmt.Printf("Inserted ID: %d\n", id)
}
⚠️ 注意事项：
- stmt.Close() 必须显式调用（或通过defer），否则预处理语句不会从MySQL服务端释放，仍会累积占用；
- LastInsertId() 仅对单行INSERT有效；若一次Exec插入多行（如INSERT ... VALUES (...),(...)），返回值行为依赖MySQL驱动实现，通常不可靠，因此推荐单行插入+复用Stmt；
- 若追求更高性能（如27万行），可考虑批量插入（INSERT INTO ... VALUES (...),(...),...）配合mysql驱动的multiStatements=true参数，但此时LastInsertId()将返回首个插入ID，无法一一对应，需权衡ID获取需求与吞吐量；
- 确保表info的主键为AUTO_INCREMENT，且驱动支持LastInsertId()（标准github.com/go-sql-driver/mysql完全支持）。
总结：解决max_prepared_statements错误的本质，不是调大MySQL配置，而是修正代码结构——Prepare once, Exec many times, Close explicitly。这既符合SQL预处理的设计初衷，也兼顾了ID获取的准确性与系统稳定性。
golang免费学习笔记（深入）：立即使用
在学习笔记中，你将探索golang的核心概念和高级技巧！
