事务中使用NpgsqlConnection.BeginBinaryImport是否受支持

开发者阿泽

2026-8-26

关于Npgsql BinaryImport事务支持的说明

NpgsqlConnection.BeginBinaryImport 完全支持事务，你找不到关联事务的参数是因为它的设计逻辑不需要手动传入事务对象。

核心逻辑

Npgsql 中所有基于数据库连接执行的操作（包括封装了PostgreSQL COPY 命令的二进制导入能力），都会自动关联到当前连接上已激活的事务上下文，不需要为单次操作单独绑定事务。PostgreSQL原生COPY命令的事务特性在这个实现里是完全对齐的：导入过程中所有写入的数据都在事务内，事务提交才会持久化，事务回滚则所有导入数据会被全部撤销。

正确使用方式

操作顺序和普通事务操作没有区别：

打开数据库连接
在连接上调用BeginTransaction()/BeginTransactionAsync()开启事务
直接在同一个连接实例上调用BeginBinaryImport()/BeginBinaryImportAsync()启动二进制导入，此时导入操作已经自动纳入当前事务范围
按常规流程写入行数据、调用Complete()标记导入完成
调用事务对象的Commit()提交所有变更，中途出错则调用Rollback()回滚全部导入数据

代码示例

await using var conn = new NpgsqlConnection("你的数据库连接字符串");
await conn.OpenAsync();
// 开启事务
await using var tx = await conn.BeginTransactionAsync();
// 启动二进制导入，自动关联当前连接上的活动事务
await using var importer = await conn.BeginBinaryImportAsync("COPY target_table (id, content) FROM STDIN (FORMAT BINARY)");
// 批量写入数据
for (var i = 0; i < 10000; i++)
{
    await importer.StartRowAsync();
    await importer.WriteAsync(i, NpgsqlTypes.NpgsqlDbType.Integer);
    await importer.WriteAsync($"数据_{i}", NpgsqlTypes.NpgsqlDbType.Text);
}
// 标记导入数据写入完成
await importer.CompleteAsync();
// 提交事务，导入数据才会正式落盘
await tx.CommitAsync();