Spring JcbcTemplate для вызова Oracle Stored Proc. Весна 3.2
У меня есть некоторый прямой код JDBC, использующий CallableStatement. Я пытался преобразовать его в Spring, используя DataSource, JdbcTemplate и SimpleJdbcCall. Я пробовал в основном каждый учебник, пример и фрагменты из документов Spring, которые я могу найти. При настройке все решения Spring дают одинаковый результат:
org.springframework.jdbc.BadSqlGrammarException: CallableStatementCallback; bad SQL grammar [{call UPCLSCH.P_GET_CLASS_SCHEDULE()}]; nested exception is java.sql.SQLException: ORA-06550: line 1, column 7:
PLS-00306: wrong number or types of arguments in call to 'P_GET_CLASS_SCHEDULE'
ORA-06550: line 1, column 7:
PL/SQL: Statement ignored
Вот раздел журнала, где готовится инструкция:
2015-12-29 17:17:18 DEBUG SimpleJdbcCall:214 - Added declared parameter for [p_get_class_schedule]: p_classsched_ref_out
2015-12-29 17:17:18 DEBUG SimpleJdbcCall:214 - Added declared parameter for [p_get_class_schedule]: p_term
2015-12-29 17:17:18 DEBUG SimpleJdbcCall:214 - Added declared parameter for [p_get_class_schedule]: p_scauid
2015-12-29 17:17:18 DEBUG SimpleJdbcCall:214 - Added declared parameter for [p_get_class_schedule]: p_pidm
2015-12-29 17:17:18 DEBUG SimpleJdbcCall:336 - JdbcCall call not compiled before execution - invoking compile
2015-12-29 17:17:18 DEBUG DataSourceUtils:110 - Fetching JDBC Connection from DataSource
2015-12-29 17:17:18 DEBUG DriverManagerDataSource:162 - Creating new JDBC DriverManager Connection to [jdbc:oracle:thin:@umadmn.umt.edu:7895:ADMNRED]
2015-12-29 17:17:21 DEBUG CallMetaDataProviderFactory:123 - Using org.springframework.jdbc.core.metadata.OracleCallMetaDataProvider
2015-12-29 17:17:21 DEBUG CallMetaDataProvider:278 - Retrieving metadata for UPCLSCH/AP_ADMN/P_GET_CLASS_SCHEDULE
2015-12-29 17:17:22 DEBUG DataSourceUtils:332 - Returning JDBC Connection to DataSource
2015-12-29 17:17:22 DEBUG SimpleJdbcCall:304 - Compiled stored procedure. Call string is [{call UPCLSCH.P_GET_CLASS_SCHEDULE()}]
2015-12-29 17:17:22 DEBUG SimpleJdbcCall:282 - SqlCall for procedure [p_get_class_schedule] compiled
2015-12-29 17:17:22 DEBUG SimpleJdbcCall:385 - The following parameters are used for call {call UPCLSCH.P_GET_CLASS_SCHEDULE()} with: {}
2015-12-29 17:17:22 DEBUG JdbcTemplate:937 - Calling stored procedure [{call UPCLSCH.P_GET_CLASS_SCHEDULE()}]
2015-12-29 17:17:22 DEBUG DataSourceUtils:110 - Fetching JDBC Connection from DataSource
2015-12-29 17:17:22 DEBUG DriverManagerDataSource:162 - Creating new JDBC DriverManager Connection to [jdbc:oracle:thin:@xxxxx.xxx.xxx:7895:PRIVATE]
2015-12-29 17:17:24 DEBUG DataSourceUtils:332 - Returning JDBC Connection to DataSource
Вот прямой код JDBC, который работает (без информации о соединении):
private static List<ScheduledClass> callOracleStoredProcCURSORParameter() throws SQLException {
Connection connection = null;
CallableStatement callableStatement = null;
ResultSet rs = null;
List<ScheduledClass> scheduledClassList = new ArrayList<ScheduledClass>();
String getDBUSERCursorSql = "{call upclsch.p_get_class_schedule (?, ?, ?, ?)}";
try {
connection = getApConnection();
callableStatement = connection.prepareCall(getDBUSERCursorSql);
callableStatement.registerOutParameter("p_classsched_ref_out", OracleTypes.CURSOR);
callableStatement.setString("p_term", "201570"); //term code
callableStatement.setString("p_scauid", "rs213498");
callableStatement.setString("p_pidm", null);
callableStatement.executeUpdate();
rs = (ResultSet) callableStatement.getObject("p_classsched_ref_out");
while (rs.next()) {
ScheduledClass sc = new ScheduledClass();
sc.setCourseNumber(rs.getString("subject_code") + rs.getString("course_number"));
sc.setCourseTitle(rs.getString("course_title"));
scheduledClassList.add(sc);
}
} catch (SQLException e) {
e.printStackTrace();
}
return scheduledClassList;
}
Вот мой нерабочий Spring Code (обратите внимание на закомментированный раздел, который дает тот же результат при передаче "in" в sjc.execute()):
public void setDataSource(DataSource dataSource){
this.jt = new JdbcTemplate(dataSource);
jt.setResultsMapCaseInsensitive(true);
sjc = new SimpleJdbcCall(jt)
.withCatalogName("upclsch")
.withProcedureName("p_get_class_schedule");
}
public Map<String, Object> execute(String termCode, String netId){
sjc.useInParameterNames("p_term", "p_scauid", "p_pidm")
.declareParameters(new SqlOutParameter("p_classsched_ref_out", OracleTypes.CURSOR),
new SqlParameter("p_term", OracleTypes.VARCHAR),
new SqlParameter("p_scauid", OracleTypes.VARCHAR),
new SqlParameter("p_pidm", OracleTypes.VARCHAR));
// SqlParameterSource in = new MapSqlParameterSource()
// .addValue("p_scauid", netId, OracleTypes.VARCHAR)
// .addValue("p_term", termCode, OracleTypes.VARCHAR)
// .addValue("p_classsched_ref_out", OracleTypes.CURSOR);
Map<String, Object> results = sjc.execute();
return results;
}
Кажется, я не могу получить дополнительную информацию на уровне TRACE или DEBUG, чтобы увидеть, правильно ли упорядочены мои параметры. Таким образом, я ищу помощи от любого, кто выполнил эту задачу, используя эту технику. Я не собираюсь расширять StoredProcedure, так как Spring Spring рекомендует это для 3.2.
2 ответа
Решение
Решено: я разобрался, пройдя источник Spring. Для тех, кто может быть заинтересован, это включает объявление параметров, которые фактически использует процедура, а затем использование SqlParameterSource для хранения значений, сопоставленных с именами, как они были объявлены. Обратите внимание, что я добавляю значения на карту в обратном порядке по мере добавления параметров. Также обратите внимание, что я добавил: .withoutProcedureColumnMetaDataAccess(), Это важно при объявлении ваших собственных параметров, как я сделал.
public class ScheduledClassesDAO {
private DataSource dataSource;
private JdbcTemplate jt;
private SimpleJdbcCall sjc;
public void setDataSource(DataSource dataSource){
this.jt = new JdbcTemplate(dataSource);
jt.setResultsMapCaseInsensitive(true);
sjc = new SimpleJdbcCall(jt)
.withCatalogName("upclsch")
.withProcedureName("p_get_class_schedule");
}
/**
* This method is used to return scheduled classes by calling a stored-proc.
* @param termCode String: The term/semester for this lookup.
* @param netId String: The netId of the student to lookup
* @return Map<String, Object>
*/
public Map<String, Object> execute(String termCode, String netId){
sjc.useInParameterNames("p_term", "p_scauid", "p_pidm")
.withoutProcedureColumnMetaDataAccess()
.declareParameters(new SqlOutParameter("p_classsched_ref_out", OracleTypes.CURSOR),
new SqlParameter("p_term", OracleTypes.VARCHAR),
new SqlParameter("p_scauid", OracleTypes.VARCHAR),
new SqlParameter("p_pidm", OracleTypes.NUMBER));
SqlParameterSource in = new MapSqlParameterSource()
.addValue("p_pidm", null)
.addValue("p_scauid", netId)
.addValue("p_term", termCode);
Map<String, Object> results = sjc.execute(in);
return results;
}
}
Вы можете использовать StoredProcedure для этого варианта использования. Вы, вероятно, не передаете параметры в процедуру.
Смотрите пример кода ниже.
TestProcedure.java
import java.util.List;
import java.util.Map;
import org.springframework.jdbc.core.JdbcTemplate;
public class TestProcedure {
public void main(String[] args) {
System.out.println("Started");
JdbcTemplate jdbcTemplate = null;//get your jdbcTemplate
MyProcedure proc = new MyProcedure(jdbcTemplate);
Map<String, Object> resultMap = proc.execute("201570","rs213498",null);
List<Map> classschedList = (List)resultMap.get(MyProcedure.P_CLASSSCHED_REF_OUT);
}
}
MyProcedure
import java.util.HashMap;
import java.util.Map;
import oracle.jdbc.internal.OracleTypes;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.SqlOutParameter;
import org.springframework.jdbc.core.SqlParameter;
import org.springframework.jdbc.object.StoredProcedure;
public class MyProcedure extends StoredProcedure {
public static final String P_CLASSSCHED_REF_OUT = "p_classsched_ref_out";
public static final String P_TERM = "p_term";
public static final String P_SCAUID = "p_scauid";
public static final String P_PIDM = "p_pidm";
public static final String PROC_NAME = "upclsch.p_get_class_schedule";
public MyProcedure(JdbcTemplate jdbcTemplate) {
setDataSource(jdbcTemplate.getDataSource());
setSql(PROC_NAME);
setFetchSize(100);
declareParameter(new SqlOutParameter(P_CLASSSCHED_REF_OUT, OracleTypes.CURSOR, new MyRowMapper()));
declareParameter(new SqlParameter(P_TERM, OracleTypes.VARCHAR));
declareParameter(new SqlParameter(P_SCAUID, OracleTypes.VARCHAR));
declareParameter(new SqlParameter(P_PIDM, OracleTypes.VARCHAR));
compile();
}
/**
* Execute stored procedure.
*/
public Map<String, Object> executeProcedure(String term, String scauid, String pidm) {
// set the input params
Map<String, Object> inParameters = new HashMap<String, Object>();
inParameters.put(P_TERM, term);
inParameters.put(P_SCAUID, scauid);
inParameters.put(P_PIDM, pidm);
// now execute
Map<String, Object> outputMap = execute(inParameters); // Call on parent class
return outputMap;
}
}
MyRowMapper
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;
import org.springframework.jdbc.core.RowMapper;
public class MyRowMapper implements RowMapper<Map> {
public Map mapRow(ResultSet rs, int paramInt) throws SQLException {
Map response = new HashMap();
// here we populate the data using the returned cursor resultset
// response.setTerm(rs.getString("cursor_col1");
return response;
}
}