Spring JDBC 模板。如何获取pl/sql脚本的结果变量

Question

我正在使用 NamedParameterJdbcTemplate 来运行 pl/sql 脚本。 但我不知道如何获取 out 变量的值 (:id_out)。 提前致谢。

String script = "declare 
                   begin 
                     if myFunc(:id_in) is null then 
                        :id_out := 0; 
                     else 
                        :id_out := 1; 
                     end if; 
                   end;";
Map<String,Object> bindVars = new HashMap<String, Object>();
bindVars.put(id_in,1);
bindVars.put(id_out,2);


jdbcTmpl.execute(script, bindVars, new PreparedStatementCallback<Object>() {
    @Override public Object doInPreparedStatement(PreparedStatement cs)
        throws SQLException, DataAccessException {
        cs.execute();
        return null;
                }
       }
       );

Answer 1

可以使用普通 JdbcTemplate 来完成，如下例所示，但请注意必须在匿名 plsql 块中使用“? := 'something';

下面使用的 java 参数指定 OUT 值：String id="12345" String fixSql=

    declare
        p_id VARCHAR2(20) := null; 
        p_status_message VARCHAR2(32767) := null;
    begin
        p_id := ?;
        p_status_message := ' Everything is possible: ' || p_id;
        ? := 'Return text.' || p_status_message;
    end;

请注意上面的两个问号 - 第一个实际上是 IN 参数，第二个是 OUT 参数。此代码将调用它：

    public class Foo extends JdbcDaoSupport {
    ...
    public String doAnonymousPlSql(final String id, String fixSql) throws CustomerFixException {
        String resultValue = getJdbcTemplate().execute(new CallableStatementCreator() {
            @Override
            public CallableStatement createCallableStatement(Connection connection) throws SQLException {
                CallableStatement sql = connection.prepareCall(fixSql);
                sql.setString(1, id);
                sql.registerOutParameter(2, Types.VARCHAR);
                return sql;
            }
        }
        , new CallableStatementCallback<String>() {
            @Override
            public String doInCallableStatement(CallableStatement callablestatement) throws SQLException,
                    DataAccessException {
                callablestatement.executeUpdate();
                return (String) callablestatement.getObject(2);
            }
        });

Answer 2

我不相信您可以将 NamedParameterJdbcTemplate （或 JdbcTemplate 的任何其他子类）与如上所述的匿名 PL/SQL 块一起使用。您必须将匿名 PL/SQL 块包装到存储过程或函数中。

Spring 旨在跨数据库移植。据我所知，MySQL 和 SQL Server 都没有类似于 Oracle 匿名 PL/SQL 块的概念（不过，我很高兴在这一点上被证明是错误的）。由于此功能不能跨数据库移植，因此 Spring 无法真正仅针对 Oracle 支持它。

Answer 3

List<SqlParameter> params = new LinkedList<SqlParameter>();
params.add(new SqlParameter(Types.NUMERIC));
params.add(new SqlParameter(Types.NUMERIC));
params.add(new SqlOutParameter("out_param_1", Types.NUMERIC));
params.add(new SqlOutParameter("out_param_2", Types.NUMERIC));
Map<String, Object> ret = simpleJdbcTemplate.getJdbcOperations().call(
new CallableStatementCreator() {

    @Override
    public CallableStatement createCallableStatement(Connection con) throws SQLException {
        CallableStatement cs = con.prepareCall("DECLARE ..." + 
                                               "BEGIN ... " + 
                                               "delete from table where table_field_1 = ? and table_field_2 = ? " + 
                                               "returning out_param_1, out_param_2 into ?, ?; " + 
                                               "END;"
        cs.setInt(1, first_in_param_value);
        cs.setInt(2, second_in_param_value);
        cs.registerOutParameter(3, Types.NUMERIC);
        cs.registerOutParameter(4, Types.NUMERIC);
        return cs;
    }
}, params);

ret.get("out_param_1");
ret.get("out_param_1");

Answer 4

这在 Spring Data 中工作得很好：

NamedParameterJdbcTemplate jdbcTemplate;
jdbcTemplate.update(
    "DECLARE ... BEGIN ... (PL/SQL Block with named binding parameters) END;",
    new MapSqlParameterSource
        .addValue("parameter1", value1)
        .addValue("parameter2", value2));