从java调用时如何将Cursor变量传递给postgres过程？

Question

我正在从 Spring Boot 应用程序调用一个 postgres 存储过程，该应用程序具有 1 个文本类型的 IN 参数和 1 个 refcursor 类型的 INOUT 参数。如何从 CallableStatement 以外的 springboot 应用程序调用此过程。

public class CallProc {
    public static void main(String[] args) throws ClassNotFoundException, java.sql.SQLException {
        
        Class.forName("org.postgresql.Driver");
        
        String url = "jdbc:postgresql://azure.com/test";
        Properties props = new Properties();
        props.setProperty("user","test");
        props.setProperty("password","test");
        props.setProperty("ssl","true");
        props.setProperty("escapeSyntaxCallMode", "callIfNoReturn");
        Connection conn = DriverManager.getConnection(url, props);

        // need a transaction
        conn.setAutoCommit(false);

        java.sql.CallableStatement callableStatement =
            conn.prepareCall("{call myProc(?, ?)}");

        callableStatement.setString(1, "user");
        callableStatement.setObject(2, null);

        callableStatement.registerOutParameter(2, java.sql.Types.REF_CURSOR);

        callableStatement.execute();
       
        java.sql.ResultSet rs =
            (java.sql.ResultSet) callableStatement.getObject(2);

        while (rs.next())
            System.out.println(rs.getInt(1));

        rs.close();
        conn.commit();

        conn.close();
    }
}

而我的程序定义是这样的，

CREATE OR REPLACE PROCEDURE myapp.MyProc(
     in_user_id TEXT,
     INOUT user_roles refcursor)
language plpgsql
AS $BODY$
DECLARE

DERIVED USER_ID VARCHAR(50);

BEGIN
//body
...
//
END
$BODY$

谢谢

Answer 1

要使用java.sql.CallableStatement 调用过程，请使用带有值call 或callIfNoReturn 的连接参数escapeSyntaxCallMode，并且不指定返回参数。正如the documentation 所说：

escapeSyntaxCallMode = 字符串

指定驱动程序如何将 JDBC 转义调用语法转换为底层 SQL，以调用过程或函数。在escapeSyntaxCallMode=select 模式（默认）下，驱动程序始终使用 SELECT 语句（仅允许函数调用）。在escapeSyntaxCallMode=callIfNoReturn 模式下，如果没有指定返回参数，则驱动程序使用 CALL 语句（允许过程调用），否则驱动程序使用 SELECT 语句。在escapeSyntaxCallMode=call 模式下，驱动程序始终使用 CALL 语句（仅允许过程调用）。

问题是在 v11 中添加过程之前，JDBC 驱动程序将 CallableStatement 调用转换为函数调用，这对过程不起作用。

这是一个调用过程p(IN integer, INOUT refcursor) 的代码示例，其中refcursor 位于integers 的结果集上：

public class CallProc {
    public static void main(String[] args) throws ClassNotFoundException, java.sql.SQLException {
        Class.forName("org.postgresql.Driver");

        java.sql.Connection conn =
            java.sql.DriverManager.getConnection(
                "jdbc:postgresql:test?user=laurenz&password=something&escapeSyntaxCallMode=callIfNoReturn"
            );

        // need a transaction
        conn.setAutoCommit(false);

        java.sql.CallableStatement callableStatement =
            conn.prepareCall("{call p(?::text, ?::refcursor)}");

        callableStatement.setInt(1, 5);
        callableStatement.setObject(2, null);

        callableStatement.registerOutParameter(2, java.sql.Types.REF_CURSOR);

        callableStatement.execute();
       
        java.sql.ResultSet rs =
            (java.sql.ResultSet) callableStatement.getObject(2);

        while (rs.next())
            System.out.println(rs.getInt(1));

        rs.close();
        conn.commit();

        conn.close();
    }
}