sql >> Databáze >  >> RDS >> Oracle

Jak volat uloženou proceduru s referenčním kurzorem jako výstupním parametrem pomocí Spring?

Zde je něco, co jsem dal dohromady na základě tuto otázku StackOverflow a dokumentace Spring :

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

import javax.sql.DataSource;

import oracle.jdbc.OracleTypes;
import org.springframework.jdbc.core.SqlOutParameter;
import org.springframework.jdbc.core.SqlParameter;
import org.springframework.jdbc.object.StoredProcedure;

public class SampleStoredProcedure extends StoredProcedure {

    public SampleStoredProcedure(DataSource dataSource) {
        super(dataSource, "PROC_NAME");
        declareParameter(new SqlParameter("param1", Types.VARCHAR));
        declareParameter(new SqlParameter("param2", Types.VARCHAR));
        declareParameter(new SqlOutParameter("results_cursor", OracleTypes.CURSOR, new SomeRowMapper()));
        compile();
    }

    public Map<String, Object> execute(String param1, String param2) {
        Map<String, Object> inParams = new HashMap<>();
        inParams.put("param1", param1);
        inParams.put("param2", param2);
        Map output = execute(inParams);
        return output;
    }
}

Pokud je vaše uložená procedura v jiném schématu nebo v balíčku, budete muset upravit název uložené procedury ve výše uvedeném. Také budete muset určit mapovač řádků, který se má použít místo SomeRowMapper .

Chcete-li to nazvat:

    DataSource dataSource = ... ; // get this from somewhere
    SampleStoredProcedure sp = new SampleStoredProcedure(dataSource);
    Map<String, Object> result = sp.execute("some string", "some other string");
    // Do something with 'result': in particular, result.get("results_cursor")
    // will be the list of objects returned

Případně můžete použít SimpleJdbcCall :

    DataSource dataSource = ... ; // get this from somewhere
    SimpleJdbcCall jdbcCall = new SimpleJdbcCall(dataSource);
    Map<String, Object> result =
        jdbcCall.withProcedureName("PROC_NAME")
            .declareParameters(
                    new SqlParameter("param1", Types.VARCHAR),
                    new SqlParameter("param2", Types.VARCHAR),
                    new SqlOutParameter("results_cursor", OracleTypes.CURSOR, new SomeRowMapper()))
            .execute("some string", "some other string");

Pokud je uložená procedura v balíčku, budete muset přidat řádek

            .withCatalogName("PACKAGE_NAME")

k nastavení jdbcCall . Podobně, pokud je v jiném schématu, budete muset přidat

            .withSchemaName("SCHEMA_NAME")


  1. ST_DWithin někdy nepoužívá index

  2. Více GROUP_CONCAT na různých polích pomocí MySQL

  3. MySQL Connector připojující k výčtu hodnotu o jednu menší, než je skutečná hodnota

  4. Použití Wicketu k zobrazení obrázku uloženého jako BLOB v MYSQL db