C# SQL幫助類

 

C# SQL幫助類

本人自己封裝的SQLHelper類，執行sql server與Oracle數據的增刪改查

vs自帶的Oracle數據庫引用需要安裝Oracle客戶端，如不想安裝Oracle客戶端，可以引用 Oracle.ManagedDataAccess.dll

下載鏈接: https://pan.baidu.com/s/1dzzTxL2fmUPrMy2Qc246jg 提取碼: 16my 

public class SQLHelper
    {
        /// <summary>
        /// 執行查詢語句
        /// </summary>
        /// <param name="ConnStr">連接字符串</param>
        /// <param name="Sql">sql語句</param>
        /// <param name="Param">查詢的字段名</param>
        /// <returns>查詢結果或錯誤信息</returns>
        public static string[] ExecuteReaderSql(string ConnStr,string Sql,string[] Param)
        {
            string[] info = new string[Param.Count()];
            SqlConnection conn = null;
            try
            {
                conn = new SqlConnection(ConnStr);
                conn.Open();
                SqlCommand cmd = new SqlCommand(Sql, conn);
                SqlDataReader sdr = cmd.ExecuteReader();
                sdr.Read();
                if (!sdr.HasRows) { info[0] = "null"; return info; }
                for (int i = 0; i <Param.Count(); i++)
                {
                    info[i] = sdr[Param[i]].ToString();
                }
            }
            catch(Exception ex)
            {
                info[0] = "sql查詢錯誤信息：" + ex.Message;
                return info;
            }
            finally
            {
                conn.Close();
            }

            return info;
        }
        /// <summary>
        /// 執行增刪改
        /// </summary>
        /// <param name="ConnStr">連接字符串</param>
        /// <param name="Sql">sql語句</param>
        /// <returns>受影響的行數或錯誤信息</returns>
        public static string ExecuteSql(string ConnStr,string Sql)
        {
            SqlConnection conn = null;
            int Row = 0;
            try
            {
                conn = new SqlConnection(ConnStr);
                conn.Open();
                SqlCommand cmd = new SqlCommand(Sql,conn);
                Row = cmd.ExecuteNonQuery();
            }
            catch(Exception ex)
            {
                return "sql執行錯誤信息：" + ex.Message;
            }
            finally
            {
                conn.Close();
            }
            return Row.ToString();
        }
        /// <summary>
        /// Oracle增刪改
        /// </summary>
        /// <param name="ConnStr">連接字符串</param>
        /// <param name="orcl">Oracle語句</param>
        /// <returns>受影響行數或錯誤信息</returns>
        public static string ExecuteOrcl(string ConnStr, string orcl)
        {
            OracleConnection conn = null;
            int Row = 0;
            try
            {
                conn = new OracleConnection(ConnStr);
                conn.Open();
                OracleCommand cmd = new OracleCommand(orcl, conn);
                Row = cmd.ExecuteNonQuery();
            }
            catch (Exception ex)
            {
                return "orcl執行錯誤信息：" + ex.Message;
            }
            finally
            {
                conn.Close();
            }
            return Row.ToString();
        }
        /// <summary>
        /// Oracle查詢
        /// </summary>
        /// <param name="ConnStr">連接字符串</param>
        /// <param name="orcl">Oracle語句</param>
        /// <param name="Param">查詢字段名</param>
        /// <returns>查詢結果或錯誤信息</returns>
        public static string[] ExecuteReaderOrcl(string ConnStr, string orcl, string[] Param)
        {
            OracleConnection conn = null;
            string[] info = new string[Param.Count()];
            try
            {
                conn = new OracleConnection(ConnStr);
                conn.Open();
                OracleCommand cmd = new OracleCommand(orcl, conn);
                OracleDataReader odr = cmd.ExecuteReader();
                odr.Read();
                if(!odr.HasRows) { info[0] = "null"; return info; }
                for (int i = 0; i < Param.Count(); i++)
                {
                    info[i] = odr[Param[i]].ToString();
                }
            }
            catch (Exception ex)
            {
                info[0] = "orcl查詢錯誤信息：" + ex.Message;
                return info;
            }
            finally
            {
                conn.Close();
            }
            return info;
        }
    }