当前位置:首页 > 开发 > 数据库 > 正文

oracle 分页存储过程

发表于: 2012-09-29   作者:blackproof   来源:转载   浏览次数:
摘要:   查询oracle时,做存储过程实现分页     create or replace procedure query_by_page( pagenum in number, pagesql in varchar2, pagesize in number, pagecount out number, allpagecount out number,

 

查询oracle时,做存储过程实现分页

 

 

create or replace procedure query_by_page(
pagenum in number,
pagesql in varchar2,
pagesize in number,
pagecount out number,
allpagecount out number,
v_cur out querypage.type_cur
) as
v_sql varchar2(3000);
v_pb number;
v_pd number;
begin
     v_sql :='select count(*) from('||pagesql||')';
     execute immediate v_sql into allpagecount; -- 记录数
     pagecount :=ceil(allpagecount/pagesize);  -- 分页数
     v_pd := pagenum*pagesize +pagesize;
     v_pb := v_pd - pagesize + 1;
     v_sql := 'select * from ('||pagesql||') where rn between '||v_pb||' and '||v_pd;
     open v_cur for v_sql;
end;

 其中 这种写法效率不太好,因为内查询遍历了,过多无用的记录,所以后来把v_pd放到了内循环里,这样能减少数据量

 

 把我现在的过程贴出来了,感觉还是不太好,还不如直接传两句sql来的痛快

create or replace procedure query_by_page(
pagenum in number,
pagesql in varchar2,
pagesize in number,
pagecount out number,
allpagecount out number,
v_cur out querypage.type_cur
) as
v_sql varchar2(3000);
v_pb number;
v_pd number;
v_innner_sql varchar2(3000);
begin
     v_sql :='select count(*) from('||pagesql||')';
     execute immediate v_sql into allpagecount; -- 记录数
     pagecount :=ceil(allpagecount/pagesize);  -- 分页数
     v_pd := pagenum*pagesize +pagesize;
     v_pb := v_pd - pagesize + 1;
     if instr(pagesql,'group by') >= 1 then
      v_sql := 'select * from ('||pagesql||') where rn between '||v_pb||' and '||v_pd;
     else if instr(pagesql,'where') >= 1 
      then  v_innner_sql := pagesql||' and rownum <= '||v_pd; v_sql:='select * from ('||v_innner_sql||') where rn >='||v_pb;
     else
       v_innner_sql := pagesql || ' where rownum <= '|| v_pd; v_sql:='select * from ('||v_innner_sql||') where rn >='||v_pb;
     end if;
     end if;
     -- v_sql := 'select * from ('||pagesql||') where rn between '||v_pb||' and '||v_pd; --效率太慢
     open v_cur for v_sql;
end;
 

 

 顺便把java的部分代码贴出来

 

 

/**
 * 分页查询
 * @param sql
 * @param pageNum
 * @param pageSize
 * @param bean
 * @param datasource
 * @throws Exception 
 */
public static PageDataBaseBean queryUsingPaging(String sql,int pageNum,int pageSize,IDataBaseBean bean,SingleDataSource datasource) throws Exception{
	PageDataBaseBean pbl = new PageDataBaseBean();
	Connection conn = null;
	CallableStatement cst = null;
	ResultSet rs = null;
	try {
		conn = datasource.getConnection();
		cst = conn.prepareCall("call query_by_page(?,?,?,?,?,?)");
		cst.setInt(1, pageNum);
		cst.setString(2, sql);
		cst.setInt(3, pageSize);
		cst.registerOutParameter(4, Types.VARCHAR);
		cst.registerOutParameter(5, Types.INTEGER);
		cst.registerOutParameter(6, OracleTypes.CURSOR);
		cst.execute();
		int pageCount = cst.getInt(4);
		int allPageCount = cst.getInt(5);
		rs = (ResultSet) cst.getObject(6);
		//赋值
		pbl.setCurrentPageNum(pageNum);
		pbl.setPageCount(pageCount);
		pbl.setPageSize(pageSize);
		pbl.setTotalSize(allPageCount);
		IDataBaseBean databaseBean =  bean.getClass().newInstance();
		while(rs.next()){
			//赋值TODO
			databaseBean = bean.getClass().newInstance();
			databaseBean.loadFromResultSet(rs);
			pbl.insertBean(databaseBean);
		}
	} catch (Exception e) {
		e.printStackTrace();
	}finally{
		
		if(conn!=null)
			conn.close();
		if(cst!=null)
			cst.close();
		if(rs!=null)
			rs.close();
	}
	return pbl;
}
 

 

PageDataBaseBean是包含分页信息和实体集合的类

    IDataBaseBean是实体bean的接口

 

 

 

oracle 分页存储过程

  • 0

    开心

    开心

  • 0

    板砖

    板砖

  • 0

    感动

    感动

  • 0

    有用

    有用

  • 0

    疑问

    疑问

  • 0

    难过

    难过

  • 0

    无聊

    无聊

  • 0

    震惊

    震惊

编辑推荐
1.首先建一个包pkg_query如下: CREATE OR REPLACE PACKAGE pkg_query AS TYPE cur_query IS REF CU
1 create proc proc_page( 2 @tableName varchar(50),--要进行分页的表名 3 @columnFilds varchar(5
一个通用的分页存储过程实现-SqlServer(附上sql源码,一键执行即刻搭建运行环境) 使用前提   查
create or replace package body cuttoship_lots is procedure prod_run(p_w_day date) as begin de
oracle的存储过程,其实就是执行一个任务,该任务包括了一系列的PL/ SQL语句,存储在数据库中,成为
什么是存储过程? 是一个可以用编程的方式来操作SQL的集合。 存储过程的优点? 执行效率很高,因为
存储过程创建语法: create or replace procedure 存储过程名(param1 in type,param2 out type)
什么是存储过程? 是一个可以用编程的方式来操作SQL的集合。 存储过程的优点? 执行效率很高,因为
存储过程 create or replace procedure pollution_level_judge(pollution_level in hm_pollution_le
oracle的版本为11g 官方描述: http://docs.oracle.com/cd/E11882_01/appdev.112/e25519/procedure.h
版权所有 IT知识库 CopyRight © 2009-2015 IT知识库 IT610.com , All Rights Reserved. 京ICP备09083238号