真正高效的方式只有两种:原生 copy(最快)或参数化 insert ... values (:a1, :b1), (:a2, :b2), ...(最通用);连接字符串须显式设 timeout=30 和 sslmode(云环境 require,本地 disable);npgsql 参数必须用 :name 占位符且大小写严格匹配;推荐显式指定 npgsqldbtype 避免类型推断错误;错误处理应依赖 npgsqlexception.sqlstate 定位根因。

批量写入 PostgreSQL 时用拼接 SQL 字符串或循环 ExecuteNonQuery(),性能会断崖式下跌——不是慢一点,是慢一个数量级。真正高效的方式只有两种:原生 COPY(最快)或参数化 INSERT ... VALUES (:a1, :b1), (:a2, :b2), ...(最通用),其他都是妥协方案。
连接字符串漏掉 Timeout 和 sslmode 会导致批量失败静默卡死
Npgsql 默认连接超时是 30 秒,但批量操作前若连接未就绪,Open() 可能卡满这 30 秒才抛异常;云环境(如 Azure、AWS RDS)强制要求加密,漏写 sslmode=require 会直接拒绝连接,错误提示却像“connection refused”这种误导信息。
- 本地开发可设
sslmode=disable,但必须显式写出,不能省略 - 务必加
Timeout=30(单位秒),避免批量启动时因网络抖动无限等待 - 完整示例:
"Host=localhost;Port=5432;Database=mydb;Username=postgres;Password=123;Timeout=30;sslmode=disable"
NpgsqlCommand 批量插入必须用 :name 占位符,不能用 @name
PostgreSQL 原生不认 @ 前缀,Npgsql 虽兼容部分 SQL Server 风格语法,但命名参数只识别冒号前缀。写成 @id 不报错,但参数值根本不会绑定,所有字段写入 NULL,且无任何警告。
- 正确写法:
"INSERT INTO logs (msg, level, ts) VALUES (:msg, :level, :ts)" - 参数添加必须严格匹配大小写:
cmd.Parameters.AddWithValue(":level", "ERROR"),:Level就失效 - 避免
AddWithValue类型推断陷阱:传null时可能被推为int,导致类型不匹配;推荐显式指定类型:cmd.Parameters.Add(":level", NpgsqlDbType.Text).Value = "ERROR"
真正高效的批量写入:优先用 COPY,其次用 UNNEST 或多值 VALUES
COPY 是 PostgreSQL 底层流式导入机制,比任何 SQL 插入快 5–10 倍;UNNEST 和多值 VALUES 属于单语句多行,比循环执行快 3–5 倍。硬拼字符串或 ORM 的 SaveChanges() 默认行为,在千条以上数据时就会暴露瓶颈。
-
COPY示例(需开启流式):using var writer = conn.BeginTextImport("COPY logs (msg, level, ts) FROM STDIN WITH (FORMAT CSV)");<br>writer.WriteLine($"\"{msg}\",\"{level}\",\"{DateTime.UtcNow}\"");<br>// ... 多次 WriteLine<br>writer.Close(); - 多值
VALUES示例(最多 1000 行/批):"INSERT INTO logs (msg, level, ts) VALUES (:msg1,:l1,:t1), (:msg2,:l2,:t2), ...",然后为每个:msg1、:l1等单独 Add 参数 -
UNNEST更适合数组参数:"INSERT INTO logs (msg, level) SELECT * FROM UNNEST(:msgs, :levels)",再传两个string[]参数
别在 catch 里只打印 Exception.Message——NpgsqlException.SqlState 才是关键线索,比如 23505 是唯一约束冲突,22P02 是类型转换失败,这些码比英文描述更准。批量场景下,单条出错容易掩盖整批问题,得靠 SqlState 快速定位根因。











