您的位置:首页 > 其它

通过jdbc调用存储过程

2009-06-11 16:52 465 查看
/**
	 * 查询结果集
	 * @param page
	 * @param condition
	 * @return
	 */
	@SuppressWarnings({ "deprecation", "unchecked" })
	public Page<Map> getlist(Page<Map> page,HashMap hashMap)
	{
		
		Connection conn=null;  
		ResultSet rs=null;
		CallableStatement cstmt=null;
		int sum=1000;
		try 
		{
			conn=SessionFactoryUtils.getDataSource(simpleHibernateTemplate.getSessionFactory()).getConnection();
			String sql = "{ call sp_TotalAccount(?,?) }";//设置存储过程及参数
			cstmt=conn.prepareCall(sql);
			cstmt.setString(1, "2008-01-01");//设置参数
			cstmt.setString(2,"2009-01-01");
			rs = cstmt.executeQuery();//返回结果集
					
			//封装resultSet数据 ,利用ResultSetMetaData对象可获得表的结构 
			ResultSetMetaData rsmd=(ResultSetMetaData) rs.getMetaData(); 
			List<Map> list=new ArrayList<Map>(); 
			while(rs.next())
			{
				//循环表 
				//每行记录放到一个map里! 
				Map map=new HashMap();//每行记录放到一个 
				for(int i=1;i<=rsmd.getColumnCount();i++) 
				{ 
					map.put(rsmd.getColumnName(i), rs.getObject(i)); 
				} 
				list.add(map); 
			} 
			page.setResult(list);
			page.setTotalCount(sum);
			
			return page;
		}
		catch (SQLException e) 
		{
			// TODO Auto-generated catch block
			e.printStackTrace();
			return null;
		}
		finally
		{//保存能关掉所有数据连接
			try
			{
				if(rs!=null)
				{
					rs.close();
				}				
			}
			catch(Exception e)
			{
				
			}
			
			try
			{
				if(cstmt!=null)
				{
					cstmt.close();
				}				
			}
			catch(Exception e)
			{
				
			}
			
			try
			{
				if(conn!=null)
				{
					conn.close();
				}				
			}
			catch(Exception e)
			{
				
			}
		}
	}






有进要通过jdbc调用存储过程,来说一下怎样来实现?
 在我见过的有两种情况:
1)返回一个结果集(ResultSet)。
  2)返回一个特定的值。
 下面来详细的说明。
 1)返回一个结果集(ResultSet),这种类似通常的处理结果集
    如果事先就有一个类似如下的procedure CREATE PROCEDURE getShipQuantity @jsid int AS
SELECT jf_js_id,SUM(jf_ship_quantity) AS shipqty
FROM tjobsheet_finish f WHERE (jf_js_id=@jsid)
GROUP BY jf_js_id 那么我们将通过如下的代码来调用   String sql = "{ call getShipQuantity(?) }";
Connection con = getSession().connection();//通过hibernate得到的连接
ResultSet rs = null;
BigDecimal shipQuantity = new BigDecimal(0);
try{
CallableStatement cs = con.prepareCall(sql);
cs.setInt(1,jsoId);//设置输入参数
rs = cs.executeQuery();//返回结果集
if(rs.next()){
shipQuantity = new BigDecimal(rs.getDouble(2));
}
logger.debug("shipQuantity --------------------- "+shipQuantity);
}catch(Exception e){
logger.debug(e);
}
2)返回一个特定的值。也就是说,在procedure的定义中已经用output输出参数了。请看下面的proceduer
create procedure getSingleWgt @@singleWgt numeric(8,3) output,@jsnum varchar(11) = '0000-0480'
as
declare @stwgt numeric(8,3)
select @stwgt = sum(b.stwgt)
from js as a
inner join jsactdtl as b
on a.jsnum = b.jsnum
where a.completion = 1
and b.stflag = 22
and a.jsnum = @jsnum
select @@singleWgt = (@stwgt/orderedqty) from js where jsnum = @jsnum
那么我们将通过如下的代码来调用
String sql = "{ call getSingleWgt(?,?) }";
Connection con = getSession().connection();//得到connection
try{
CallableStatement cs = con.prepareCall(sql);//通过它来执行sql
cs.registerOutParameter(1,java.sql.Types.FLOAT);//注册输出参数
cs.setString(2,shipment.getJsnum());//指出输入参数

if(cs.execute()){//执行
float output = cs.getFloat(1);//返回值
}
}catch(Exception e){
logger.debug(e);
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: