c# oracle 存储过程分页查询

简单贴出主要部分代码。

.sql

--定义包

create or replace package PKG_G_SelectSp as type p_G_Cursor is ref cursor;

procedure P_G_GetPagingData(

q_Sql varchar2,

rowCountPage number,

indexNowPage number,

totalRows out number,

totalPages out number,

p_corsor out PKG_G_SelectSp.p_G_Cursor

);

end PKG_G_SelectSp;

--分页查询数据存储过程

create or replace procedure P_G_GetPagingData(

q_Sql varchar2,

rowCountPage number, --每页面记录条数

indexNowPage number, --当前页码

totalRows out number, --总记录数

totalPages out number, --总页数

p_corsor out PKG_G_SelectSp.p_G_Cursor --游标,用于返回结果集

) as

--分页起始记录编号

startRowNum number:=(indexNowPage-1)*rowCountPage+1;

--分页结束记录编号

endRowNum number:=indexNowPage*rowCountPage;

--查询数据sql字符串

s_sql varchar2(5000);

sc_sql varchar2(5000);

begin

s_sql:='select * from (select t1.*,rownum rn from ('||q_Sql||') t1 where rownum <= '||endRowNum||' )where rn >='||startRowNum;

--打开游标,关联Sql语句

open p_corsor for s_sql;

--查询记录总数

sc_sql:='select count(*) from('||q_Sql|| ')';

execute immediate sc_sql into totalRows;

--计算总页数

if mod(totalRows,rowCountPage)=0 then

totalPages:=totalRows/rowCountPage;

else

totalPages:=totalRows/rowCountPage+1;

end if;

end;

.aspx

public OracleConnection oConnection;

public OracleCommand oCommand;

public OracleDataReader oDataReader;

public int totalRows = 0;

public int totalPages = 0;

//连接数据库部分省略....

//定义调用存储过程方法

/// <summary>

/// 调用存储过程查询指定页码记录条数的数据

/// </summary>

/// <param name="q_Sql">基本的数据查询</param>

/// <param name="rowsCountPage">每页显示的记录数</param>

/// <param name="indexNowPage">页码</param>

/// <param name="totalRows">查询总记录数</param>

/// <param name="totalPages">总页数</param>

public void procedureSelectData(string q_Sql, int rowsCountPage, int indexNowPage, ref int totalRows, ref int totalPages) {

try {

this.oCommand = new OracleCommand();

this.oCommand.Connection = this.oConnection;

oCommand.CommandText = "P_G_GetPagingData";

oCommand.CommandType = CommandType.StoredProcedure;

OracleParameter op0 = new OracleParameter("q_Sql", OracleDbType.Varchar2, 2000);

OracleParameter op1 = new OracleParameter("rowCountPage", OracleDbType.Int32, 10);

OracleParameter op2 = new OracleParameter("indexNowPage", OracleDbType.Int32, 10);

OracleParameter op3 = new OracleParameter("totalRows", OracleDbType.Int32, 10);

OracleParameter op4 = new OracleParameter("totalPages", OracleDbType.Int32, 10);

OracleParameter op5 = new OracleParameter("p_corsor", OracleDbType.RefCursor);

op0.Direction = ParameterDirection.Input;

op1.Direction = ParameterDirection.Input;

op2.Direction = ParameterDirection.Input;

op3.Direction = ParameterDirection.Output;

op4.Direction = ParameterDirection.Output;

op5.Direction = ParameterDirection.Output;

op0.Value = q_Sql;

op1.Value = rowsCountPage;

op2.Value = indexNowPage;

oCommand.Parameters.Add(op0);

oCommand.Parameters.Add(op1);

oCommand.Parameters.Add(op2);

oCommand.Parameters.Add(op3);

oCommand.Parameters.Add(op4);

oCommand.Parameters.Add(op5);

this.oDataReader = oCommand.ExecuteReader();

totalRows = Int32.Parse(op3.Value.ToString());

totalPages = int.Parse(op4.Value.ToString());

} catch(Exception) {

}

}

//调用方法

procedureSelectData(sqlStr, 200, 1, ref this.totalRows, ref this.totalPages);