SQLServer2005及以上存储过程分页方法

网络整理 - 08-18

   最近实习期间,项目开发过程中遇到了分页问题,问题如下:

  在项目开发过程中,往往会遇到展示展示内容的问题。当内容数量不多的时候,我们直接用一条“SELECT * FROM ...”将去不内容提取出来也无伤大雅。但是,随着项目的不断扩大,将过多的内容展示在一个页面就显得不合理了,此时,就要用到分页技术。

  其实分页,包括前台分页和后台分页。

  所谓前台分页:就是一次性后天存储设备取出多页数据,传到前台,再分页展示。前台分页的好处是:

  1、当每次去适量数据时,取数据时间并没有太大影响,前台分页展示速度却得到了明显加快,只有当分页到了一定页数,再次从数据库读取时分页才会有明显停顿;

  2、前台分页,减少了数据库的链接访问次数,降低了数据库的负荷。

  其实,今天所分享的主要是后台分页技术。这个分页方法,是在实践中经历了多次惨痛的教训后总结的。

  主要解决了的问题:

  1、按条件查询分页

  2、多列排序分页:分页过程中最后取出数据的顺序可有多列决定

  3、不依赖主键分页(这是之前到网上看到的分页查询遇到的最大瓶颈)

  4、返回查询总记录数,便于分页(在网上看到很多所谓存储过程分页查询,竟然没有返回总记录数,不知道他们是如何实现分页的)

  5、分页放在数据库存储过程中,减轻服务器的负担,个人认为将分页任务交个数据库比较合适:第一可以避免上次代码冗长的分页逻辑;第二分页速度有保证

  本分页查询有这些好处,必然也有其缺陷

  1、查询速度不一定有绝对保证,因为我们的数据量有限,从15000+条数据中进行分页查询是0.158ms,但目前不知数据量扩大以后的查询时间

  2、查询数据库类型是:sqlserver2005及以上

  我们开发的环境是:Visual Studio 2012, SQL Server 2008, 下面是sql存储过程源代码:(注:@sqlStr中不能有排序条件,排序条件一定要放在@sortStr里面!!!下面有一个示例)

?

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 CREATE PROCEDURE [dbo].[FinalSortingAndPaging]   @sqlStr varchar(2000) =  'SELECT  DISTINCT h_year , z_periods, h_periods from FertilizerHeader WHERE 1=1',--完整的sql查询语句, @sortStr varchar(50) = 'h_year desc, z_periods desc',  --查询排序条件 @pageIndex INT = 1, --页号 @pageSize INT = 100 --分页大小   AS BEGIN   -- routine body goes here, e.g.   -- SELECT 'Navicat for SQL Server'       SET NOCOUNT ON;       DECLARE @queryStr nvarchar(2000)     DECLARE @queryRecordStr nvarchar(2000)     DECLARE @recordCount INT --返回的记录总数       SET @queryRecordStr = 'SELECT @recordCount=COUNT(*) FROM ('+@sqlStr+') AS c';       SET @queryStr = 'WITH tempTable AS (SELECT *, Row_number() OVER(ORDER BY '+@sortSt +') AS RowNumber FROM('+@sqlStr+') AS a) SELECT * FROM tempTable WHERE RowNumber BETWEEN '+ CAST((@pageIndex-1)*@pageSize + 1 AS VARCHAR(10))+' AND '+ CAST(@pageIndex * @pageSize AS VARCHAR(10)); END       EXEC sp_executesql @queryRecordStr, N'@recordCount INT OUTPUT ', @recordCount OUTPUT     EXEC(@queryStr)     --SELECT @recordCount AS RecordCount     RETURN @recordCount

  下面再贴一个C#访问该存储过程的接口:

?

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 private static readonly string connectionString = ConfigurationManager.                     ConnectionStrings["XXXX"].ToString();   public DataSet FinalSortingAndPagingQuery(string sqlStr, string sortStr,                 int pageIndex, int pageSize,out int recordCount) {     DataSet dataSet = new DataSet();     try     {         using (SqlConnection connection = new SqlConnection(connectionString))         {             SqlCommand sqlCommand = connection.CreateCommand();               // Define procedure             sqlCommand.CommandType = CommandType.StoredProcedure;             sqlCommand.CommandText = "FinalSortingAndPaging";               // SelectField sql parameter definition             SqlParameter sqlStrParameter = new SqlParameter("@sqlStr", SqlDbType.VarChar);             sqlStrParameter.Value = sqlStr;             sqlCommand.Parameters.Add(sqlStrParameter);               // attention: srot string should be like "h_year desc, z_periods desc"!!!             SqlParameter sortStrParameter = new SqlParameter("@sortStr", SqlDbType.VarChar);             sortStrParameter.Value = sortStr;             sqlCommand.Parameters.Add(sortStrParameter);               SqlParameter pageIndexParameter = new SqlParameter("@pageIndex", SqlDbType.Int);             pageIndexParameter.Value = pageIndex;             sqlCommand.Parameters.Add(pageIndexParameter);               SqlParameter pageSizeParameter = new SqlParameter("@pageSize", SqlDbType.Int);             pageSizeParameter.Value = pageSize;             sqlCommand.Parameters.Add(pageSizeParameter);               SqlParameter recordCountParameter = new SqlParameter("@recordCount", SqlDbType.Int);             recordCountParameter.Direction = ParameterDirection.ReturnValue; sqlCommand.Parameters.Add(recordCountParameter);               connection.Open();               SqlDataAdapter sqlDataAdapter = new SqlDataAdapter(sqlCommand);             sqlDataAdapter.Fill(dataSet);               recordCount = Convert.ToInt32(recordCountParameter.Value);         }     }     catch (Exception)     {         dataSet = null;         recordCount = 0;     }       return dataSet; }

  总结:个人认为这个存储过程在小型项目中,还是比较实用的。发现问题请一定直言不讳,欢迎讨论交流。