如何在Java中从PostgreSQL访问返回setof refcursor的程序？

Question

需要访问一个从PostgreSQL返回setof refcursor的过程。

我能够访问第一个对象，但不能访问其余对象，而不能访问其余对象。

    con.setAutoCommit(false);
    try (CallableStatement proc = 
             con.prepareCall("{ ? = call usp_sel_article_initialdata_new1() }")) {
        proc.registerOutParameter(1, Types.OTHER);
        proc.execute();
        ResultSet results = (ResultSet) proc.getObject(1); 
        while (results.next()) {
            System.out.println("Result Id" + results.getString(1));
            System.out.println("Results Name" + results.getString(2));
    }

这给了我第一个refcursor值，但是当我尝试使用第二个refcursor时给了我错误，我使用了这一行：

proc.registerOutParameter(2, Types.OTHER);

它给出了错误。还尝试了：

proc.registerOutParameter(1, Types.REF);

这也行不通。过程示例为：

    CREATE OR REPLACE FUNCTION usp_sel_article_initialdata_new1()
    RETURNS SETOF refcursor AS
    $BODY$
    Declare swv_refcur refcursor;
    swv_refcur2 refcursor;
    DECLARE r record;
    BEGIN

    open SWV_RefCur for Select OM.opID as ID,OM.OperatorName as Name from operator
    AS OM (OPid bigint,OperatorName character varying(100),status boolean)
    where OM.status = true 
    order By OperatorName;
    return next SWV_RefCur;

    open SWV_RefCur2 for Select CC.cirid as ID,CC.cirnm as Name from  circle 
    AS CC (cirid bigint,cirnm character varying(100),status boolean)
    where Status = true and cirid not in(28,31) 
    order by cirnm;
    return next SWV_RefCur2;

请帮助我如何访问第二个对象。

Answer 1

returns setof refcursor表示您在调用时得到一个常规ResultSet，其中每个“行”包含 另一个 ResultSet
getObject()：

以下对我有用：

ResultSet rs = stmt.executeQuery("select * from usp_sel_article_initialdata_new1()");
if (rs.next())
{
  // first result set returned
  Object o = rs.getObject(1);
  if (o instanceof ResultSet)
  {
    ResultSet rs1 = (ResultSet)o;
    while (rs1.next())
    {
       int id = rs1.getInt(1);
       String name = rs1.getString(2);
       .... retrieve the other columns using the approriate getXXX() calls
    }
  }
}

if (rs.next()) 
{
  // process second ResultSet 
  Object o = rs.getObject(1);
  if (o instanceof ResultSet)
  {
    ResultSet rs2 = (ResultSet)o;
    while (rs2.next())
    {
       ......
    }
  }
}

从内部psql您也可以使用，select * from usp_sel_article_initialdata_new1()您只需要在FETCH ALL以后使用即可。有关示例，请参见手册：http : //www.postgresql.org/docs/current/static/plpgsql-
cursors.html#AEN59018

postgres=> select * from usp_sel_article_initialdata_new1();
 usp_sel_article_initialdata_new1
----------------------------------
 <unnamed portal 1>
 <unnamed portal 2>
(2 rows)

postgres=> fetch all from "<unnamed portal 1>";
 ?column?
----------
        1
(1 row)

postgres=> fetch all from "<unnamed portal 2>";
 ?column?
----------
        2
(1 row)

postgres=>

（我为上面的示例创建了一个虚拟函数，该函数仅返回一行包含1第一个游标和2第二个游标的值）

编辑 ：

为了使其正常工作，它需要在事务内部运行。因此，必须关闭自动提交：

connection.setAutoCommit(false);