<div class="codetitle"><a style="CURSOR: pointer" data="62853" class="copybut" id="copybut62853" onclick="doCopy('code62853')"> 代码如下:<div class="codebody" id="code62853"> declare @TotalCount int declare @TotalPageCount int exec P_viewPage_A 'type1','','id','','id asc',1,4,3,@TotalCount output,@TotalPageCount output select from type1 Create PROC P_viewPage_A / nzperfect [no_mIss] 高效通用分页存储过程(双向检索) 2007.5.7 QQ:34813284 敬告:适用于单一主键或存在唯一值列的表或视图 ps:Sql语句为8000字节,调用时请注意传入参数及sql总长度不要超过指定范围 / @TableName VARCHAR(200),--表名 @FieldList VARCHAR(2000),--显示列名,如果是全部字段则为 @PrimaryKey VARCHAR(100),--单一主键或唯一值键 @Where VARCHAR(2000),--查询条件 不含'where'字符,如id>10 and len(userid)>9 @Order VARCHAR(1000),--排序 不含'order by'字符,如id asc,userid desc,必须指定asc或desc --注意当@SortType=3时生效,记住一定要在最后加上主键,否则会让你比较郁闷 @SortType INT,--排序规则 1:正序asc 2:倒序desc 3:多列排序方法 @RecorderCount INT,--记录总数 0:会返回总记录 @PageSize INT,--每页输出的记录数 @PageIndex INT,--当前页数 @TotalCount INT OUTPUT,--记返回总记录 @TotalPageCount INT OUTPUT --返回总页数 AS SET NOCOUNT ON IF ISNULL(@TotalCount,'') = '' SET @TotalCount = 0 SET @Order = RTRIM(LTRIM(@Order)) SET @PrimaryKey = RTRIM(LTRIM(@PrimaryKey)) SET @FieldList = REPLACE(RTRIM(LTRIM(@FieldList)),' ','') WHILE CHARINDEX(',',@Order) > 0 OR CHARINDEX(',@Order) > 0 BEGIN SET @Order = REPLACE(@Order,') SET @Order = REPLACE(@Order,') END IF ISNULL(@TableName,'') = '' OR ISNULL(@FieldList,'') = '' OR ISNULL(@PrimaryKey,'') = '' OR @SortType < 1 OR @SortType >3 OR @RecorderCount < 0 OR @PageSize < 0 OR @PageIndex < 0 BEGIN PRINT('ERR_00') RETURN END IF @SortType = 3 BEGIN IF (UPPER(RIGHT(@Order,4))!=' ASC' AND UPPER(RIGHT(@Order,5))!=' DESC') BEGIN PRINT('ERR_02') RETURN END END DECLARE @new_where1 VARCHAR(1000) DECLARE @new_where2 VARCHAR(1000) DECLARE @new_order1 VARCHAR(1000) DECLARE @new_order2 VARCHAR(1000) DECLARE @new_order3 VARCHAR(1000) DECLARE @Sql VARCHAR(8000) DECLARE @SqlCount NVARCHAR(4000) IF ISNULL(@where,'') = '' BEGIN SET @new_where1 = ' ' SET @new_where2 = ' WHERE ' END ELSE BEGIN SET @new_where1 = ' WHERE ' + @where SET @new_where2 = ' WHERE ' + @where + ' AND ' END IF ISNULL(@order,'') = '' OR @SortType = 1 OR @SortType = 2 BEGIN IF @SortType = 1 BEGIN SET @new_order1 = ' ORDER BY ' + @PrimaryKey + ' ASC' SET @new_order2 = ' ORDER BY ' + @PrimaryKey + ' DESC' END IF @SortType = 2 BEGIN SET @new_order1 = ' ORDER BY ' + @PrimaryKey + ' DESC' SET @new_order2 = ' ORDER BY ' + @PrimaryKey + ' ASC' END END ELSE BEGIN SET @new_order1 = ' ORDER BY ' + @Order END IF @SortType = 3 AND CHARINDEX(','+@PrimaryKey+' ','+@Order)>0 BEGIN SET @new_order1 = ' ORDER BY ' + @Order SET @new_order2 = @Order + ',' SET @new_order2 = REPLACE(REPLACE(@new_order2,'ASC,'{ASC},'),'DESC,'{DESC},') SET @new_order2 = REPLACE(REPLACE(@new_order2,') SET @new_order2 = ' ORDER BY ' + SUBSTRING(@new_order2,LEN(@new_order2)-1) IF @FieldList <> '' BEGIN SET @new_order3 = REPLACE(REPLACE(@Order + ',') SET @FieldList = ',' + @FieldList WHILE CHARINDEX(',@new_order3)>0 BEGIN IF CHARINDEX(SUBSTRING(','+@new_order3,CHARINDEX(',@new_order3)),'+@FieldList+',')>0 BEGIN SET @FieldList = @FieldList + ',' + SUBSTRING(@new_order3,@new_order3)) END SET @new_order3 = SUBSTRING(@new_order3,@new_order3)+1,LEN(@new_order3)) END SET @FieldList = SUBSTRING(@FieldList,2,LEN(@FieldList)) END END SET @SqlCount = 'SELECT @TotalCount=COUNT(),@TotalPageCount=CEILING((COUNT()+0.0)/' + CAST(@PageSize AS VARCHAR)+') FROM ' + @TableName + @new_where1 IF @RecorderCount = 0 BEGIN EXEC SP_EXECUTESQL @SqlCount,N'@TotalCount INT OUTPUT,@TotalPageCount INT OUTPUT', @TotalCount OUTPUT,@TotalPageCount OUTPUT END ELSE BEGIN SELECT @TotalCount = @RecorderCount END IF @PageIndex > CEILING((@TotalCount+0.0)/@PageSize) BEGIN SET @PageIndex = CEILING((@TotalCount+0.0)/@PageSize) END IF @PageIndex = 1 OR @PageIndex >= CEILING((@TotalCount+0.0)/@PageSize) BEGIN IF @PageIndex = 1 --返回第一页数据 BEGIN SET @Sql = 'SELECT TOP ' + STR(@PageSize) + ' ' + @FieldList + ' FROM ' + @TableName + @new_where1 + @new_order1 END IF @PageIndex >= CEILING((@TotalCount+0.0)/@PageSize) --返回最后一页数据 BEGIN SET @Sql = 'SELECT TOP ' + STR(@PageSize) + ' ' + @FieldList + ' FROM (' + 'SELECT TOP ' + STR(ABS(@PageSize@PageIndex-@TotalCount-@PageSize)) + ' ' + @FieldList + ' FROM ' + @TableName + @new_where1 + @new_order2 + ' ) AS TMP ' + @new_order1 END END ELSE BEGIN IF @SortType = 1 --仅主键正序排序 BEGIN IF @PageIndex <= CEILING((@TotalCount+0.0)/@PageSize)/2 --正向检索 BEGIN SET @Sql = 'SELECT TOP ' + STR(@PageSize) + ' ' + @FieldList + ' FROM ' + @TableName + @new_where2 + @PrimaryKey + ' > ' + '(SELECT MAX(' + @PrimaryKey + ') FROM (SELECT TOP ' + STR(@PageSize(@PageIndex-1)) + ' ' + @PrimaryKey + ' FROM ' + @TableName + @new_where1 + @new_order1 +' ) AS TMP) '+ @new_order1 END ELSE --反向检索 BEGIN SET @Sql = 'SELECT TOP ' + STR(@PageSize) + ' ' + @FieldList + ' FROM (' + 'SELECT TOP ' + STR(@PageSize) + ' ' + @FieldList + ' FROM ' + @TableName + @new_where2 + @PrimaryKey + ' < ' + '(SELECT MIN(' + @PrimaryKey + ') FROM (SELECT TOP ' + STR(@TotalCount-@PageSize@PageIndex) + ' ' + @PrimaryKey + ' FROM ' + @TableName + @new_where1 + @new_order2 +' ) AS TMP) '+ @new_order2 + ' ) AS TMP ' + @new_order1 END END IF @SortType = 2 --仅主键反序排序 BEGIN IF @PageIndex <= CEILING((@TotalCount+0.0)/@PageSize)/2 --正向检索 BEGIN SET @Sql = 'SELECT TOP ' + STR(@PageSize) + ' ' + @FieldList + ' FROM ' + @TableName + @new_where2 + @PrimaryKey + ' < ' + '(SELECT MIN(' + @PrimaryKey + ') FROM (SELECT TOP ' + STR(@PageSize(@PageIndex-1)) + ' ' + @PrimaryKey +' FROM '+ @TableName + @new_where1 + @new_order1 + ') AS TMP) '+ @new_order1 END ELSE --反向检索 BEGIN SET @Sql = 'SELECT TOP ' + STR(@PageSize) + ' ' + @FieldList + ' FROM (' + 'SELECT TOP ' + STR(@PageSize) + ' ' + @FieldList + ' FROM ' + @TableName + @new_where2 + @PrimaryKey + ' > ' + '(SELECT MAX(' + @PrimaryKey + ') FROM (SELECT TOP ' + STR(@TotalCount-@PageSize@PageIndex) + ' ' + @PrimaryKey + ' FROM ' + @TableName + @new_where1 + @new_order2 +' ) AS TMP) '+ @new_order2 + ' ) AS TMP ' + @new_order1 END END IF @SortType = 3 --多列排序,必须包含主键,且放置最后,否则不处理 BEGIN IF CHARINDEX(',' + @PrimaryKey + ' ',' + @Order) = 0 BEGIN PRINT('ERR_02') RETURN END IF @PageIndex <= CEILING((@TotalCount+0.0)/@PageSize)/2 --正向检索 BEGIN SET @Sql = 'SELECT TOP ' + STR(@PageSize) + ' ' + @FieldList + ' FROM ( ' + 'SELECT TOP ' + STR(@PageSize) + ' ' + @FieldList + ' FROM ( ' + ' SELECT TOP ' + STR(@PageSize@PageIndex) + ' ' + @FieldList + ' FROM ' + @TableName + @new_where1 + @new_order1 + ' ) AS TMP ' + @new_order2 + ' ) AS TMP ' + @new_order1 END ELSE --反向检索 BEGIN SET @Sql = 'SELECT TOP ' + STR(@PageSize) + ' ' + @FieldList + ' FROM ( ' + 'SELECT TOP ' + STR(@PageSize) + ' ' + @FieldList + ' FROM ( ' + ' SELECT TOP ' + STR(@TotalCount-@PageSize @PageIndex+@PageSize) + ' ' + @FieldList + ' FROM ' + @TableName + @new_where1 + @new_order2 + ' ) AS TMP ' + @new_order1 + ' ) AS TMP ' + @new_order1 END END END EXEC(@Sql) GO
如何用vc#调用上面的存储过程 <div class="codetitle"><a style="CURSOR: pointer" data="54567" class="copybut" id="copybut54567" onclick="doCopy('code54567')"> 代码如下:<div class="codebody" id="code54567"> private void fyDB() { DataTable dt = new DataTable(); string con = System.Configuration.ConfigurationSettings.AppSettings["connectionstring"]; SqlConnection conn = new SqlConnection(con); SqlCommand comm = new SqlCommand("P_viewPage_A",conn); //建立SqlCommand对象 comm.CommandType = CommandType.StoredProcedure; //设置SqlCommand对象执行类型为存储过程 comm.Parameters.Add("@TableName",SqlDbType.VarChar,200); //向Parameters参数列表添加参数 comm.Parameters.Add("@FieldList",2000); comm.Parameters.Add("@PrimaryKey",100); comm.Parameters.Add("@where",2000); comm.Parameters.Add("@Order",1000); comm.Parameters.Add("@SortType",SqlDbType.Int); comm.Parameters.Add("@RecorderCount",SqlDbType.Int); comm.Parameters.Add("@PageSize",SqlDbType.Int); comm.Parameters.Add("@PageIndex",SqlDbType.Int); comm.Parameters.Add("@TotalCount",SqlDbType.Int); comm.Parameters.Add("@TotalPageCount",SqlDbType.Int); comm.Parameters["@TotalCount"].Direction = ParameterDirection.Output; //设置参数的输出类型 comm.Parameters["@TotalPageCount"].Direction = ParameterDirection.Output; //设置参数的输出类型 comm.Parameters["@TableName"].Value = "type1";//表名 comm.Parameters["@FieldList"].Value = "";//显示列名,如果是全部字段则为* comm.Parameters["@PrimaryKey"].Value = "id";//单一主键或唯一值键 comm.Parameters["@where"].Value = "";//查询条件 不含'where'字符,如id>10 and len(userid)>9 comm.Parameters["@Order"].Value = "id asc";//排序 不含'order by'字符,如id asc,userid desc,必须指定asc或desc comm.Parameters["@SortType"].Value = 1;//排序规则 1:正序asc 2:倒序desc 3:多列排序方法 comm.Parameters["@RecorderCount"].Value = 0;//记录总数 0:会返回总记录 comm.Parameters["@PageSize"].Value = 2;//每页输出的记录数 int id1; if (Request.QueryString["id"] == null) id1 = 1; else id1 = Convert.ToInt32(Request.QueryString["id"]); comm.Parameters["@PageIndex"].Value = id1;//当前页数 conn.Open(); // SqlDataReader asr = comm.ExecuteReader(); //int dtr = (int)comm.ExecuteScalar(); SqlDataReader sdr = comm.ExecuteReader(); int i=0; //while (sdr.Read()) //{ // dt.Rows[i][0] = sdr.GetValue(0); // dt.Rows[i][1] = sdr.GetValue(1); //} dt = ConvertDataReaderToDataTable(sdr); GridView1.DataSource = dt; GridView1.DataBind(); // dt.Rows[0][0]; sdr.Close(); // Response.Write(dtr); Response.Write(comm.Parameters["@TotalCount"].Value + " "); Response.Write(comm.Parameters["@TotalPageCount"].Value + " "); // if((Int32)comm.Parameters["RETURN_VALUE"].Value==0) conn.Close(); //string conStr = System.Configuration.ConfigurationSettings.AppSettings["connectionstring"]; //SqlConnection connection = new SqlConnection(conStr); //DataSet dataSet = new DataSet(); //connection.Open(); //SqlDataAdapter sqlDA = new SqlDataAdapter(); //sqlDA.SelectCommand = BuildQueryCommand(connection,"P_viewPage_A",parameters); //sqlDA.Fill(dataSet,tableName); //connection.Close(); //return dataSet; } #region 将DataReader 转为 DataTable /// /// 将DataReader 转为 DataTable /// /// <param name="DataReader">DataReader public static DataTable ConvertDataReaderToDataTable(SqlDataReader reader) { try { DataTable objDataTable = new DataTable(); int intFieldCount = reader.FieldCount; for (int intCounter = 0; intCounter < intFieldCount; ++intCounter) { objDataTable.Columns.Add(reader.GetName(intCounter),reader.GetFieldType(intCounter)); } objDataTable.BeginLoadData(); object[] objValues = new object[intFieldCount]; while (reader.Read()) { reader.GetValues(objValues); objDataTable.LoadDataRow(objValues,true); } reader.Close(); objDataTable.EndLoadData(); return objDataTable; } catch (Exception ex) { throw new Exception("转换DataReader为DataTable出错!",ex); } } #endregion
(编辑:李大同)
【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!
|