Go 无法直接通过 EXEC "COPY table FROM 'path.csv'" 执行服务端文件导入；必须使用 lib/pq 提供的 pq.CopyIn 系列接口，配合事务和逐行写入，实现高效批量数据导入。
go 无法直接通过 `exec "copy table from 'path.csv'"` 执行服务端文件导入；必须使用 `lib/pq` 提供的 `pq.copyin` 系列接口，配合事务和逐行写入，实现高效批量数据导入。
在 PostgreSQL 中，COPY ... FROM file 是一条服务端命令，要求文件路径对数据库服务器可见（即位于 PostgreSQL 进程可读的本地磁盘），而非客户端机器。因此，像 COPY mytable FROM '/tmp/data.csv' CSV HEADER 这类语句在 Go 客户端中不能直接执行——lib/pq 驱动不支持解析或转发该语法，调用 Prepare() 时会返回 pq: unknown response for copy query: 'C' 错误，本质是驱动未进入 PostgreSQL 的 COPY 协议流模式。
正确的做法是使用 lib/pq 提供的 pq.CopyIn / pq.CopyInSchema 接口，它主动协商 PostgreSQL 的二进制 COPY 协议，将客户端数据以流式方式高效写入表中。该过程完全绕过 SQL 字符串拼接，安全、高效且可控。
✅ 正确实现步骤（含完整示例）
import (
"database/sql"
"fmt"
"github.com/lib/pq"
)
func BulkCopyFromCSV(db *sql.DB, schema, table string, columns []string, rows [][]interface{}) error {
// 1. 开启事务（COPY 必须在事务内执行）
tx, err := db.Begin()
if err != nil {
return fmt.Errorf("failed to begin transaction: %w", err)
}
defer func() {
if err != nil {
tx.Rollback() // 出错时回滚
}
}()
// 2. 准备 COPY 入口语句（注意：列名需显式指定，类型由 PostgreSQL 自动推断）
stmt, err := tx.Prepare(pq.CopyInSchema(schema, table, columns...))
if err != nil {
return fmt.Errorf("failed to prepare COPY statement: %w", err)
}
defer stmt.Close()
// 3. 逐行写入数据（支持从 CSV 解析器、结构体切片等来源获取）
for _, row := range rows {
if _, err := stmt.Exec(row...); err != nil {
return fmt.Errorf("failed to insert row %v: %w", row, err)
}
}
// 4. 发送结束信号（关键！否则 COPY 不完成）
if _, err := stmt.Exec(); err != nil {
return fmt.Errorf("failed to finalize COPY: %w", err)
}
// 5. 提交事务
return tx.Commit()
}? 使用示例（模拟 CSV 解析后导入）
// 示例：从内存 CSV 数据导入（实际中可用 encoding/csv 包解析文件）
csvData := [][]interface{}{
{"Alice", 28, "alice@example.com"},
{"Bob", 35, "bob@example.com"},
{"Charlie", 42, "charlie@example.com"},
}
err := BulkCopyFromCSV(
db,
"public", // schema 名
"users", // 表名
[]string{"name", "age", "email"}, // 目标列（顺序必须匹配）
csvData,
)
if err != nil {
log.Fatal("Bulk import failed:", err)
}⚠️ 关键注意事项
- 事务必需：pq.CopyIn 必须在显式事务（db.Begin()）中使用，否则会报错。
- 列名不可省略：pq.CopyInSchema(schema, table, cols...) 中的 cols 是必需参数，且顺序必须与数据行严格一致。
- 无自动类型转换：传入的 []interface{} 中每个值需为 Go 可映射到 PostgreSQL 类型的原生类型（如 int, string, time.Time, nil 表示 NULL），避免 []byte 或自定义类型未实现 driver.Valuer。
-
性能优化建议：
- 批量提交前可适当增加 rows 数量（如 1000–10000 行/批），减少网络往返；
- 对超大文件，建议分块读取 + 分批 BulkCopyFromCSV 调用；
- 确保目标表有合适索引（导入前可 DROP INDEX，导入后重建以加速）。
- 错误处理严谨性：stmt.Exec() 在中间失败时，需及时中断并回滚整个事务；示例中已通过 defer 和显式 tx.Rollback() 保障一致性。
✅ 总结
Go 中实现 PostgreSQL COPY 功能，绝不可拼接 SQL 字符串调用 COPY ... FROM 'file'，而应拥抱 lib/pq 的协议级支持——使用 pq.CopyIn* 启动 COPY 流，配合事务控制与结构化数据写入。这种方式不仅规避了路径权限、SQL 注入等风险，更在吞吐量上远超逐条 INSERT，是生产环境批量导入的事实标准方案。
