spring integration dsl :: stored procedure传递输入参数

Question

我试图将现有的存储过程出站网关xml转换为dsl。

    <int-jdbc:stored-proc-outbound-gateway  id="my-proc"
                                        request-channel="myChannel"
                                        data-source="datasource"
                                        stored-procedure-name="SAMPLE_SP"
                                        expect-single-result="false"
                                        ignore-column-meta-data="true">
    <!-- Parameter Definitions -->                                      
    <int-jdbc:sql-parameter-definition  name="V_TEST_ID" direction="IN"/>
    <int-jdbc:sql-parameter-definition name="O_MSG" direction="OUT"/>

    <!-- Parameter Mappings Before Passing & Receiving -->                              
    <int-jdbc:parameter name="V_TEST_ID" expression="payload.testId"/>
</int-jdbc:stored-proc-outbound-gateway>

请问如何将输入参数传递给dsl？

    @Bean
public StoredProcOutboundGateway spGateway(){
    StoredProcOutboundGateway storedProcOutboundGateway = new StoredProcOutboundGateway(storedProcExecutor());
    storedProcOutboundGateway.setExpectSingleResult(true);
    storedProcOutboundGateway.setRequiresReply(true);
    return storedProcOutboundGateway;
}

@Bean
public StoredProcExecutor storedProcExecutor() {
    StoredProcExecutor storedProcExecutor = new StoredProcExecutor(this.datasource);
    storedProcExecutor.setStoredProcedureName("SAMPLE_SP2");
    storedProcExecutor.setIsFunction(false);
    storedProcExecutor.setReturningResultSetRowMappers(..);
    return storedProcExecutor;
}

Answer 1

你需要创建过程参数和sql参数......

@Bean
public StoredProcExecutor storedProcExecutor() {
    StoredProcExecutor storedProcExecutor = new StoredProcExecutor(this.datasource);
    storedProcExecutor.setStoredProcedureName("SAMPLE_SP2");
    storedProcExecutor.setIsFunction(false);
    storedProcExecutor.setReturningResultSetRowMappers(..);

    List<ProcedureParameter> procedureParameters = new ArrayList<>();
    procedureParameters.add(new ProcedureParameter("cdc_group_name", groupName, null));
    // TODO set output_limit from property file
    procedureParameters.add(new ProcedureParameter("output_limit", 500, null));
    storedProcExecutor.setProcedureParameters(procedureParameters);

    List<SqlParameter> sqlParameters = new ArrayList<>();
    sqlParameters.add(new SqlParameter("cdc_group_name", Types.CHAR));
    sqlParameters.add(new SqlParameter("output_limit", Types.BIGINT));
    storedProcExecutor.setSqlParameters(sqlParameters);

    return storedProcExecutor;
}