用C# 语言实现MYSQL 真分页

本文涉及的产品
云数据库 RDS MySQL Serverless,0.5-2RCU 50GB
简介: 用C# 语言实现MYSQL 真分页

@[TOC]用C# 语言实现MYSQL 真分页(wcf框架)

真分页与假分页

假分页

  从数据库中取出所有的数据,然后分页在界面上显示。访问一次数据库,但由于选择的数据量比较大,所以第一次花费时间比较长,但之后每一页的显示都是直接、快速的,避免对数据库的多次访问。

 真分页

  确定要显示的数量和内容,然后每次都去数据库取出该少量数据,优点是数据量小,缺点是访问数据库频繁。在大型网站中往往采用真分页,比如百度的图片获取。

为提高效率,我们使用真分页,

SQL帮助类

public class MySQLHelper
    {
        //public MySqlConnection GetConn()
        //{
        //    
        //    MySqlConnection connect = new MySqlConnection(constructorString);
        //    return connect;
        //}
        private MySqlConnection conn = null;//数据库连接
        private MySqlCommand cmd = null;//对数据库进行操作,也就是增删改查
        private MySqlDataReader sdr = null;//从数据库中只读
        public MySQLHelper()
        {
            string connStr = "server=192.168.60.54;port=3306;User Id=sentry;password=sentry;Database=sentry_system_dev;SslMode=none;Charset=utf8;";
            conn = new MySqlConnection(connStr);//打开数据库的连接,此时并未连接成功
        }
        /// <summary>
        /// 判断数据源的连接情况
        /// </summary>
        /// <returns>连接</returns>
        private MySqlConnection GetConn()
        {
            if (conn.State == ConnectionState.Closed) //枚举ConnectionState,用于描述数据源当前的连接状态
            {
                conn.Open();//连接数据库
            }
            return conn;
        }
        /// <summary>
        /// 通过ExecuteQuery()方法。执行带参的SQL查询语句或存储过程
        /// </summary>
        /// <param name="cmdText">查询文本</param>
        /// <param name="paras">参数</param>
        /// <param name="ct">执行类型</param>
        /// <returns>受影响的行</returns>
        public DataTable ExecuteQuery(string cmdText, MySqlParameter[] paras, CommandType ct)
        {
            DataTable dt = new DataTable();//实例化数据库内存中的一个表
            cmd = new MySqlCommand(cmdText, GetConn());  //cmdText:查询的文本;getConn():连接数据库的方法
            cmd.CommandType = ct;//指定命令对象的执行形式,默认为text
            cmd.Parameters.AddRange(paras);//将参数加入到参数集中
            using (sdr = cmd.ExecuteReader(CommandBehavior.CloseConnection)) //在执行命令时,将关联 Connection 对象已关闭时关联 DataReader 对象已关闭
            {
                dt.Load(sdr);   //将提供的数据源中的值填充到DataTable,如果已存在,则合并
            }
            return dt;  //返回表到DAL层
        }
        /// <summary>
        /// 执行不带参数的SQL查询语句或者存储过程
        /// </summary>
        /// <param name="cmdText">查询SQL语句或存储过程</param>
        /// <param name="ct">命令类型</param>
        /// <returns>返回受影响的行数</returns>
        public DataTable ExecuteQuery(string cmdText, CommandType ct)
        {
            DataTable dt = new DataTable();
            cmd = new MySqlCommand(cmdText, GetConn());
            cmd.CommandType = ct;
            using (sdr = cmd.ExecuteReader(CommandBehavior.CloseConnection))
            {
                dt.Load(sdr);
            }
            return dt;
        }
        /// <summary>
        /// 执行不带参数的数据库操作或者存储过程heihei
        /// </summary>
        /// <param name="cmdText">增删改查操作</param>
        /// <param name="ct">命令类型</param>
        /// <returns>返回受影响的行数</returns>
        public int ExecuteNonQuery(string cmdText, CommandType ct)
        {
            int res;
            cmd = new MySqlCommand(cmdText, GetConn());
            cmd.CommandType = ct;
            res = cmd.ExecuteNonQuery();
            if (conn.State == ConnectionState.Open)
            {
                conn.Close();
            }
            return res;
        }
        /// <summary>
        /// 执行带参数的数据库操作或者存储过程
        /// </summary>
        /// <param name="cmdText">增删改查操作</param>
        /// <param name="paras">要查询的参数</param>
        /// <param name="ct">命令类型</param>
        /// <returns>返回受影响的行数</returns>
        public int ExecuteNonQuery(string cmdText, MySqlParameter[] paras, CommandType ct)
        {
            int res;
            using (cmd = new MySqlCommand(cmdText, GetConn()))
            {
                cmd.CommandType = ct;
                cmd.Parameters.AddRange(paras);
                res = cmd.ExecuteNonQuery();
            }
            return res;
        }
    }

实体层:

public class FaceImageEntity

{

private string userID;//用户姓名

private string imageByte;//图片字节码
    public byte[] ImageByte;
    private string faceToken;//图片的唯一标识
    public string UserID
    {
        get { return userID; }
        set { userID = value; }
    }
    public string  Sex { get; set; }
    public string  UserName { get; set; }
    public string FaceToken
    {
        get { return faceToken; }
        set { faceToken = value; }
    }
    public DateTime CreatTime { get; set; }
    public DateTime UpadateTime { get; set; }
    public int ISDelet { get; set; }
}

