分页管理器实现

    在DataGrid的web版控件中提供了自动分页的功能，但是我从来没用过它，因为它实现的分页只是一种假相。我们为什么需要分页？那是因为符合条件的记录可能很多，如果一次读取所有的记录，不仅延长获取数据的时间，而且也极度浪费内存。而分页的存在的主要目的正是为了解决这两个问题（当然，也不排除为了UI美观的需要而使用分页的）。而web版的DataGrid是怎样实现分页的了？它并没有打算解决上述两个问题，而还是一次读取所有的数据，然后以分页的样子表现出来。这是对效率和内存的极大损害！

    于是我自己实现了分页管理器IPaginationManager ，IPaginationManager 每次从数据库中读取指定的任意一页，并且可以缓存指定数量的page。这个分页管理器的主要特点是：
（1）支持随机跳转。这是通过嵌套Select语句实现的。
（2）支持缓存。通过EnterpriseServerBase.DataStructure.FixCacher进行支持。
 
    先来看看IPaginationManager接口的定义：

    public interface IPaginationManager
    {
        void      Initialize(DataPaginationParas paras) ;
        void      Initialize(IDBAccesser accesser ,int page_Size ,string whereStr ,string[] fields) ;//如果选择所有列，fields可传null
        
        DataTable GetPage(int index) ;  //取出第index页
        DataTable CurrentPage() ;
        DataTable PrePage() ;
        DataTable NextPage() ;

        int          PageCount{get ;}
        int       CacherSize{get; set; }
    }

    这个接口定义中，最主要的是GetPage()方法，实现了这个方法，其它的三个获取页面的方法CurrentPage、PrePage、NextPage也就非常容易了。另外，CacherSize属性可以让我们指定缓存页面的数量。如果不需要缓存，则设置其值<=0，如果需要无限缓存，则值为Int.MaxValue。
    IPaginationManager接口中的第二个Initialize方法，你不要关心，它是给XCodeFactory生成的数据层使用了，我们来看看第一个Initialize方法的参数类型DataPaginationParas的定义：

    public class DataPaginationParas
    {
        public int      PageSize = 10 ;        
        public string[] Fields = {"*"}; //要搜索出的列，"*"表示所有列

        public string   ConnectString ;
        public string   TableName ; 
        public string   WhereStr ;      //搜索条件的where字句

        public DataPaginationParas(string connStr ,string tableName ,string whereStr)
        {
            this.ConnectString = connStr ;
            this.TableName       = tableName ;
            this.WhereStr      = whereStr ;
        }        

        #region GetFiedString
        public string GetFiedString()
        {
            if(this.Fields == null) 
            {
                this.Fields = new string[] {"*"} ;
            }

            string fieldStrs = "" ;

            for(int i=0 ;i<this.Fields.Length ;i++)
            {
                fieldStrs += " " + this.Fields[i] ;
                if(i != (this.Fields.Length -1))
                {
                    fieldStrs += " , " ;
                }
                else
                {
                    fieldStrs += " " ;
                }
            }

            return fieldStrs ;
        }
        #endregion

    }

    DataPaginationParas.GetFiedString用于把要搜索的列形成字符串以便嵌入到SQL语句中。DataPaginationParas中的其它字段的意思都很明显。
    现在来看看分页管理器的实现了：

    public class PaginationManager :IPaginationManager
    {
        private DataPaginationParas   theParas ;
        private IADOBase              adoBase ;            
        private DataTable   curPage      = null ;
        private int         itemCount    = 0 ;
        private int         pageCount    = -1 ;        
        private int         curPageIndex = -1 ;
        
        private FixCacher   fixCacher    = null ;
        private string      fieldStrs    = "" ;

        /// <summary>
        /// cacheSize 小于等于0 －－ 表示不缓存 ，Int.MaxValue －－ 缓存所有
        /// </summary>        
        public PaginationManager(int cacheSize)
        {
            if(cacheSize == int.MaxValue)
            {
                this.fixCacher = new FixCacher() ;
            }
            else if(cacheSize >0)
            {
                this.fixCacher = new FixCacher(cacheSize) ;
            }
            else
            {
                this.fixCacher = null ;
            }
        }    

        public PaginationManager()
        {
        }

        #region IDataPaginationManager 成员
        public int CacherSize
        {
            get
            {
                if(this.fixCacher == null)
                {
                    return 0 ;
                }

                return this.fixCacher.Size ;
            }
            set
            {
                if(this.fixCacher == null)
                {
                    this.fixCacher = new FixCacher(value) ;
                }
                else
                {
                    this.fixCacher.Size = value ;
                }
            }
        }
        public int PageCount
        {
            get
            {
                if(this.pageCount == -1)
                {
                    string selCountStr = string.Format("Select count(*) from {0} {1}" ,this.theParas.TableName ,this.theParas.WhereStr) ;
                    DataSet ds = this.adoBase.DoQuery(selCountStr) ;
                    this.itemCount = int.Parse(ds.Tables[0].Rows[0][0].ToString()) ;
                    this.pageCount = this.itemCount/this.theParas.PageSize ;
                    if((this.itemCount%this.theParas.PageSize > 0))
                    {
                        ++ this.pageCount ;
                    }
                }

                return this.pageCount ;
            }
        }

        /// <summary>
        /// GetPage 取出指定的一页
        /// </summary>        
        public DataTable GetPage(int index)
        {
            if(index == this.curPageIndex)
            {
                return this.curPage ;
            }

            if((index < 0) || (index > (this.PageCount-1)))
            {
                return null;
            }

            DataTable dt = this.GetCachedObject(index) ;

            if(dt == null)
            {
                string selectStr = this.ConstrutSelectStr(index) ;
                DataSet ds = this.adoBase.DoQuery(selectStr) ;
                dt = ds.Tables[0] ;

                this.CacheObject(index ,dt) ;
            }

            this.curPage      = dt ;
            this.curPageIndex = index ;
            return this.curPage ;
        }

        private DataTable GetCachedObject(int index)
        {
            if(this.fixCacher == null)
            {
                return null ;
            }

            return (DataTable)this.fixCacher[index] ;
        }

        private void CacheObject(int index ,DataTable page)
        {
            if(this.fixCacher != null)
            {
                this.fixCacher.PutIn(index ,page) ;
            }
        }

        public DataTable CurrentPage()
        {
            return this.curPage ;
        }

        public DataTable PrePage()
        {
            return this.GetPage((--this.curPageIndex)) ;
        }

        public DataTable NextPage()
        {
            return this.GetPage((++this.curPageIndex)) ;
        }    
    
        private string ConstrutSelectStr(int pageIndex)
        {
            if(pageIndex == 0)
            {
                return string.Format("Select top {0} {1} from {2} {3} ORDER BY ID" ,this.theParas.PageSize ,this.fieldStrs ,this.theParas.TableName ,this.theParas.WhereStr) ;
            }

            int innerCount     = this.itemCount - this.theParas.PageSize*pageIndex ;
            string innerSelStr = string.Format("Select top {0} {1} from {2} {3} ORDER BY ID DESC " ,innerCount , this.fieldStrs ,this.theParas.TableName ,this.theParas.WhereStr) ;
            string outerSelStr = string.Format("Select top {0} * from ({1}) DERIVEDTBL ORDER BY ID" ,this.theParas.PageSize ,innerSelStr) ;

            return outerSelStr ;
        }

        #region Initialize
        public void Initialize(IDBAccesser accesser, int page_Size, string whereStr, string[] fields)
        {
            this.theParas = new DataPaginationParas(accesser.ConnectString ,accesser.DbTableName ,whereStr) ;
            this.theParas.Fields = fields ;
            this.theParas.PageSize = page_Size ;
        
            this.fieldStrs = this.theParas.GetFiedString() ;    
            this.adoBase = new SqlADOBase(this.theParas.ConnectString) ;
        }    
        
        public void Initialize(DataPaginationParas paras)
        {
            this.theParas = paras ;
            this.fieldStrs = this.theParas.GetFiedString() ;    
            this.adoBase = new SqlADOBase(this.theParas.ConnectString) ;
        }

        #endregion

        #endregion
    }

    了解这个类的实现，可以从GetPage(int index)方法入手，另外私有方法ConstrutSelectStr()的实现说明了如何使用嵌套sql语句进行随机分页搜索。
    最后，关于分页管理器，需要指出的是，搜索对应的表必须有一个名为"ID"的主键－－这是唯一的要求。另外，分页管理器实现用到的数据访问低阶封装IADOBase定义于EnterpriseServerBase类库中。
    使用分页管理器是很简单的，加上UI界面后，只要把返回的DataTable绑定到DataGrid就可以了：）