SqlServer调用存储过程返回结果集

下载本文档

ID 203459
格式 docx
大小 14.66 KB
约4页
收藏
点赞(0)
海报
举报

/ 4

下载本文档

文本预览下载提示常见问题

USE[zhuhaioa7-4]GO/******Object:StoredProcedure[dbo].[proc_records]ScriptDate:12/26/201420:31:09******/SETANSI_NULLSONGOSETQUOTED_IDENTIFIERONGOALTERprocedure[dbo].[proc_records]asDECLARE@map_tabletable(r_keyvarchar(100),r_valuevarchar(50))DECLARE@type_idvarchar(40)DECLARE@type_namevarchar(50)DECLARE@project_idvarchar(40)DECLARE@project_namevarchar(50)DECLARE@payTypeMoneynumeric(16,2)DECLARE@sumPayTypeMoneynumeric(16,2)BEGINset@payTypeMoney=0set@sumPayTypeMoney=0--查询项目列表DECLAREproject_cursorCURSORforselectep_id,ep_namefromAB_engineeringPhasewhereaccount_id='2'openproject_cursorfetchnextfromproject_cursorinto@project_id,@project_namewhile@@FETCH_STATUS=0begin--查询项目支付类别DECLAREprojectType_cursorCURSORforselectid,namefromT_DataItemwheretypeId='payType'orderbysortascopenprojectType_cursorfetchnextfromprojectType_cursorinto@type_id,@type_namewhile@@FETCH_STATUS=0begin--业务逻辑处理处理内层游标--获取一个项目某一项支付类型的数据--查询一个项目某一支付类别金额select@payTypeMoney=sum(checkProjectPayMoney)fromJiLiangZhiFuwhereprojectId=@project_idandpayType=@type_idgroupbypayType--一个项目某一支付类别金额存入insertinto@map_tablevalues(@project_id+','+@type_id,@payTypeMoney)--一个项目累计支付类别金额set@sumPayTypeMoney=@sumPayTypeMoney+@payTypeMoney--一个项目某一支付类别金额重置为set@payTypeMoney=0fetchnextfromprojectType_cursorinto@type_id,@type_name--内层游标向下移动一行end--插入某一项目各个支付类别的金额合计insertinto@map_tablevalues(@project_id,@sumPayTypeMoney)set@sumPayTypeMoney=0closeprojectType_cursordeallocateprojectType_cursorfetchnextfromproject_cursorinto@project_id,@project_name--内层游标处理结束后,外层游标才继续向下移动一行endcloseproject_cursordeallocateproject_cursorselect*from@map_tableENDpublicMapgetProjectPayMoneyByPayType(){try{return(Map)this.getHibernateTemplate().execute(newHibernateCallback(){publicObjectdoInHibernate(Sessionsession)throwsHibernateException,SQLException{Connectioncon=session.connection();Statementstmt=con.createStatement();CallableStatementcs=con.prepareCall("{callproc_records}");//ResultSetrs=stmt.executeQuery("{callproc_records}");ResultSetrs=cs.executeQuery();Mapmap=newHashMap();while(rs.next()){map.put(rs.getString(1),rs.getString(2));}rs.close();stmt.close();returnmap;}});}catch(org.springframework.dao.DataAccessExceptione){thrownewDataAccessException(e.getMessage(),e);}}

1、当您付费下载文档后，您只拥有了使用权限，并不意味着购买了版权，文档只能用于自身使用，不得用于其他商业用途（如 [转卖]进行直接盈利或[编辑后售卖]进行间接盈利）。
2、本站不对文档的完整性、权威性及其观点立场正确性做任何保证或承诺！文档内容仅供参考，付费前请自行鉴别。
3、如文档内容存在侵犯商业秘密、侵犯著作权等，请点击“举报”。