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

spring中调用存储过程

阅读更多

org.springframework.jdbc.object.StoredProcedure是对应存储过程调用的操作对象,它通过其父类org.springframework.jdbc.object.SqlCall获得相应的底层API支持(CallableStatementCreator), 然后在此基础之上构建了调用存储过程的执行方法。

StoredProcedure是抽象类,所以需要实现相应子类以封装对特定存储过程的调用,还记得我们在讲解JdbcTemplate调用存储过程时候定义的存储过程吗?

CREATE PROCEDURE CountTable(IN tableName varchar(1000),OUT sqlStr varchar(1000) , INOUT v INT)
BEGIN
    set @flag = v;
    set @sql = CONCAT('select count(*) into @res from ' , tableName , ' where ACTIVE_FLAG=?');
    PREPARE stmt FROM @sql;
    EXECUTE stmt using @flag;
    DEALLOCATE PREPARE stmt;
    set v = @res;
    set sqlStr = @sql;
END
						

通过继承StoredProcedure,我们可以为该存储过程的调用提供一个对应的操作对象:

public class CountTableStoredProcedure extends StoredProcedure {
	
	private static final String PROCEDURE_NAME = "CountTable";
	
	public static final String IN_PARAMETER_NAME = "tableName";
	public static final String OUT_PARAMETER_NAME = "sqlStr";
	public static final String INOUT_PARAMETER_NAME = "v";
	
	public CountTableStoredProcedure(DataSource dataSource)
	{
		super(dataSource,PROCEDURE_NAME);
		// setFunction(true);
		declareParameter(new SqlParameter(IN_PARAMETER_NAME,Types.VARCHAR));
		declareParameter(new SqlOutParameter(OUT_PARAMETER_NAME,Types.VARCHAR));
		declareParameter(new SqlInOutParameter(INOUT_PARAMETER_NAME,Types.INTEGER));
		compile();
	}
	
	public CountTableResult doCountTable(String tableName,Integer v)
	{
		Map paraMap = new HashMap();
		paraMap.put(IN_PARAMETER_NAME, tableName);
		paraMap.put(INOUT_PARAMETER_NAME, v);
		
		Map resultMap = execute(paraMap);
		
		CountTableResult result = new CountTableResult();
		result.setSql((String)resultMap.get(OUT_PARAMETER_NAME));
		result.setCount((Integer)resultMap.get(INOUT_PARAMETER_NAME));
		return result;
	}
}
						

关于该存储过程操作对象,部分细节我们有必要关注一下:

  • 存储过程操作对象对应的SQL是存储过程的名称,而不是真正意义上的SQL语句,当我们调用compile方法的时候, StoredProcedure的父类SqlCall会根据你提供的存储过程名称拼装真正意义上的符合SQL92标准的存储过程调用语句, 类似于“{ call CountTable(?,?,?) }”的形式。

    因为我们的CountTableStoredProcedure只针对CountTable存储过程调用,所以,该存储过程的名称我们在类一开始就声明为常量:

    private static final String PROCEDURE_NAME = "CountTable";
    如果有多个存储过程的参数顺序相同,结果处理也一样的话,你也可以将存储过程的名称声明为变量,这完全要取决于具体的应用场景。

     

  • 在构造方法中,我们将“setFunction(true);”注释掉了,因为我们调用的CountTable不是一个Function, 如果你要调用的存储过程类型为Function的话,你需要通过该方法将“function”的值设置为true,以告知StoredProcedure在处理调用的时候要区别对待。

  • 在complie之前通过declareParameter声明参数,这几乎是雷打不动的惯例,不过,在StoredProcedure中使用declareParameter的时候却要有所注意了:

    • 针对存储过程参数类型为IN,OUT和INOUT不同,declareParameter接受的参数类型也应该是SqlParameter,SqlOutParameter和SqlInOutParameter;

    • SqlParameter,SqlOutParameter和SqlInOutParameter的相应实例在构造的时候,必须指定对应的参数名称,因为在调用存储过程的时候, 需要根据名称传入参数,更需要根据名称取得调用结果;

     

  • StoredProcedure提供了execute方法执行存储过程调用,通过Map的形式传入调用所需要的IN或者INOUT类型的参数值, 所以,在构建参数Map的时候,该Map中的Key应该与declareParameter时候声明的参数名称相同; 另外,execute执行后返回的结果也是Map形式,从该结果Map中取得具体的结果值的时候,也是通过declareParameter中声明的OUT/INOUT参数名作为key来获取的, 所以,这就是我们将各个参数的名称在类定义的开始声明为常量的原因:

    public static final String IN_PARAMETER_NAME = "tableName";
    public static final String OUT_PARAMETER_NAME = "sqlStr";
    public static final String INOUT_PARAMETER_NAME = "v";
    									
    无论是输入参数Map还是输出参数结果对应的Map,他们中的Key应该与通过declareParameter方法声明的参数名称一一对应。

     

通过扩展StoredProcedure,我们不但封装了参数的声明和结果的提取,我们还为调用方提供了强类型的调用方法, 现在,调用方可以通过doCountTable方法的强类型参数声明传入参数值,并取得强类型的CountTableResult对象作为结果,而不是泛泛的一个Map。

 

对于存储过程的调用者来说,它的代码现在可以简洁到两行代码:

// DataSource dataSource = ...;
CountTableStoredProcedure storedProcedure = new CountTableStoredProcedure(dataSource);
CountTableResult          result          = storedProcedure.doCountTable("tableName",1);
...
						

漂亮多了,不是吗?

 

StoredProcedure提供了两个execute方法执行存储过程的调用,一个就是我们刚才使用的通过Map提供输入参数的execute方法,另一个则是使用ParameterMapper类型提供输入参数的execute方法。 那么,为什么要提供这个使用ParameterMapper类型提供输入参数的execute方法那?

ParameterMapper定义的callback方法暴露了相应的Connection,如果说在构造输入参数列表的时候,必须用到Connection的话, ParameterMapper恰好可以提供支持。比如,Oracle中定义的一存储过程,接收数组类型作为参数,而在oracle中,你只能通过Oracle.sql.ARRAY和相应的Oracle.sql.ArrayDescriptor来定义数组类型的参数, ARRAY和ArrayDescriptor都需要用到相应的Connection进行构造。所以,对于Oracle中需要使用数组传入参数的存储过程来说,我们可以通过如下类似代码进行调用:

public class OracleStoredProcedure
{
	...
	
	public Map call(...)
	{
		ParameterMapper paramMapper = new ParameterMapper(){

			public Map createMap(Connection connection) throws SQLException {
				Map inMap = new HashMap();
				...
				Integer[] params = new Integer[]{new Integer(1),new Integer(2)};
				ArrayDescriptor desc = new ArrayDescriptor("numbers", connection);
				ARRAY nums = new ARRAY(desc, connection, params);
				inMap.put("ArrayParameterName", nums);
				...
				return inMap;
			}};
		
		return execute(paramMapper);
	}
}
						

当然啦,我们的CountTableStoredProcedure在调用存储过程的时候也可以使用ParameterMapper传入相应的调用参数,只不过,ParameterMapper的createMap方法暴露的Connection对于我们来说没有太大用处罢了。

分享到:
评论
3 楼 wgcniler 2012-06-16  
请问如果传到存储过程的参数是一个嵌套表的话该怎么写?

自定义的oracle对象类型为:
create or replace
TYPE passenger_trip_condition AS OBJECT(
    ticket_no                   VARCHAR2(20),
    departure_date              VARCHAR2(10),
    departure_airport_code      VARCHAR2(3),
    arrival_airport_code        VARCHAR2(3)
    );

我自定义了一个嵌套表:
create or replace
TYPE psg_trip_condition_table AS TABLE OF passenger_trip_condition;

存储过程为:

create or replace
PROCEDURE update_psg_trip_proc (V_ARRAY IN psg_trip_condition_table) IS
BEGIN
...
END update_psg_trip_proc;
以上的存储过程应该怎么用spring调用?
2 楼 wgcniler 2012-06-16  
请问如果传到存储过程的参数是ARRAY,但ARRAY的元素不是基本类型(varchar,number之类)而是oracle的复杂类型(自定义的oracle对象类型)的话该怎么写?
1 楼 zglxx2004 2008-12-25  
请问:
如果是个CLOB型的参数该怎么获取,比如
declareParameter(new SqlInOutParameter           (INOUT_PARAMETER_NAME,Types.CLOB));

原文为:(String)resultMap.get(OUT_PARAMETER_NAME)


