SQL Server：如何使用Spring jdbctemplate将数组传递给返回多个结果集的存储过程

Question

我在SQL Server 2008中有一个存储过程，它将数组作为输入参数。根据http://www.sommarskog.se/arrays-in-sql-2008.html，我将使用TVP。但是，MSSQL JDBC驱动程序不支持这一点。因此，我无法使用SimpleJDBCall来执行存储过程，因为我无法传递数组参数。我返回使用JdbcTemplate调用此过程，如下所示：

StringBuilder sb = new StringBuilder();
sb.append("declare @d object_url_type;");
sb.append("insert into @d values (0, 'http://example.com', '/index.html', '');");
sb.append("insert into @d values (0, 'http://example.com', '/help.html', '');");
sb.append("exec procedure_name @objs=@d, @id=123");
jdbcTemplate.query(sb.toString(), new BeanPropertyRowMapper(ObjectData.class));

我遇到的问题是存储过程返回两个结果集。但似乎我只能使用jdbcTemplate检索第一个结果集。如果我可以使用SimpleJdbcCall，那么很容易分解两个结果集，但不幸的是我不能使用它。我在谷歌上搜索了很多，但找不到这个问题的任何解决方案。有人能帮我吗？我想我会回去使用原始JDBC方式。

Answer 1

您应该使用Spring StoredProcedure类而不是jdbcTemplate，然后可以使用declareParameter返回多个结果集：

package com.example;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Types;
import java.util.HashMap;
import java.util.Map;

import javax.sql.DataSource;

import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.core.SqlParameter;
import org.springframework.jdbc.core.SqlReturnResultSet;
import org.springframework.jdbc.object.StoredProcedure;

public class ExampleStoredProcedure extends StoredProcedure {

    public class MyOtherRowMapper implements RowMapper<Long> {

        @Override
        public Long mapRow(ResultSet rs, int rowNum) throws SQLException {
            return rs.getLong("LONGCOLUMNNAME");
        }

    }

    public class MyRowMapper implements RowMapper<String> {

        @Override
        public String mapRow(ResultSet rs, int rowNum) throws SQLException {
            return rs.getString("STRINGCOLUMNMNAME");
        }

    }

    private static final String INPUT_PARAM = "@strParam";
    public static final String RESULTSET1 = "ResultSet1";
    public static final String RESULTSET2 = "ResultSet2";

    public ExampleStoredProcedure(DataSource dataSource, String storedProcName) {
        super(dataSource, storedProcName);
        this.declareParameters();
        compile();
    }

    public Map<String, Object> execute(String param) {
        Map<String, Object> inputs = new HashMap<String, Object>();

        inputs.put(INPUT_PARAM, param);
        Map<String, Object> results = super.execute(inputs);

        return results;
    }

    protected void declareParameters() {
        declareParameter(new SqlParameter(INPUT_PARAM, Types.VARCHAR));
        declareParameter(new SqlReturnResultSet(RESULTSET1, new MyRowMapper()));
        declareParameter(new SqlReturnResultSet(RESULTSET2, new MyOtherRowMapper()));
    }

}

调用存储过程：

package com.example;

import java.util.List;
import java.util.Map;

import org.junit.Test;
import org.springframework.beans.factory.annotation.Autowired;

public class ExampleStoredProcedureTest {
    // assuming you pass the dataSource in via injection, etc, etc.
    @Autowired
    public ExampleStoredProcedure storedProc;

    @Test
    public void test() {
        Map<String, Object> results = storedProc.execute("Test Parameter");

        // accessing the result sets
        List<?> rs1 = (List<?>) results.get(ExampleStoredProcedure.RESULTSET1);
        List<?> rs2 = (List<?>) results.get(ExampleStoredProcedure.RESULTSET2);

        // etc
    }

}