Usage:
/**
* 调用存储过程返回结果集
*
* @param proc
* 存储过程名称
* @param map
* 存储过程绑定参数
*/
@SuppressWarnings("unchecked")
public List<Map<String, Object>> callProc(String proc,
final Map<String, Object> map) {
OracleCallableSupport support = new OracleCallableSupport(proc, map);
List<Map<String, Object>> result = (List<Map<String, Object>>) getJdbc()
.execute(support.getCreator(), support.getCallback());
return result;
}
OracleCallableSupport.java:
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import oracle.jdbc.OracleTypes;
import org.springframework.jdbc.core.CallableStatementCallback;
import org.springframework.jdbc.core.CallableStatementCreator;
import org.springframework.jdbc.core.ColumnMapRowMapper;
/**
* 支持ORACLE存储过程调用.<br>
* 约定:被调用的存储过程,最后一个参数为OUT SYS_REFCURSOR类型,其他参数为IN类型
*/
public class OracleCallableSupport implements CallableStatementCreator {
static final String SQL_IN_ARGS = "select t.POSITION,t.ARGUMENT_NAME from all_arguments t"
+ " where t.in_out = 'IN' and t.OWNER = %s and t.object_name = upper(:object_name)";
private StoredProc storedProc;
/**
* 存储过程绑定参数
*/
private Map<String, Object> bindParam;
private int resultSetIndex;
/**
* Constructs a callable statement.
*
* @param proc
* The stored procedure's name.
* @param params
* Input parameters.
* @param outResultCount
* count of output result set.
*/
public OracleCallableSupport(String proc, Map<String, Object> bindParam) {
this.bindParam = bindParam;
this.storedProc = new StoredProc(proc);
}
/**
* Get the CallableStatementCreator
*/
public CallableStatementCreator getCreator() {
return this;
}
/**
* Get the CallableStatementCallback
*/
public CallableStatementCallback getCallback() {
return new Callback();
}
protected Map<Integer, String> getInArgs() {
String sql = String.format(SQL_IN_ARGS, this.storedProc.owner);
Map<String, Object> map = new HashMap<String, Object>();
map.put("object_name", this.storedProc.name);
List<Map<String, Object>> args = AbstractDao.DAO.getSimpleJdbc()
.queryForList(sql, map);
Map<Integer, String> result = new HashMap<Integer, String>();
for (Map<String, Object> arg : args) {
int pos = Integer.valueOf(String.valueOf(arg.get("POSITION")));
result.put(pos, String.valueOf(arg.get("ARGUMENT_NAME")));
}
setResultSetIndex(result.size() + 1);
return result;
}
protected int getResultSetIndex() {
return this.resultSetIndex;
}
protected void setResultSetIndex(int index) {
this.resultSetIndex = index;
}
/**
* Returns a callable statement
*
* @param conn
* Connection to use to create statement
* @return cs A callable statement
*/
public CallableStatement createCallableStatement(Connection conn) {
StringBuffer sql = new StringBuffer("call ");
sql.append(storedProc).append("(");
// set input parameters
Map<Integer, String> args = getInArgs();
for (int i = 0; i < args.size(); i++) {
sql.append("?").append(",");
}
// set ountput parameters
sql.append("?").append(")");
CallableStatement cs = null;
try {
cs = conn.prepareCall(sql.toString());
// set the paramters
for (Map.Entry<Integer, String> arg : args.entrySet()) {
cs.setObject(arg.getKey(), this.bindParam.get(arg.getValue()));
}
// set the last parameter is OracleTypes.CURSOR for oracle stored
// procedure
cs.registerOutParameter(getResultSetIndex(), OracleTypes.CURSOR);
} catch (SQLException e) {
throw new DaoException(e);
}
return cs;
}
protected static class StoredProc {
String owner;
String name;
String proc;
StoredProc(String proc) {
this.proc = proc;
int i = proc.indexOf(".");
if (i < 0) {
owner = "user";
name = proc;
} else {
owner = "'" + proc.substring(0, i) + "'";
name = proc.substring(i + 1);
}
}
@Override
public String toString() {
return this.proc;
}
}
/**
*
* The ProcCallableStatementCallback return a result object, for example a
* collection of domain objects.
*
*/
public class Callback implements CallableStatementCallback {
/**
* Constructs a ProcCallableStatementCallback.
*/
Callback() {
}
/**
* Returns a List(Map) collection.
*
* @param cs
* object that can create a CallableStatement given a
* Connection
* @return resultsList: List<Map> a result object returned by the action
*/
public Object doInCallableStatement(CallableStatement cs) {
List<Object> resultList = new ArrayList<Object>();
try {
cs.execute();
ResultSet rs = (ResultSet) cs.getObject(getResultSetIndex());
ColumnMapRowMapper mapper = new ColumnMapRowMapper();
int i = 0;
while (rs.next()) {
Object obj = mapper.mapRow(rs, i++);
resultList.add(obj);
}
rs.close();
} catch (SQLException e) {
throw new DaoException(e);
}
return resultList;
}
}
}
分享到:
相关推荐
我们将首先编写 Oracle 存储过程,然后编写 Java 代码使用 Spring JdbcTemplate 调用这些存储过程。 Oracle 存储过程 首先,我们编写了两个 Oracle 存储过程:`P_EMP_SELECT` 和 `P_EMP_ADD`。 `P_EMP_SELECT` ...
能不能写个动态的业务,只输入存储过程名称,自动获取存储过程参数,并且参数的数据从前台传递过来...只根据输入不同的存储过程名称、参数内容,自动调用不同的存储过程。 已经使用在多个项目中 全开源项目 请放心下载
使用Spring的JdbcTemplate调用Oracle的存储过程
本文将深入探讨如何在Spring Boot项目中整合MyBatis,实现调用Oracle存储过程并处理游标返回的数据。 首先,我们需要在Spring Boot项目中引入相关的依赖。在`pom.xml`文件中添加Oracle JDBC驱动(ojdbc66-oracle...
在Spring Boot应用中,调用Oracle数据库的存储过程有多种方式。本文主要介绍三种方法,包括使用`entityManagerFactory.unwrap(SessionFactory.class).openSession()`、直接使用`EntityManager`的`...
本文将深入探讨如何在Spring和MyBatis集成环境中调用Oracle数据库的存储过程,包括无返回值、返回结果集以及返回多个结果的情况。 首先,让我们理解基础概念。Spring是一个全面的后端开发框架,它提供了依赖注入、...
Spring Boot 调用 Oracle 存储过程的两种方式及完整代码 在本文中,我们将为大家介绍 Spring Boot 调用 Oracle 存储过程的两种方式,并提供完整的代码示例。本文主要解决了在 Spring Boot 项目中调用 Oracle 存储...
Java调用Oracle存储过程是数据库操作中常见的任务,特别是在需要执行复杂业务逻辑或者批量处理数据时。本篇文章将详细介绍如何通过Java与Oracle数据库交互,调用存储过程,并提供几个简单的实例帮助新手理解。 首先...
当我们谈论`Spring`访问传入数组参数的`Oracle`存储过程时,我们实际上是在探讨如何利用Java的Spring框架与Oracle数据库进行高级交互。Spring是一个广泛使用的开源框架,它简化了企业级Java应用的开发,而Oracle...
总之,使用Java调用Oracle存储过程进行数据库备份是一种常见的实践,它允许我们在应用程序中灵活地管理复杂的数据库操作,同时确保数据的安全性。结合适当的备份策略和工具,可以构建出高效可靠的数据库备份系统。
"Mybatis调用Oracle存储过程传List参数解决方法" Mybatis是当前最流行的持久层框架之一,它提供了强大的数据访问和操作功能。但是,如何将List类型参数传递给Oracle存储过程,实现批量插入数据却是一个棘手的问题,...
在初学SpringCloud的过程中,与Oracle数据库的连接是构建分布式系统的一个重要环节。SpringCloud作为一个微服务框架,提供了丰富的服务治理功能,而数据库作为数据存储的核心,与SpringBoot的集成使得我们可以轻松...
总之,"Oracle触发器实时调用Java中HTTP接口"是一个数据库与应用程序实时通信的示例,涉及Oracle的触发器、存储过程和UTL_HTTP包,以及Java HTTP服务器的设计和实现。这样的设计需要对Oracle PL/SQL和Java网络编程有...
在给出的“简单的存储过程.txt”文件中,可能包含了一个示例存储过程的定义和如何通过JDBC调用它的Java代码。例如,一个存储过程可能用于插入数据: ```sql CREATE OR REPLACE PROCEDURE insert_user ( p_username...
本文将详细讲解如何在Spring MVC和MyBatis集成的项目中调用MySQL存储过程。 首先,让我们理解存储过程的概念。存储过程是在数据库中预编译的一组SQL语句,可以包含输入、输出和内部参数,能够执行复杂的业务逻辑。...
我们可以通过几种不同的方式调用Oracle存储过程。 使用 使用javax.persistence 。 我们在这种情况下使用了这种方法无论我们选择哪种方式,在使用spring-data时都应该设置一些关键方面/属性(尤其是当我们不让Spring...