zoukankan      html  css  js  c++  java
  • 支持多返回值存储过程的SqlHelper

    public readonly string connStr = ConfigurationManager.ConnectionStrings["sql"].ConnectionString;
    
            /// <summary>
            /// 执行非插叙语句,返回受影响行数
            /// </summary>
            /// <param name="cmdText">Sql语句</param>
            /// <param name="ps">参数列表</param>
            /// <returns>受影响行数</returns>
            public int ExecuteNonQuery(string cmdText, params SqlParameter[] ps)
            {
                return this.ExecuteNonQuery(cmdText, CommandType.Text, ps);
            }
    
            /// <summary>
            /// 执行存储过程
            /// </summary>
            /// <param name="cmdText">存储过程名称</param>
            /// <param name="ps">参数列表</param>
            /// <returns>返回存储过程成功与否</returns>
            public int ExecuteNonQuerySP(string cmdText, params SqlParameter[] ps)
            {
                return this.ExecuteNonQuery(cmdText, CommandType.StoredProcedure, ps);
            }
    
            /// <summary>
            /// 执行SQL语句或存储过程,返回结果
            /// </summary>
            /// <param name="cmdText">SQL语句或存储过程名称</param>
            /// <param name="type">执行类型</param>
            /// <param name="ps">参数列表</param>
            /// <returns>返回受影响行数或存储过程成功与否</returns>
            public int ExecuteNonQuery(string cmdText, CommandType type, params SqlParameter[] ps)
            {
                if (type == CommandType.Text)
                {
                    try
                    {
                        using (SqlConnection conn = new SqlConnection(connStr))
                        {
                            using (SqlCommand cmd = new SqlCommand(cmdText, conn))
                            {
                                if (ps != null)
                                {
                                    cmd.Parameters.AddRange(ps);
                                }
                                conn.Open();
                                return cmd.ExecuteNonQuery();
                            }
                        }
                    }
                    catch (Exception ex)
                    {
                        throw ex;
                    }
                }
                else if (type == CommandType.StoredProcedure)
                {
                    try
                    {
                        ps[ps.Length - 1].Direction = ParameterDirection.Output;
                        using (SqlConnection conn = new SqlConnection(connStr))
                        {
                            using (SqlCommand cmd = new SqlCommand(cmdText, conn))
                            {
                                cmd.CommandType = CommandType.StoredProcedure;
                                if (ps != null)
                                {
                                    cmd.Parameters.AddRange(ps);
                                }
                                conn.Open();
                                cmd.ExecuteNonQuery();
                            }
                        }
                        return (int)ps[ps.Length - 1].Value;
                    }
                    catch (Exception ex)
                    {
                        throw ex;
                    }
                }
                else
                {
                    return -1;
                }
            }
    
            /// <summary>
            /// 执行查询语句,返回第一行第一列数据
            /// </summary>
            /// <param name="cmdText">Sql语句</param>
            /// <param name="ps">参数列表</param>
            /// <returns>第一行第一列数据</returns>
            public object ExecuteScalar(string cmdText, params SqlParameter[] ps)
            {
                return ExecuteScalar(cmdText, CommandType.Text, ps);
            }
    
            /// <summary>
            /// 执行存储过程,返回存储过程返回值
            /// </summary>
            /// <param name="cmdText">存储过程名称</param>
            /// <param name="ps">参数列表</param>
            /// <returns>存储过程返回值</returns>
            public object ExecuteScalarSP(string cmdText, params SqlParameter[] ps)
            {
                return ExecuteScalar(cmdText, CommandType.StoredProcedure, ps);
            }
    
            /// <summary>
            /// 执行查询语句或存储过程,返回第一行第一列数据或存储过程返回值
            /// </summary>
            /// <param name="cmdText">Sql语句或存储过程名称</param>
            /// <param name="ps">参数列表</param>
            /// <returns>第一行第一列数据或存储过程返回值</returns>
            public object ExecuteScalar(string cmdText, CommandType type, params SqlParameter[] ps)
            {
                if (type == CommandType.Text)
                {
                    try
                    {
                        using (SqlConnection conn = new SqlConnection(connStr))
                        {
                            using (SqlCommand cmd = new SqlCommand(cmdText, conn))
                            {
                                if (ps != null)
                                {
                                    cmd.Parameters.AddRange(ps);
                                }
                                conn.Open();
                                return cmd.ExecuteScalar();
                            }
                        }
                    }
                    catch (Exception ex)
                    {
                        return ex;
                    }
                }
                else if (type == CommandType.StoredProcedure)
                {
                    try
                    {
                        for (int i = 0; i < ps.Length; i++)
                        {
                            if (ps[i].Value == null)
                            {
                                ps[i].Direction = ParameterDirection.Output;
                            }
                        }
                        using (SqlConnection conn = new SqlConnection(connStr))
                        {
                            using (SqlCommand cmd = new SqlCommand(cmdText, conn))
                            {
                                cmd.CommandType = type;
                                if (ps != null)
                                {
                                    cmd.Parameters.AddRange(ps);
                                }
                                conn.Open();
                                cmd.ExecuteScalar();
                            }
                        }
                        List<Object> returnValue = new List<object>();
                        for (int i = 0; i < ps.Length; i++)
                        {
                            if (ps[i].Direction == ParameterDirection.Output)
                            {
                                returnValue.Add(ps[i].Value);
                            }
                        }
                        return returnValue;
                    }
                    catch (Exception ex)
                    {
                        return ex;
                    }
                }
                else
                {
                    return -1;
                }
            }
    
            /// <summary>
            /// 执行查询语句,并返回一个DataReader阅读器
            /// </summary>
            /// <param name="cmdText">Sql语句</param>
            /// <param name="ps">参数列表</param>
            /// <returns>DataReader阅读器</returns>
            public SqlDataReader ExecuteReader(string cmdText, params SqlParameter[] ps)
            {
                return ExecuteReader(cmdText, CommandType.Text, ps);
            }
    
            /// <summary>
            /// 执行存储过程,并返回一个DataReader阅读器
            /// </summary>
            /// <param name="cmdText">存储过程名称</param>
            /// <param name="ps">参数列表</param>
            /// <returns>DataReader阅读器</returns>
            public SqlDataReader ExecuteReaderSP(string cmdText, params SqlParameter[] ps)
            {
                return ExecuteReader(cmdText, CommandType.StoredProcedure, ps);
            }
    
            /// <summary>
            /// 执行查询语句或存储过程,并返回一个DataReader阅读器
            /// </summary>
            /// <param name="cmdText">Sql语句或存储过程名称</param>
            /// <param name="ps">参数列表</param>
            /// <returns>DataReader阅读器</returns>
            public SqlDataReader ExecuteReader(string cmdText, CommandType type, params SqlParameter[] ps)
            {
                SqlConnection conn = new SqlConnection(connStr);
                try
                {
                    using (SqlCommand cmd = new SqlCommand(cmdText, conn))
                    {
                        cmd.CommandType = type;
                        if (ps != null)
                        {
                            cmd.Parameters.AddRange(ps);
                        }
                        conn.Open();
                        return cmd.ExecuteReader(CommandBehavior.CloseConnection);
                    }
                }
                catch (Exception ex)
                {
                    conn.Dispose();
                    throw (ex);
                }
            }
    
            /// <summary>
            /// 执行查询语句,返回DataSet
            /// </summary>
            /// <param name="cmdText">Sql语句</param>
            /// <param name="ps">参数列表</param>
            /// <returns>返回的DataSet</returns>
            public DataSet GetDataSet(string cmdText, params SqlParameter[] ps)
            {
                return this.GetDataSet(cmdText, CommandType.Text, ps);
            }
    
            /// <summary>
            /// 执行存储过程返回DataSet
            /// </summary>
            /// <param name="cmdText">存储过程名</param>
            /// <param name="ps">参数列表</param>
            /// <returns>返回DataSet</returns>
            public DataSet GetDataSetSP(string cmdText, params SqlParameter[] ps)
            {
                return this.GetDataSet(cmdText, CommandType.StoredProcedure, ps);
            }
    
            /// <summary>
            /// 执行存储过程,或SQL语句,返回DataSet
            /// </summary>
            /// <param name="cmdText">SQL语句或存储过程名称</param>
            /// <param name="type">执行类型</param>
            /// <param name="ps">参数列表</param>
            /// <returns>返回DataSet</returns>
            public DataSet GetDataSet(string cmdText, CommandType type, params SqlParameter[] ps)
            {
                DataSet ds = new DataSet();
                try
                {
                    using (SqlDataAdapter sda = new SqlDataAdapter(cmdText, connStr))
                    {
                        if (ps != null)
                        {
                            sda.SelectCommand.Parameters.AddRange(ps);
                        }
                        sda.SelectCommand.CommandType = CommandType.StoredProcedure;
                        sda.Fill(ds);
                    }
                    return ds;
                }
                catch (Exception ex)
                {
                    ds.Dispose();
                    throw (ex);
                }
            }
    

      

  • 相关阅读:
    swift 初见-4运算符与字符串操作
    IOS中数据持久化1-CoreData
    swift 初见-3
    swift 初见-2
    系统硬件1-短信,打电话
    swift 初见-1
    socket理解流程图
    文件操作方法fscanf
    Prim模板
    树剖求LCA模板
  • 原文地址:https://www.cnblogs.com/wl-blog/p/13745603.html
Copyright © 2011-2022 走看看