如何使用Npgsql高效批量获取指定Guid对应的多行数据？

绝对不要逐个循环查询——这种做法会带来严重的性能问题：每次循环都要建立数据库连接、发送请求、处理响应，频繁的网络往返会拖慢程序，还会给数据库造成不必要的连接压力。

推荐用批量查询的方式一次性获取所有对应数据，下面给你两种靠谱的实现方案：

方案一：使用参数化的ANY子句（适合中小规模Guid列表） #

直接通过ANY(@Guids)匹配所有Guid，同时必须用参数化查询避免SQL注入风险，Npgsql对集合参数有原生支持：

var guids = new List<string>()
{
    "1HFAoQchL1NB9Tc5wJLYHm",
    "1OLd2nLP92c87kmkHaMAtO",
    "2FwmMnAX98sg537nfo$S39",
    "38pd0XqUvEvA8nrnF$3vvZ",
    "0iqYqWKBvC_x62wk0jcKW3",
    "0njEfI2BzDEeQpiOo5S18q",
    "0chMA4Bgf9nxnq2i1gG9Fb",
    "3TrnV9L79FfBz0ni6_bJ9N"
};

var streams = new List<MemoryStream>();

using (var conn = new NpgsqlConnection(connectionString))
{
    conn.Open();
    string sql = "SELECT geometricaldata FROM entities WHERE guid = ANY(@Guids)";
    using (var command = new NpgsqlCommand(sql, conn))
    {
        // 将Guid列表作为参数传入，Npgsql会自动处理集合格式
        command.Parameters.AddWithValue("@Guids", guids);
        
        using (var reader = command.ExecuteReader())
        {
            while (reader.Read())
            {
                streams.Add(new MemoryStream((byte[])reader[0]));
            }
        }
    }
}

方案二：使用临时表关联查询（适合超大规模Guid列表） #

如果Guid数量上千甚至上万条，ANY子句可能触发数据库参数数量限制，这时可以用临时表批量插入Guid后再关联查询：

var guids = new List<string>()
{
    // 你的Guid列表
};

var streams = new List<MemoryStream>();

using (var conn = new NpgsqlConnection(connectionString))
{
    conn.Open();
    
    // 创建临时表存储Guid
    using (var createTempCmd = new NpgsqlCommand("CREATE TEMP TABLE temp_guids (guid TEXT PRIMARY KEY)", conn))
    {
        createTempCmd.ExecuteNonQuery();
    }
    
    // 批量导入Guid到临时表（效率远高于逐条插入）
    using (var writer = conn.BeginBinaryImport("COPY temp_guids (guid) FROM STDIN"))
    {
        foreach (var guid in guids)
        {
            writer.StartRow();
            writer.Write(guid);
        }
        writer.Complete();
    }
    
    // 关联查询获取目标数据
    string sql = @"
        SELECT e.geometricaldata 
        FROM entities e
        JOIN temp_guids t ON e.guid = t.guid";
    
    using (var command = new NpgsqlCommand(sql, conn))
    {
        using (var reader = command.ExecuteReader())
        {
            while (reader.Read())
            {
                streams.Add(new MemoryStream((byte[])reader[0]));
            }
        }
    }
}

额外注意事项 #

• 绝对禁止字符串拼接SQL，必须用参数化查询，否则会有SQL注入风险，还可能因特殊字符导致语法错误。
• 复用数据库连接，不要在循环内反复创建连接——即使有连接池，频繁开关连接仍会产生额外开销。
• 确保entities表的guid字段有索引，这会大幅提升查询速度。

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