Hsqldb - 从存储过程返回结果集

Question

我试图在 HsqlDB 中调用一个存储过程并返回一个结果集

我的存储过程如下

    CREATE PROCEDURE p_getTeamTasksForLastXDays(IN teamId BIGINT, IN numberOfDays BIGINT) READS SQL DATA
  DYNAMIC RESULT SETS 1
  BEGIN ATOMIC
   declare curs cursor for select taskId, taskName from V_TASK_DETAILS;
   open curs;
  END;
  /;

我用来调用这个proc的Java和hibernate代码如下

public void getTaskExecutionLogs(Long teamId, Long numberOfDays) {
        LOG.info("Entered getTaskExecutionLogs Method - teamId:{}, numberOfDays: {}", teamId, numberOfDays);

        ProcedureCall procedureCall = currentSession().createStoredProcedureCall("p_getTeamTasksForLastXDays");
        procedureCall.registerParameter( TEAM_ID, Long.class, ParameterMode.IN ).bindValue( teamId );
        procedureCall.registerParameter( NUMBER_OF_DAYS, Long.class, ParameterMode.IN ).bindValue( numberOfDays );

        ProcedureOutputs outputs = procedureCall.getOutputs();
        ResultSetOutput resultSetOutput = (ResultSetOutput) outputs.getCurrent();

        List resultSetList = resultSetOutput.getResultList();

}

当我尝试调用这个过程时得到的错误如下

java.lang.ClassCastException: org.hibernate.result.internal.UpdateCountOutputImpl cannot be cast to org.hibernate.result.ResultSetOutput
    at com.mct.dao.database.impl.TaskDetailsDAOImpl.getTaskExecutionLogs(TaskDetailsDAOImpl.java:229)

当我尝试在 MySql 中调用存储过程时，完全相同的代码可以正常工作

非常感谢任何帮助

谢谢 达米安

Answer 1

ProcedureOutputs 是一个 interface 哪个 extends Outputs (source)。

ResultSetOutput 是一个 interface 哪个 extends Output (source)。 当你调用getCurrent() 或Outputs 时，你会得到一个Output (source)。

基本上，您希望转换是正确的，因为您将结果转换为Output 的子接口。你正在做的事情叫做downcast。来看看案例吧。

您想将一个对象投射到另一个对象。由于ResultSetOutputextendsOutput，因此可能会感到沮丧。由于向下转换可能是可能的，因此您不会收到编译时错误，并且在可能的情况下，例如在您调用 MySQL 中的存储过程的情况下，向下转换将成功。但是，当无法进行向下转换时，您会收到运行时异常。在我们的特殊情况下，向下转换是不可能的，因为.getOutputs 返回另一个分类，可能是另一个继承分支上的子接口，例如UpdateCountOutput。

Answer 2

Lajos 关于沮丧是正确的。问题是您在编码时假设ProcedureOutputs.getCurrent() 返回的Output 将是ResultSetOutput，而实际上它可能是UpdateCountOutput。

其实Output接口有一个方法isResultSet()可以帮你判断：

布尔型 org.hibernate.result.Output.isResultSet()

确定此返回是否为结果（可转换为ResultSetOutput）。另一种方法是它是一个更新计数（可转换为UpdateCountOutput）。

返回：

true 表示可以安全地转换为ResultSetOutput)，否则可以转换为UpdateCountOutput。

除此之外，Outputs 可以传递多个Output，Output.getCurrent() 的状态由Output.goToNext() 控制。

因此，为了正确处理多个结果，您必须通过以下方式获取输出：

ProcedureOutputs outputs = procedureCall.getOutputs();

do {
    Output current = outputs.getCurrent();

    if (current.isResultSet()) {
        ResultSetOutput resultSetOutput = (ResultSetOutput) current;
        System.out.println("do something with result set output");
    } else {
        UpdateCountOutput updateCountOutput = (UpdateCountOutput) current;
        System.out.println("do something with update count output");
    }            
} while (outputs.goToNext());

outputs.release();

在我的测试中我得到：

1647 [main] 调试 org.hibernate.SQL - {调用 p_getTeamTasksForLastXDays(?,?)}

休眠：{调用 p_getTeamTasksForLastXDays(?,?)}

1668 [main] 调试 org.hibernate.result.internal.OutputsImpl - 构建返回 [isResultSet=false, updateCount=0, extendedReturn=false

对更新计数输出做一些事情

1669 [main] 调试 org.hibernate.result.internal.OutputsImpl - 构建返回 [isResultSet=true, updateCount=-1, extendedReturn=false

1671 [main] DEBUG org.hibernate.loader.Loader - 结果集行：0

1671 [main] DEBUG org.hibernate.loader.Loader - 结果行：

对结果集输出做一些事情

PS：我这里没有mysql，所以我无法确认它是否同时返回ResultSetOutput和UpdateCountOutput，但顺序与hsqldb不同，但也许你可以验证一下。