标签：SqlHelper C# cmd SqlCommand sql new DataTable conn

using System;
using System.Collections.Generic;
using System.Configuration;
using System.Data;
using System.Data.SqlClient;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace CarHailing.Base
{
    /// <summary>
    ///  数据库帮助类
    /// </summary>
    public class SqlHelp
    {
        /// <summary>
        /// 创建一个已打开的连接
        /// </summary>
        /// <returns></returns>
        private static SqlConnection CreateConn()
        {
            SqlConnection conn = new SqlConnection(ConfigurationManager.ConnectionStrings["conn"].ConnectionString);
            conn.Open();
            return conn;
        }

        /// <summary>
        /// 执行sql语句，返回受影响的行数
        /// </summary>
        /// <param name="sql"></param>
        /// <returns></returns>
        public static int ExecuteNonQuery(string sql)
        {
            return ExecuteNonQuery(sql, null);
        }

        /// <summary>
        /// 执行sql语句，返回受影响的行数
        /// </summary>
        /// <param name="sql"></param>
        /// <returns></returns>
        public static int ExecuteNonQuery(string sql, SqlParameter[] ps)
        {
            SqlConnection conn = CreateConn();
            SqlCommand cmd = new SqlCommand(sql, conn);
            try
            {
                if (ps != null)
                {
                    cmd.Parameters.AddRange(ps);
                }
                return cmd.ExecuteNonQuery();
            }
            catch (Exception ex)
            {
                return 0;
            }
            finally
            {
                conn.Close();
            }
        }

        /// <summary>
        /// 执行sql语句,返回一个结果表
        /// </summary>
        /// <param name="sql"></param>
        /// <returns></returns>
        public static DataTable ExecuteSelectDataTable(string sql)
        {
            return ExecuteSelectDataTable(sql, null);
        }

        /// <summary>
        /// 执行sql语句,返回一个结果表
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="ps"></param>
        /// <returns></returns>
        public static DataTable ExecuteSelectDataTable(string sql, SqlParameter[] ps = null)
        {

            SqlConnection conn = CreateConn();
            SqlCommand cmd = new SqlCommand(sql, conn);
            try
            {
                if (ps != null)
                {
                    cmd.Parameters.AddRange(ps);
                }
                //SqlDataAdapter sda = new SqlDataAdapter(cmd);
                SqlDataReader read = cmd.ExecuteReader();
                DataTable table = new DataTable();
                table.Load(read);
                //DataSet ds = new DataSet();
                //sda.Fill(ds);
                return table;
            }
            finally
            {
                conn.Close();
            }
        }

        /// <summary>
        /// 
        /// </summary>
        /// <param name="sql"></param>
        /// <returns></returns>decimal
        public static DataTable ExecuteSelectPageDataTable(string sql, ref SqlParameter[] ps)
        {
            SqlConnection conn = CreateConn();
            SqlCommand cmd = new SqlCommand(sql, conn);
            cmd.CommandType = CommandType.StoredProcedure;
            try
            {
                cmd.Parameters.AddRange(ps);
                SqlDataAdapter sda = new SqlDataAdapter(cmd);
                DataSet ds = new DataSet();
                sda.Fill(ds);
                return ds.Tables[0];
            }
            catch (SqlException ex)
            {
                throw ex;
            }
            finally
            {
                conn.Close();
            }
        }

        //public static SqlDataReader ExecuteReader(string cmdText, CommandType cmdType, params SqlParameter[] cmdParms)
        //{
        //    SqlCommand cmd = new SqlCommand();
        //    SqlConnection conn = CreateConn();

        //    try
        //    {
        //        ProCommand(cmd, conn, cmdText, cmdType, cmdParms);
        //        SqlDataReader rdr = cmd.ExecuteReader(CommandBehavior.CloseConnection);
        //        //cmd.Parameters.Clear();//放到这里，返回参数会被清空。
        //        return rdr;
        //    }
        //    catch
        //    {
        //        conn.Close();
        //        throw;
        //    }
        //}

        /// <summary>   
        /// 分页读取数据   
        /// </summary>   
        /// <param name="query">select查询语句</param>   
        /// <param name="pageSize">每页显示数据数</param>   
        /// <param name="PageIndex">当前页码</param>   
        /// <param name="dt">存储数据的DataTable实例</param>   
        public static void PageDataTable(string query, int pageSize, int PageIndex, DataTable dt)
        {
            //读取数据的开始索引   
            long startIndex = (PageIndex - 1) * pageSize;
            //读取数据的结束索引   
            long endIndex = PageIndex * pageSize - 1;
            //DataReader读取的当前数据行的索引   
            long readToIndex = -1;
            using (SqlConnection conn = CreateConn())
            {
                SqlCommand cmd = new SqlCommand(query, conn);
                //conn.Open();
                SqlDataReader dr = cmd.ExecuteReader();
                //数据源中的列数   
                int cols = dr.VisibleFieldCount;
                //构造DataTable结构   
                for (int i = 0; i < cols; i++)
                {
                    dt.Columns.Add(new DataColumn(dr.GetName(i), dr.GetFieldType(i)));
                }
                //读取数据，将数据一行一行添加到DataTable   
                while (dr.Read())
                {
                    readToIndex++;
                    //当DataReader指针在开始索引和结束索引闭区间时才读取数据构造DataRow   
                    //并添加到DataTable   
                    if (readToIndex >= startIndex && readToIndex <= endIndex)
                    {
                        DataRow row = dt.NewRow();
                        for (int i = 0; i < cols; i++)
                        {
                            row[i] = dr[i];
                        }
                        dt.Rows.Add(row);
                    }
                }
                dr.Close();
            }
        }
    }
}

标签：SqlHelper,C#,cmd,SqlCommand,sql,new,DataTable,conn
来源： https://www.cnblogs.com/zhang1f/p/11106070.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。