如何在 Go 中安全执行多语句 SQL 脚本(含文件加载与事务处理)

11次阅读

如何在 Go 中安全执行多语句 SQL 脚本(含文件加载与事务处理)

go 的 `database/sql` 标准库不支持单次 `exec()` 执行含多个分号的 sql 脚本,需手动拆分语句并在事务中逐条执行;本文提供健壮的字符串/文件加载方案、防空语句处理、错误回滚机制及生产级替代建议。

go 应用初始化阶段(如安装脚本),常需执行包含 DDL(建表)和 DML(初始化数据)的 SQL 脚本。但直接将多语句拼接为单个字符串并调用 db.Exec() 会触发错误:”pq: cannot insert multiple commands into a prepared statement”。这不是 postgresql 驱动(如 lib/pq 或 pgx)的限制,而是 Go 标准库 database/sql 的明确设计约束——Exec() 和 Query() 仅接受单条 SQL 语句,不支持分号分隔的批处理。

✅ 推荐实现:安全拆分 + 事务封装

以下是一个生产就绪的函数,支持从字符串或文件读取 SQL 脚本,并在事务中顺序执行每条非空语句:

import (     "database/sql"     "fmt"     "io/ioutil"     "Strings" )  // ExecuteSQLScript 在事务中执行 SQL 脚本(支持多语句) func ExecuteSQLScript(db *sql.DB, script string) error {     tx, err := db.Begin()     if err != nil {         return fmt.Errorf("failed to begin transaction: %w", err)     }     defer func() {         if r := recover(); r != nil {             _ = tx.Rollback()         }     }()      // 按分号分割(兼容 ;、;n、;rn)     statements := strings.Split(script, ";")     for i, stmt := range statements {         cleanStmt := strings.TrimSpace(stmt)         if cleanStmt == "" || strings.HasPrefix(cleanStmt, "--") || strings.HasPrefix(cleanStmt, "/*") {             continue // 跳过空行和注释         }          _, err := tx.Exec(cleanStmt)         if err != nil {             _ = tx.Rollback()             return fmt.Errorf("failed to execute statement #%d (%q): %w", i+1, cleanStmt[:min(50, len(cleanStmt))], err)         }     }      return tx.Commit() }  // 从文件加载并执行 func ExecuteSQLFile(db *sql.DB, filename string) error {     content, err := ioutil.ReadFile(filename)     if err != nil {         return fmt.Errorf("failed to read SQL file %s: %w", filename, err)     }     return ExecuteSQLScript(db, string(content)) }  func min(a, b int) int {     if a < b {         return a     }     return b }

⚠️ 关键注意事项

  • 分号不是万能分隔符:SQL 字符串字面量(如 'foo;bar')内的分号不应被拆分。上述简单分割适用于无嵌套分号的初始化脚本(推荐用于 DDL/DML 初始化)。若需完整 SQL 解析,应使用专业解析器(如 github.com/xwb1989/sqlparser)。
  • 注释处理:代码已跳过 -- 行注释和 /* */ 块注释开头的语句,避免执行无效内容。
  • 事务原子性:任一语句失败即回滚全部操作,确保数据库状态一致。
  • 资源安全:使用 defer + recover() 防止 panic 导致事务未关闭。

? 生产环境更优方案:使用迁移工具

对于长期维护的应用,强烈建议采用成熟的 SQL 迁移工具替代手写脚本执行逻辑,它们天然解决版本管理、幂等性、依赖顺序、回滚支持等问题:

工具 特点 适用场景
goose 支持 Go 代码迁移 + SQL 文件,带版本号、up/down、CLI 工具 中大型项目,需复杂逻辑或动态数据初始化
rambler 轻量纯 SQL 迁移,基于文件名排序执行,零依赖 简洁需求,偏好纯 SQL 管理
golang-migrate 最流行,支持 10+ 数据库,CLI + Go API,云存储后端 多数据库、CI/CD 集成、企业级部署

示例(goose):

goose postgres "user=xxx dbname=xxx sslmode=disable" up

对应迁移文件:20240101120000_create_users_table.sql

总结

  • ✅ 短期方案:用 strings.Split() 拆分语句 + sql.Tx 事务封装,注意过滤空行与注释;
  • ✅ 加载来源:可无缝切换 string 字面量、ioutil.ReadFile() 或 embed.FS(Go 1.16+);
  • ⚠️ 避免陷阱:勿在生产环境硬编码长 SQL 字符串;勿忽略事务错误处理;
  • ? 长期演进:立即引入 goose 或 golang-migrate,将初始化脚本纳入版本化迁移流程——这是 Go 生态中事实标准的最佳实践。

text=ZqhQzanResources