spring-boot - 使用 Spring Batch 中的 IN 和 OUT 参数调用存储过程

问题描述

我正在尝试从 Spring Batch 执行存储过程，该存储过程有两个参数，一个 IN 参数和一个 OUT 参数。我想要的是在调用存储过程时获取结果集和 out 参数。

我提到了StoredProcedureItemReader和StoredProcedureItemReaderBuilder

我可以使用它来调用只有 IN 参数的存储过程，但是，我在注册 OUT 参数后无法调用。

如果我们引用我们可以使用的原始 JDBC 模板，则可以使用https://docs.oracle.com/javase/7/docs/api/java/sql/CallableStatement.html调用具有 IN 和 OUT 变量的存储过程

我相信StoredProcedureItemReader还是在幕后StoredProcedureIteamReaderBuilder使用。CallableStatement

我的问题是，如何使用StoredProcedureItemReaderBuilder注册 OUT 参数以在 Spring Batch 中执行

这是我尝试过的示例代码

@StepScope
    @Bean
    public StoredProcedureItemReader<MyRow> rowReader(@Value("#{stepExecutionContext[tableName]}") String tableName) {
        return new StoredProcedureItemReaderBuilder<MyRow>()
                .procedureName("GetNameCountByFname")
                .parameters(
                        new SqlParameter[]{
                                new SqlParameter("fname", Types.VARCHAR),
                                new SqlOutParameter("total", Types.INTEGER)
                        }).
                        preparedStatementSetter(
                                new PreparedStatementSetter() {
                                    @Override
                                    public void setValues(PreparedStatement ps)
                                            throws SQLException {
                                        ps.setString(1, "bob");
                                    }
                                }
                .rowMapper(new MyRowMapper(tableName))
                .name(tableName + "_read")
                .dataSource(dataSource)
                .build();
    }

给出以下错误：

Caused by: java.lang.ArrayIndexOutOfBoundsException: -1
    at java.util.ArrayList.elementData(ArrayList.java:422) ~[na:1.8.0_251]
    at java.util.ArrayList.get(ArrayList.java:435) ~[na:1.8.0_251]
    at com.mysql.cj.jdbc.CallableStatement$CallableStatementParamInfo.getParameter(CallableStatement.java:283) ~[mysql-connector-java-8.0.20.jar:8.0.20]
    at com.mysql.cj.jdbc.CallableStatement.checkIsOutputParam(CallableStatement.java:634) ~[mysql-connector-java-8.0.20.jar:8.0.20]
    at com.mysql.cj.jdbc.CallableStatement.getObject(CallableStatement.java:1356) ~[mysql-connector-java-8.0.20.jar:8.0.20]

调用以下存储过程

DELIMITER $$

CREATE PROCEDURE GetNameCountByFname(
    IN  fname VARCHAR(25),
    OUT total INT
)
BEGIN
    SELECT COUNT(*)
    INTO total
    FROM `first`
    WHERE `name` = fname;
END$$

DELIMITER ;

标签： spring-bootspring-batchjava-stored-procedures

spring-boot - 使用 Spring Batch 中的 IN 和 OUT 参数调用存储过程

问题描述

解决方案

推荐阅读