阅读182 返回首页    go 阿里云 go 技术社区[云栖]


[C#][MySql]统计数据表总行数函数--C#和MySQL开发

Web.config设置

<?xml version="1.0"?>
<configuration>
  <connectionStrings>
    <add name="MyConnectionString" connectionString="server=localhost;user id=root;password=123456;database=demo; pooling=true;"/>
  </connectionStrings>
</configuration>

--------------------------------------------------------------------------------------------

// 使用MySql数据库
using MySql.Data.MySqlClient;

--------------------------------------------------------------------------------------------

#region 统计数据表总行数函数
    /// <summary>
    /// 统计数据表总行数
    /// </summary>
    /// <param name="intCount">数据表统计数</param> 
    /// <returns>执行结果</returns>
    public int GetDataCount()
    {
        int intCount = 0;
        // 数据库SQL语句
        String strSQL = @"SELECT Count(*) As MyCount FROM User";
        // 数据库连接参数(对客户端应用程序配置文件的访问)
        string strConn = @System.Configuration.ConfigurationManager.ConnectionStrings["MyConnectionString"].ConnectionString;
        // 数据库的一个连接
        MySql.Data.MySqlClient.MySqlConnection MyConn = new MySql.Data.MySqlClient.MySqlConnection(strConn);
        // 连接到数据源时执行的 SQL 语句
        MySql.Data.MySqlClient.MySqlCommand MyComm = new MySql.Data.MySqlClient.MySqlCommand(strSQL, MyConn);
        try
        {
            // 使用所指定的属性设置打开数据库连接
            MyConn.Open();
            // 提供一种从数据库读取只进的一种方式
            MySql.Data.MySqlClient.MySqlDataReader MyDataReader = MyComm.ExecuteReader();
            // 读取数据,判断是否有数据
            if (MyDataReader.HasRows)
            {
                // 读数据
                MyDataReader.Read();
                // 统计数据表总行数
                intCount = MyDataReader.GetInt32(MyDataReader.GetOrdinal("MyCount"));
                // 返回成功
                return intCount;
            }
            else
            {
                // 返回失败
                return 0;
            }
        }
        catch (MySql.Data.MySqlClient.MySqlException Exp) // 数据库操作异常处理
        {
            // 异常信息
            System.Diagnostics.Debug.Write(Exp.Message.ToString());
            // 判断是否连接
            if (MyConn.State == System.Data.ConnectionState.Open)
            {
                // 关闭数据库连接
                MyConn.Close();
            }
            // 释放内存资源
            MyConn.Dispose();
            MyComm.Dispose();
            // 返回失败
            return 0;
        }
        catch (System.Exception Exp) // 异常处理
        {
            // 异常信息
            System.Diagnostics.Debug.Write(Exp.Message.ToString());
            // 判断是否连接
            if (MyConn.State == System.Data.ConnectionState.Open)
            {
                // 关闭数据库连接
                MyConn.Close();
            }
            // 释放内存资源
            MyConn.Dispose();
            MyComm.Dispose();
            // 返回失败
            return 0;
        }
        finally // 执行完毕清除在try块中分配的任何资源
        {
            // 判断是否连接
            if (MyConn.State == System.Data.ConnectionState.Open)
            {
                // 关闭数据库连接
                MyConn.Close();
            }
            // 释放内存资源
            MyConn.Dispose();
            MyComm.Dispose();
        }
    }
    #endregion

--------------------------------------------------------------------------------------------

我有几张分享给你,用券购买或者升级阿里云相应产品会有特惠惊喜哦!把想要买的产品的幸运券都领走吧!快下手,马上就要抢光了。 

最后更新:2017-10-23 00:33:32

  上一篇:go  如何用好PostgreSQL的备份与恢复?
  下一篇:go  云栖大会所感所想