如何使用 postgresql 函数获取多结果集
how can I get multi result set with postgresql function
我想 return 具有函数的多个结果集。但是 reader.NextResult()
不起作用。查询结果如下
"<unnamed portal 1>"
"<unnamed portal 2>"
函数(存储过程),PostgreSQL
CREATE OR REPLACE FUNCTION public.sp_get_multiviewlist
( )
RETURNS SETOF refcursor
DECLARE
ref1 refcursor;
ref2 refcursor;
BEGIN
OPEN ref1 FOR
SELECT * FROM public."Customer";
RETURN NEXT ref1;
OPEN ref2 FOR
SELECT * FROM public."Order";
RETURN NEXT ref2;
END;
$$ LANGUAGE plpgsql;
其他数据库运行正常。我该怎么做?
npgsql:版本 3.2.5
使用setof refcursor
是一种可以在PG 中模拟多个结果集的方法。但其实和多结果集不是一回事
Npgsql 过去常常自动获取从存储过程返回的游标的内容,但这也不总是预期的,所以它被删除了。在 this github issue.
阅读整个(长篇)讨论
无论如何,要获取数据,您必须执行 FETCH ALL FROM "<unnamed portal 1>"
- 其中 unnamed portal 1
必须是从存储过程返回的字符串。
如果您在事务中执行存储过程,游标只会保持足够长的时间。
你可以看看 Npgsql 过去是如何做到这一点的here,或者遵循下面的一般方法:
using(var trans = db.BeginTransaction())
using(var cmd = db.CreateCommand()) {
cmd.CommandText = "sp_get_multiviewlist";
cmd.CommandType = CommandType.StoredProcedure;
string cursor1Name,cursor2Name;
using (var reader = cmd.ExecuteReader())
{
reader.Read();
cursor1Name = reader.GetString(0);
reader.Read();
cursor2Name = reader.GetString(0);
}
using(var resultSet1 = db.CreateCommand())
{
resultSet1.CommandText = $@"FETCH ALL FROM ""{cursor1Name}""";
using (var reader = resultSet1.ExecuteReader())
{
while (reader.Read())
{
// Do something with the customer row
}
}
}
using (var resultSet2 = db.CreateCommand())
{
resultSet2.CommandText = $@"FETCH ALL FROM ""{cursor2Name}""";
using (var reader = resultSet2.ExecuteReader())
{
while (reader.Read()) {
// Do something with the order row
}
}
}
}
我想 return 具有函数的多个结果集。但是 reader.NextResult()
不起作用。查询结果如下
"<unnamed portal 1>"
"<unnamed portal 2>"
函数(存储过程),PostgreSQL
CREATE OR REPLACE FUNCTION public.sp_get_multiviewlist
( )
RETURNS SETOF refcursor
DECLARE
ref1 refcursor;
ref2 refcursor;
BEGIN
OPEN ref1 FOR
SELECT * FROM public."Customer";
RETURN NEXT ref1;
OPEN ref2 FOR
SELECT * FROM public."Order";
RETURN NEXT ref2;
END;
$$ LANGUAGE plpgsql;
其他数据库运行正常。我该怎么做?
npgsql:版本 3.2.5
使用setof refcursor
是一种可以在PG 中模拟多个结果集的方法。但其实和多结果集不是一回事
Npgsql 过去常常自动获取从存储过程返回的游标的内容,但这也不总是预期的,所以它被删除了。在 this github issue.
阅读整个(长篇)讨论无论如何,要获取数据,您必须执行 FETCH ALL FROM "<unnamed portal 1>"
- 其中 unnamed portal 1
必须是从存储过程返回的字符串。
如果您在事务中执行存储过程,游标只会保持足够长的时间。
你可以看看 Npgsql 过去是如何做到这一点的here,或者遵循下面的一般方法:
using(var trans = db.BeginTransaction())
using(var cmd = db.CreateCommand()) {
cmd.CommandText = "sp_get_multiviewlist";
cmd.CommandType = CommandType.StoredProcedure;
string cursor1Name,cursor2Name;
using (var reader = cmd.ExecuteReader())
{
reader.Read();
cursor1Name = reader.GetString(0);
reader.Read();
cursor2Name = reader.GetString(0);
}
using(var resultSet1 = db.CreateCommand())
{
resultSet1.CommandText = $@"FETCH ALL FROM ""{cursor1Name}""";
using (var reader = resultSet1.ExecuteReader())
{
while (reader.Read())
{
// Do something with the customer row
}
}
}
using (var resultSet2 = db.CreateCommand())
{
resultSet2.CommandText = $@"FETCH ALL FROM ""{cursor2Name}""";
using (var reader = resultSet2.ExecuteReader())
{
while (reader.Read()) {
// Do something with the order row
}
}
}
}