PostgreSQL函数返回多结果集：reader.NextResult()无法正常工作求助

这个问题我之前碰到过，本质是PostgreSQL的refcursor机制和Npgsql 3.2.5版本的处理逻辑不匹配导致的——你当前的函数返回的是无名游标引用，而Npgsql旧版本无法自动识别并通过NextResult()直接获取这些游标对应的结果集，只会返回游标名称（也就是你看到的<unnamed portal 1>这类内容）。

第一步：修改函数，使用命名游标 #

首先需要给函数里的游标指定明确的名称，这样客户端可以精准地获取每个游标对应的结果集。修改后的函数如下：

CREATE OR REPLACE FUNCTION public.sp_get_multiviewlist ( ) 
RETURNS SETOF refcursor 
AS $$
DECLARE 
  ref1 refcursor := 'customer_cursor'; -- 给游标命名
  ref2 refcursor := 'order_cursor';
BEGIN 
  OPEN ref1 FOR SELECT * FROM public."Customer"; 
  RETURN NEXT ref1; 
  OPEN ref2 FOR SELECT * FROM public."Order"; 
  RETURN NEXT ref2; 
END; 
$$ LANGUAGE plpgsql;

第二步：客户端通过事务+显式FETCH获取结果集 #

PostgreSQL的游标必须在事务上下文中使用，所以你需要在客户端开启事务，先调用函数获取游标名称，再对每个游标执行FETCH ALL命令来获取对应的结果集。以下是C#的示例代码：

using (var conn = new NpgsqlConnection("你的数据库连接字符串"))
{
    conn.Open();
    // 必须开启事务，PostgreSQL游标只能在事务内生效
    using (var transaction = conn.BeginTransaction())
    {
        // 调用函数获取所有游标名称
        using (var cmd = new NpgsqlCommand("SELECT * FROM sp_get_multiviewlist()", conn, transaction))
        {
            using (var cursorReader = cmd.ExecuteReader())
            {
                // 读取第一个游标名称，获取Customer数据
                cursorReader.Read();
                var customerCursor = cursorReader.GetString(0);
                using (var customerCmd = new NpgsqlCommand($"FETCH ALL FROM {customerCursor}", conn, transaction))
                {
                    using (var customerReader = customerCmd.ExecuteReader())
                    {
                        while (customerReader.Read())
                        {
                            // 处理Customer表的每一行数据
                            // 例如：var id = customerReader.GetInt32(0);
                        }
                    }
                }

                // 读取第二个游标名称，获取Order数据
                cursorReader.Read();
                var orderCursor = cursorReader.GetString(0);
                using (var orderCmd = new NpgsqlCommand($"FETCH ALL FROM {orderCursor}", conn, transaction))
                {
                    using (var orderReader = orderCmd.ExecuteReader())
                    {
                        while (orderReader.Read())
                        {
                            // 处理Order表的每一行数据
                        }
                    }
                }
            }
        }
        transaction.Commit();
    }
}

为什么原来的方法不生效？ #

你之前用的是无名游标，PostgreSQL会自动生成<unnamed portal>这类临时名称，但Npgsql 3.2.5版本无法自动将这些游标引用转换为可通过NextResult()遍历的结果集——NextResult()通常用于处理单个SQL命令直接返回的多个结果集，而不是游标引用。通过命名游标+显式FETCH，就能让客户端明确地获取每个结果集。

内容的提问来源于stack exchange，提问作者Korkut Düzay