相关推荐

    Spring Data JPA调用存储过程实例代码

    每个 `@NamedStoredProcedureQuery` 都包含 `name`(在JPA中调用存储过程时使用的名字)、`procedureName`(实际的存储过程名称)以及 `parameters`(存储过程参数列表),通过 `@StoredProcedureParameter` 指定...

    MyBatis调用存储过程

    在数据库管理中,存储过程是一种预编译的SQL语句集合,它...通过以上步骤,你可以成功地在MyBatis中调用存储过程,并处理其返回的结果。记得根据实际情况调整XML映射文件和Java代码,以适应不同的存储过程和业务需求。

    springmvc+spring+hibernate整合全注解

    在Spring中调用存储过程,可以使用JdbcTemplate或NamedParameterJdbcTemplate。例如: ```java @Autowired private JdbcTemplate jdbcTemplate; public void callProcedure(Long userId) { jdbcTemplate.update(...

    java操作存储过程

    `JdbcTemplate`和`NamedParameterJdbcTemplate`提供了`call()`方法,使得在Spring应用中调用存储过程变得简单。 - `JdbcTemplate`适用于无命名参数的存储过程,而`NamedParameterJdbcTemplate`则适合有命名参数的...

    hiberate SQL Server 2000 存储过程.pdf

    如何在Hibernate中调用存储过程? 在Hibernate中调用SQL Server 2000的存储过程主要有两种方式:通过JDBC直接调用和通过Hibernate的映射文件配置调用。 ##### 2.1 使用JDBC直接调用 示例代码展示了如何在...

    mybatis调用储存过程

    本项目是基于Maven、SpringMVC和MyBatis构建的一个示例,其中重点展示了如何在MyBatis中调用存储过程。以下是对这个主题的详细阐述: 首先,我们需要理解MyBatis是如何工作的。MyBatis允许开发者编写XML或注解形式...

    存储过程.docx

    总结一下,Java中调用存储过程主要涉及到以下几点: 1. 使用`JdbcTemplate`或`SimpleJdbcTemplate`(如果在JDK1.5环境下)来简化操作。 2. 对于无返回值的存储过程,直接使用`execute`方法执行存储过程。 3. 对于有...

    Grails探索之访问存储过程及其事务控制

    本文将详细介绍如何在Grails应用中调用存储过程,并讨论如何在这些操作中实现事务控制。 #### 二、访问存储过程 **1. 配置DataSource** 在Grails项目中,首先要确保已经正确配置了数据源。Grails默认使用...

    JAVA通过MyBatis调用MySql存储过程和函数doc文档合集整理.zip

    3. **在MyBatis中调用存储过程** - 在Mapper接口中定义方法,方法名与存储过程名相同。 - 使用`@SelectProcedure`或在XML映射文件中配置`<select id="procName" statementType="CALLABLE">`,指定存储过程。 - ...

    Hibernate 存储过程的调用.doc

    本篇文章将详细讲解如何在Hibernate中调用存储过程。 首先,我们需要了解Hibernate存储过程调用的基本概念。存储过程可以封装复杂的数据库操作,如多条SQL语句、条件判断等,然后通过一个名称来执行。在Hibernate中...

    Spring JPA学习

    **2.6.2 JPA中调用存储过程** - 可以通过`EntityManager`的`createStoredProcedureQuery`方法调用存储过程。 **2.6.3 用例** - 例子:`entityManager.createQuery("SELECT e FROM Employee e WHERE e.salary > :...

    ssm框架整合视频

    对于MyBatis,可能会讲述如何编写Mapper接口和XML配置,以及如何在Service中调用这些接口执行SQL。 总的来说,这个视频教程是Java Web开发者入门SSM框架的好资源,通过理论与实践相结合的方式,帮助初学者快速理解...

    springmvc+mybatis整合redis

    4. **测试**:建立测试表`user`,包含`id`和`name`字段,编写对应的Mapper接口和SQL语句,然后在Spring MVC的Controller中调用这些接口,确保数据能正确存取并缓存在Redis中。 5. **最佳实践**:在实际项目中,要...

    myEclipse学习手册

    - 在 Java 中调用存储过程通常使用 `CallableStatement` 类,具体实现需参考 JDBC API 文档。 #### 九、Hibernate示例 - **示例代码**:提供了使用 Hibernate 进行基本 CRUD 操作的示例代码,包括配置、创建 ...

    MyBatis教程

    - 在MyBatis中调用存储过程,需要在映射文件中定义并使用`call`关键字。 8. **MyBatis缓存机制**: - **一级缓存**:默认开启,作用于同一个SQLSession之内,提高了单个请求的执行效率; - **二级缓存**:需要...

    springboot2+mybatis+mysql

    学习这个示例项目,你可以了解到如何设置Spring Boot项目,配置MyBatis以连接MySQL数据库,创建Mapper接口和映射文件,以及如何在Service和Controller中调用这些接口进行数据操作。此外,你还可以探索Spring Boot的...

    SpringBoot+mybatis+Oracle整合代码

    5. **Service层设计**:在业务逻辑层,你可以创建Service接口及其实现类,使用@Autowired注解注入Mapper接口,从而在Service中调用数据库操作。 6. **SpringBoot的启动器(Starter)**:SpringBoot的启动器可以帮助...

    Java数据库高级编程宝典

    8. **存储过程与函数**: 学习如何在Java中调用数据库的存储过程和函数,理解其参数传递方式,以及如何处理返回值和结果集,可以提高程序的复杂性和效率。 9. **数据库设计与优化**: 包括数据库模式设计、范式理论、...

    ssm框架做的增删改查demo带数据库完美demo

    通过这个项目,开发者可以学习到如何配置SSM框架,如何编写Mapper接口和XML文件,如何在Service和Controller中调用这些接口,以及如何设计数据库表和编写SQL语句。同时,这也是一个实践项目,有助于提升实际开发技能...

Global site tag (gtag.js) - Google Analytics