`
sea0108
  • 浏览: 54760 次
  • 性别: Icon_minigender_1
  • 来自: 广州
社区版块
存档分类
最新评论

Java 里Spring如何调用oracle存储过程:OracleCallableSupport

 
阅读更多
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&lt;Map&gt; 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;
		}
	}
}
分享到:
评论

相关推荐

    Spring JdbcTemplate调用Oracle存储过程实现CRUD

    我们将首先编写 Oracle 存储过程,然后编写 Java 代码使用 Spring JdbcTemplate 调用这些存储过程。 Oracle 存储过程 首先,我们编写了两个 Oracle 存储过程:`P_EMP_SELECT` 和 `P_EMP_ADD`。 `P_EMP_SELECT` ...

    springboot mybatis 动态调用oracle存储过程,通过存储过程名称,就能动态调用存储过程、java动态调用or

    能不能写个动态的业务,只输入存储过程名称,自动获取存储过程参数,并且参数的数据从前台传递过来...只根据输入不同的存储过程名称、参数内容,自动调用不同的存储过程。 已经使用在多个项目中 全开源项目 请放心下载

    使用Spring的JdbcTemplate调用Oracle的存储过程

    使用Spring的JdbcTemplate调用Oracle的存储过程

    springboot整合mybatis调用oracle存储过程

    本文将深入探讨如何在Spring Boot项目中整合MyBatis,实现调用Oracle存储过程并处理游标返回的数据。 首先,我们需要在Spring Boot项目中引入相关的依赖。在`pom.xml`文件中添加Oracle JDBC驱动(ojdbc66-oracle...

    Springboot调用Oracle存储过程的几种方式.docx

    在Spring Boot应用中,调用Oracle数据库的存储过程有多种方式。本文主要介绍三种方法,包括使用`entityManagerFactory.unwrap(SessionFactory.class).openSession()`、直接使用`EntityManager`的`...

    spring mybatis 调用oracle存储过程

    本文将深入探讨如何在Spring和MyBatis集成环境中调用Oracle数据库的存储过程,包括无返回值、返回结果集以及返回多个结果的情况。 首先,让我们理解基础概念。Spring是一个全面的后端开发框架,它提供了依赖注入、...

    Spring boot调用Oracle存储过程的两种方式及完整代码

    Spring Boot 调用 Oracle 存储过程的两种方式及完整代码 在本文中,我们将为大家介绍 Spring Boot 调用 Oracle 存储过程的两种方式,并提供完整的代码示例。本文主要解决了在 Spring Boot 项目中调用 Oracle 存储...

    java调用oracle存储过程

    Java调用Oracle存储过程是数据库操作中常见的任务,特别是在需要执行复杂业务逻辑或者批量处理数据时。本篇文章将详细介绍如何通过Java与Oracle数据库交互,调用存储过程,并提供几个简单的实例帮助新手理解。 首先...

    Spring访问传入数组参数的Oracle存储过程

    当我们谈论`Spring`访问传入数组参数的`Oracle`存储过程时,我们实际上是在探讨如何利用Java的Spring框架与Oracle数据库进行高级交互。Spring是一个广泛使用的开源框架,它简化了企业级Java应用的开发,而Oracle...

    项目里用到用java写oracle的存储过程,做个备份

    总之,使用Java调用Oracle存储过程进行数据库备份是一种常见的实践,它允许我们在应用程序中灵活地管理复杂的数据库操作,同时确保数据的安全性。结合适当的备份策略和工具,可以构建出高效可靠的数据库备份系统。

    Mybatis传list参数调用oracle存储过程的解决方法

    "Mybatis调用Oracle存储过程传List参数解决方法" Mybatis是当前最流行的持久层框架之一,它提供了强大的数据访问和操作功能。但是,如何将List类型参数传递给Oracle存储过程,实现批量插入数据却是一个棘手的问题,...

    初学SpringCloud连接Oracle数据库

    在初学SpringCloud的过程中,与Oracle数据库的连接是构建分布式系统的一个重要环节。SpringCloud作为一个微服务框架,提供了丰富的服务治理功能,而数据库作为数据存储的核心,与SpringBoot的集成使得我们可以轻松...

    oracle 触发器实时调用java 中http接口

    总之,"Oracle触发器实时调用Java中HTTP接口"是一个数据库与应用程序实时通信的示例,涉及Oracle的触发器、存储过程和UTL_HTTP包,以及Java HTTP服务器的设计和实现。这样的设计需要对Oracle PL/SQL和Java网络编程有...

    jdbc连接oracle,执行存储过程,带数据库存储过程

    在给出的“简单的存储过程.txt”文件中,可能包含了一个示例存储过程的定义和如何通过JDBC调用它的Java代码。例如,一个存储过程可能用于插入数据: ```sql CREATE OR REPLACE PROCEDURE insert_user ( p_username...

    spring mvc + mybatis 调用mysql 存储过程

    本文将详细讲解如何在Spring MVC和MyBatis集成的项目中调用MySQL存储过程。 首先,让我们理解存储过程的概念。存储过程是在数据库中预编译的一组SQL语句,可以包含输入、输出和内部参数,能够执行复杂的业务逻辑。...

    spring-oracle-stored-proc:SpringBoot Oracle存储过程演示项目

    我们可以通过几种不同的方式调用Oracle存储过程。 使用 使用javax.persistence 。 我们在这种情况下使用了这种方法无论我们选择哪种方式,在使用spring-data时都应该设置一些关键方面/属性(尤其是当我们不让Spring...

Global site tag (gtag.js) - Google Analytics