D层:

/// <summary>
      /// 通过输入页数大小与第多少页来获取数据
      /// </summary>
      /// <param name="inputPageSidze">输入每页的大小</param>
      /// <param name="inputpageCode">要查询第几个的页数</param>
      /// <returns></returns>
        public List<FaceImageEntity> PagingSelectAllImage(int inputPageSize, int inputpageCode)
        {
            List<FaceImageEntity> faceToken =new List<FaceImageEntity>();
            MySqlParameter[] sqlparams = new MySqlParameter[]
           {
                 new MySqlParameter("@is_Delet",0),
           };
           string sql= "SELECT * FROM t_faceimage_info where  is_Delet=@is_Delet  order  by create_Time desc limit " + (inputpageCode - 1) * inputPageSize + "," + inputPageSize;
            DataTable dataTable = sqlHelper.ExecuteQuery(sql, sqlparams, CommandType.Text);
                foreach (DataRow dataRow in dataTable.Rows)
                {
                    faceToken.Add(new FaceImageEntity
                    {
                        FaceToken = Convert.ToString(dataRow["face_Token"]),
                        ImageByte = (byte[])dataRow["image_Byte"],
                        UserID = Convert.ToString(dataRow["user_ID"]),
                        ISDelet = Convert.ToInt32(dataRow["is_Delet"]),
                        Sex = Convert.ToString(dataRow["sex"]),
                        UserName = Convert.ToString(dataRow["user_Name"]),
                        CreatTime = Convert.ToDateTime(dataRow["create_Time"]),
                        UpadateTime = Convert.ToDateTime(dataRow["update_Time"])
                    }); ;
                }
            return faceToken;
        }

B层:

/// <summary>
        /// 通过输入每页大小与获取第几页,
        /// </summary>
        /// <param name="inputPageSidze">每页大小</param>
        /// <param name="inputpageCode">查询第几页</param>
        /// <returns>返回数据</returns>
        public List<FaceImageEntity> PagingSelectAllImage(int inputPageSidze, int inputpageCode)
        {
            return FaceImageDAL.PagingSelectAllImage(inputPageSidze,inputpageCode);
        }


相关实践学习
基于CentOS快速搭建LAMP环境
本教程介绍如何搭建LAMP环境,其中LAMP分别代表Linux、Apache、MySQL和PHP。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
1月前
Mybatis+mysql动态分页查询数据案例——分页工具类(Page.java)
Mybatis+mysql动态分页查询数据案例——分页工具类(Page.java)
24 1
|
1月前
|
SQL 关系型数据库 MySQL
【MySQL 数据库】2、MySQL 的数据控制语言、函数和约束
【MySQL 数据库】2、MySQL 的数据控制语言、函数和约束
31 0
|
1月前
|
SQL 关系型数据库 MySQL
MYSQL分页limit速度太慢优化方法
MYSQL分页limit速度太慢优化方法
32 0
|
2月前
|
SQL 关系型数据库 MySQL
MySQL技能完整学习列表3、SQL语言基础——1、SQL(Structured Query Language)简介——2、基本SQL语句:SELECT、INSERT、UPDATE、DELETE
MySQL技能完整学习列表3、SQL语言基础——1、SQL(Structured Query Language)简介——2、基本SQL语句:SELECT、INSERT、UPDATE、DELETE
51 0
|
10天前
|
SQL 关系型数据库 MySQL
排序与分页——“MySQL数据库”
排序与分页——“MySQL数据库”
|
13天前
|
SQL 关系型数据库 MySQL
DQL语言之基础查询(mysql)
DQL语言之基础查询(mysql)
|
13天前
|
SQL 关系型数据库 MySQL
DQL语言之常见函数(mysql)
DQL语言之常见函数(mysql)
|
13天前
|
SQL 关系型数据库 MySQL
DQL语言之连接查询(mysql)
DQL语言之连接查询(mysql)
|
19天前
|
SQL 关系型数据库 MySQL
mysql基本查询、运算符、排序和分页
mysql基本查询、运算符、排序和分页
|
1月前
|
数据挖掘 C# 开发工具
采用C#语言开发的全套医院体检系统PEIS源码功能介绍
体检系统,是专为体检中心/医院体检科等体检机构,专门开发的全流程管理系统,通过软件实现检测仪器数据自动提取,内置多级医生工作台,细化工作将体检检查结果汇总,生成体检报告登记到计算机系统中。通过软件系统进行数据分析统计与评判以及建立体检相关的体检档案。从而实现体检流程的信息化,提高工作效率,减少手动结果录入的一些常犯错误。 在实际应用中,医院体检系统能够解决传统体检中手工操作带来的问题,如工作量大、效率低下、易漏检、重检或错检等。通过与医院信息系统(如HIS、LIS、PACS等)的连接,系统能够满足体检中心的日常工作流程,提供更好的管理、统计和查询分析功能。同时,基于网络基础的系统可以在网上传输
27 1