标签:
 private static string connString = "server=.;database=hotel;uid=aa;pwd=123";//最好从配置文件中取出
        public static SqlConnection conn = new SqlConnection(connString);
        //公用的增删改方法
        public static bool ZhengShanGai(string sql)
        {
            bool flag = false;
            SqlCommand com = null;
            try
            {
                if (sql == null || sql == "")
                {
                    return false;
                }
                if (conn.State != ConnectionState.Open)
                    conn.Open();
                com = new SqlCommand(sql, conn);
                if (com.ExecuteNonQuery() > 0)
                    flag = true;
            }
            catch (Exception ex)
            {
                throw ex;
            }
            finally
            {
                com.Dispose();
                conn.Close();
            }
            return flag;
        }
        //公用的查询方法 ,返回值为SqlDateReader
        public static SqlDataReader Query(string sql)
        {
            SqlCommand com = null;
            SqlDataReader reader = null;
            try
            {
                if (sql == null || sql == "")
                {
                    return null;
                }
                if (conn.State != ConnectionState.Open)
                    conn.Open();
                com = new SqlCommand(sql, conn);
                //当关闭reader后连接自动关闭
                reader = com.ExecuteReader(CommandBehavior.CloseConnection);
            }
            catch (Exception ex)
            {
                return null;
                throw ex;
            }
            return reader;
        }
        //公用的查询方法 ,返回值为DataTable;
        public static DataTable QueryInfo(string sql)
        {
            DataTable dt = new DataTable();
            SqlDataAdapter da = null;
            try
            {
                DBHelper.conn.Open();
                da = new SqlDataAdapter(sql, DBHelper.conn);
                da.Fill(dt);
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
            }
            finally
            {
                DBHelper.conn.Close();
            }
            return dt;
        }
        // 执行带参数存储过程的方法
        public bool ExcuteProc(string procName, SqlParameter[] procParams)
        {
            bool flag = false;
            SqlCommand com = null;
            try
            {
                if (procName == null || procName == "") return false;
                if (conn.State != ConnectionState.Open) conn.Open();
                com = new SqlCommand(procName, conn);
                com.CommandType = CommandType.StoredProcedure;
                if (procParams != null)
                {
                    foreach (SqlParameter procParam in procParams)
                    {
                        com.Parameters.Add(procParam);
                    }
                }
                if (com.ExecuteNonQuery() > 0) flag = true;
            }
            catch (Exception)
            {
                return false;
            }
            finally
            {
                com.Dispose();
                conn.Close();
            }
            return flag;
        }
}
以上是很简单的ado.net基础帮助类,如有什么疑问,或是认为我写的有错,我愿意和大家交流
标签:
原文地址:http://www.cnblogs.com/aiai-An/p/4428712.html