Mysql万能分页存储过程

小渣渣

1. DROP PROCEDURE IF EXISTS `pPage`;  
   
2. DELIMITER ;;  
   
3. CREATE DEFINER=`root`@`localhost` PROCEDURE `pPage`(in _pagecurrent int, /*当前页*/  
   
4. in _pagesize int,        /*每页的记录数*/  
   
5. in _ifelse varchar(1000),/*显示字段*/  
   
6. in _where varchar(1000), /*条件*/  
   
7. in _order varchar(1000))  
   
8.     COMMENT '分页存储过程\r\n调用例1  call sp_Page(1,3,''*'',''test'',''order by id desc'');\r\n'  
   
9. BEGIN  
   
10. if _pagesize<=1 then  
    
11.   set _pagesize=20;  
    
12. end if;  
    
13. if _pagecurrent < 1 then  
    
14.   set _pagecurrent = 1;  
    
15. end if;  
    
16.    
    
17. set @strsql = concat('select ',_ifelse,' from ',_where,' ',_order,' limit ',_pagecurrent*_pagesize-_pagesize,',',_pagesize);  
    
18. prepare stmtsql from @strsql;  
    
19. execute stmtsql;  
    
20. deallocate prepare stmtsql;   
    
21.   
    
22. set @strsqlcount=concat('select count(0) AS count from ',_where);/*count(1) 这个字段最好是主键*/  
    
23. prepare stmtsqlcount from @strsqlcount;  
    
24. execute stmtsqlcount;  
    
25. deallocate prepare stmtsqlcount;  
    
26.   
    
27. END  
    
28. ;;  
    
29. DELIMITER ;  

复制代码

小渣渣

对应的.net方法

1. public List<T> Get<T>(int _pagecurrent, int _pagesize, string _ifelse, string _where, string _order)
   
2.         {
   
3.             try
   
4.             {
   
5.                 MySqlParameter[] parmeter = new MySqlParameter[5];
   
6.                 parmeter[0] = new MySqlParameter("_pagecurrent", _pagecurrent);
   
7.                 parmeter[1] = new MySqlParameter("_pagesize", _pagesize);
   
8.                 parmeter[2] = new MySqlParameter("_ifelse", _ifelse);
   
9.                 parmeter[3] = new MySqlParameter("_where", _where);
   
10.                 parmeter[4] = new MySqlParameter("_order", _order);
    
11.                 DataSet ds = BucketDiagram.DataAccess.MySqlHelper.GetDataSet(Config.SqlConn, CommandType.StoredProcedure, "pPage", parmeter);
    
12.                 if (ds != null && ds.Tables.Count > 0)
    
13.                 {
    
14.                     List<T> list = ds.Tables[0].ToListFromDataTable<T>();
    
15.                     return list;
    
16.                 }
    
17.                 else {
    
18.                     return null;
    
19.                 }
    
20.             }
    
21.             catch (Exception ex)
    
22.             {
    
23.                 return null;
    
24.             }
    
25.         }

复制代码

小渣渣

1. /// <summary>
   
2.     /// 万能分页
   
3.     /// </summary>
   
4.     /// <typeparam name="T"></typeparam>
   
5.     public abstract class pPage
   
6.     {
   
7.         protected List<T> Get<T>(int _pagecurrent, int _pagesize, string _ifelse, string _where, string _order,out int count)
   
8.         {
   
9.             count = 0;
   
10.             try
    
11.             {
    
12.                 MySqlParameter[] parmeter = new MySqlParameter[5];
    
13.                 parmeter[0] = new MySqlParameter("_pagecurrent", _pagecurrent);
    
14.                 parmeter[1] = new MySqlParameter("_pagesize", _pagesize);
    
15.                 parmeter[2] = new MySqlParameter("_ifelse", _ifelse);
    
16.                 parmeter[3] = new MySqlParameter("_where", _where);
    
17.                 parmeter[4] = new MySqlParameter("_order", _order);
    
18.                 DataSet ds = BucketDiagram.DataAccess.MySqlHelper.GetDataSet(Config.SqlConn, CommandType.StoredProcedure, "pPage", parmeter);
    
19.                 if (ds != null && ds.Tables.Count > 0)
    
20.                 {
    
21.                     //总条数
    
22.                     count = Convert.ToInt32(ds.Tables[1].Rows[0][0]);
    
23.                     //List<T> list = ds.Tables[0].ToListFromDataTable<T>();
    
24.                     List<T> list = ConvertTo<T>(ds.Tables[0]).ToList();
    
25.                     return list;
    
26.                 }
    
27.                 else {
    
28.                     return null;
    
29.                 }
    
30.             }
    
31.             catch (Exception ex)
    
32.             {
    
33.                 return null;
    
34.             }
    
35.         }
    
36. 
    
37.         public static IList<T> ConvertTo<T>(DataTable table)
    
38.         {
    
39.             if (table == null)
    
40.             {
    
41.                 return null;
    
42.             }
    
43. 
    
44.             List<DataRow> rows = new List<DataRow>();
    
45. 
    
46.             foreach (DataRow row in table.Rows)
    
47.             {
    
48.                 rows.Add(row);
    
49.             }
    
50. 
    
51.             return ConvertTo<T>(rows);
    
52.         }
    
53. 
    
54.         public static IList<T> ConvertTo<T>(IList<DataRow> rows)
    
55.         {
    
56.             IList<T> list = null;
    
57. 
    
58.             if (rows != null)
    
59.             {
    
60.                 list = new List<T>();
    
61. 
    
62.                 foreach (DataRow row in rows)
    
63.                 {
    
64.                     T item = CreateItem<T>(row);
    
65.                     list.Add(item);
    
66.                 }
    
67.             }
    
68. 
    
69.             return list;
    
70.         }
    
71.         public static T CreateItem<T>(DataRow row)
    
72.         {
    
73.             T obj = default(T);
    
74.             if (row != null)
    
75.             {
    
76.                 obj = Activator.CreateInstance<T>();
    
77. 
    
78.                 foreach (DataColumn column in row.Table.Columns)
    
79.                 {
    
80.                     PropertyInfo prop = obj.GetType().GetProperty(column.ColumnName);
    
81.                     try
    
82.                     {
    
83.                         object value = row[column.ColumnName];
    
84.                         prop.SetValue(obj, value, null);
    
85.                     }
    
86.                     catch
    
87.                     {  //You can log something here     
    
88.                         //throw;   
    
89.                     }
    
90.                 }
    
91.             }
    
92. 
    
93.             return obj;
    
94.         }
    
95.     }

复制代码

正确的写法