小编典典

带有PostgreSQL和REF_CURSOR的JPA 2.1 StoredProcedureQuery

hibernate

我在PostgreSQL数据库中创建了一个函数,希望使用JPA 2.1的StoredProcedureQuery方法调用该函数。

这是我的PostgreSQL查询:

CREATE OR REPLACE FUNCTION get_values(date text) returns refcursor 
AS $$ 
    DECLARE tuples refcursor; 
    BEGIN OPEN tuples FOR 
        SELECT user, COUNT(*) 
        FROM my_table 
        WHERE date_ = date
        GROUP BY user; 
    return tuples; 
    END; 
$$ 
LANGUAGE plpgsql

这只是一个简单的查询,可以计算特定日期的用户。这只是一个演示查询,用于测试StoredProcedureQueries的工作方式。实际上,当仅通过postgreSQL使用时,它就可以正常工作。

现在,让我们尝试使用JPA 2.1和Javaland来调用它:

StoredProcedureQuery storedProcedure = em.createStoredProcedureQuery("get_values");
storedProcedure.registerStoredProcedureParameter(2, String.class, ParameterMode.IN);
storedProcedure.registerStoredProcedureParameter(1, Object.class, ParameterMode.REF_CURSOR);
storedProcedure.setParameter(2, "2015-02-01");
storedProcedure.execute();

当我这样做时,我得到以下异常:

org.hibernate.HibernateException: PostgreSQL supports only one REF_CURSOR parameter, but multiple were registered

仅声明了一个ref游标!实际上,如果我只在WHERE date_ =
date的Postgresql函数的值中注册单个REF_CURSOR参数和硬编码,则此调用可以正常进行。

因此,使用ref_cursor向存储过程查询中添加任何其他参数似乎破坏了功能。单独使用ref_cursor参数可以正常工作。

有人看到为什么会这样吗? 为什么为我的PostgreSQL函数向StoredProcedureQuery添加参数会破坏它?

何时工作的示例:

 CREATE OR REPLACE FUNCTION get_values(date text) returns refcursor 
AS $$ 
    DECLARE tuples refcursor; 
    BEGIN OPEN tuples FOR 
        SELECT user, COUNT(*) 
        FROM my_table 
        WHERE date_ = '2015-02-01'
        GROUP BY user; 
    return tuples; 
    END; 
$$ 
LANGUAGE plpgsql

在javaland中:

StoredProcedureQuery storedProcedure =    em.createStoredProcedureQuery("get_values");
storedProcedure.registerStoredProcedureParameter(1, Object.class, ParameterMode.REF_CURSOR);
storedProcedure.execute();

阅读 431

收藏
2020-06-20

共1个答案

小编典典

简短答案:将您的两个呼叫顺序颠倒为registerStoredProcedureParameter()

storedProcedure.registerStoredProcedureParameter(1, Object.class, ParameterMode.REF_CURSOR);
storedProcedure.registerStoredProcedureParameter(2, String.class, ParameterMode.IN);

长答案:我对Hibernate源代码进行了一些挖掘,以获取Postgress可调用语句支持,并发现每个registerStoredProcedureParameter()调用都创建了一个ParameterRegistrationImplementor实例,该实例被添加到列表中并传递。您会注意到,此类存储了参数的位置,该位置与其在列表中的位置无关。

稍后,将分析此列表,并假定REF_CURSOR参数将排在第一位,并且如果REF_CURSOR参数不是第一个参数(
无论参数号是) 将抛出错误消息。

这不是一个非常聪明的处事方式(IMHO),但至少解决方法很简单:如果交换呼叫顺序,就可以了。

2020-06-20