C#应用SQL Server转PostgreSQL：Npgsql替代SqlDataRecord方案咨询

我来帮你搞定这个迁移问题！Npgsql确实没有和SqlDataRecord、SqlMetaData直接对应的类，因为PostgreSQL处理批量参数的逻辑和SQL Server的TVP不一样，但有两种更简洁的替代方案，完全能满足你的需求：

方案1：直接传递整数数组（最推荐、最简洁） #

PostgreSQL原生支持数组类型，这是处理这类批量ID列表的首选方式，不需要构建复杂的记录结构：

步骤1：修改PostgreSQL存储过程/函数 #

把原来接受自定义表类型IntKeyTable的参数，改成接受int[]类型：

CREATE OR REPLACE FUNCTION YourTargetProcedure(CIDList int[])
RETURNS void AS $$
BEGIN
    -- 你可以用unnest()函数把数组转成行集，和原来TVP的用法一致
    -- 示例：SELECT * FROM unnest(CIDList) AS ids(n);
END;
$$ LANGUAGE plpgsql;

步骤2：修改C#代码 #

直接把你的List<int>作为参数传递，Npgsql会自动完成类型映射：

List<int> cidList = <filled list>;
// 假设cmd是已经初始化好的NpgsqlCommand
cmd.CommandType = CommandType.StoredProcedure;
// 添加数组参数，指定类型为整数数组
cmd.Parameters.Add("@CIDList", NpgsqlDbType.Array | NpgsqlDbType.Integer).Value = cidList;

方案2：模拟SQL Server TVP（使用复合类型数组） #

如果你的业务逻辑必须依赖类似表结构的参数（比如后续可能扩展字段），可以在PostgreSQL中创建对应复合类型，再传递该类型的数组：

步骤1：创建PostgreSQL复合类型 #

对应原来的IntKeyTable表类型，创建一个复合类型：

CREATE TYPE IntKeyTable AS (n int);

步骤2：修改存储过程/函数 #

让它接受IntKeyTable[]类型的参数：

CREATE OR REPLACE FUNCTION YourTargetProcedure(CIDList IntKeyTable[])
RETURNS void AS $$
BEGIN
    -- 同样用unnest()处理，获取n字段
    -- 示例：SELECT (unnest(CIDList)).n;
END;
$$ LANGUAGE plpgsql;

步骤3：修改C#代码 #

你可以定义一个类映射复合类型，或者直接用匿名类型：

// 定义对应复合类型的类（可选，也可以用匿名类型）
[NpgsqlComposite("IntKeyTable")]
public class IntKeyRecord
{
    public int n { get; set; }
}

List<int> cidList = <filled list>;
// 转换为复合类型列表
var contList = cidList.Select(i => new IntKeyRecord { n = i }).ToList();

// 初始化NpgsqlCommand后
cmd.CommandType = CommandType.StoredProcedure;
// 添加复合类型数组参数
cmd.Parameters.Add("@CIDList", NpgsqlDbType.Array | NpgsqlDbType.Composite).Value = contList;

// 如果用匿名类型，需要提前注册复合类型映射（全局或连接级）
// NpgsqlConnection.GlobalTypeMapper.MapComposite<dynamic>("IntKeyTable");
// var contList = cidList.Select(i => new { n = i }).ToList();

关键提示 #

• 优先选方案1：PostgreSQL的数组支持非常成熟，代码更简洁，性能也和TVP相当，甚至更优。
• 如果你用方案2，记得确保Npgsql能识别复合类型——要么用NpgsqlCompositeAttribute标记类，要么提前注册类型映射。
• 完全不需要再用SqlDataRecord和SqlMetaData，Npgsql会自动处理.NET类型到PostgreSQL类型的转换。

内容的提问来源于stack exchange，提问作者User12111111