一、連接字符串(使用配置文件)
添加對 System.Configuration的引用,并且在封裝類中引入該namespace
/// <summary> /// 功能:讀取配置文件中的連接字符串 /// 返回值類型:string /// </summary> /// <param name="conName">參數:配置文件中的連接字符串名稱</param> /// <returns>返回值:string 連接字符串</returns> public static string GetConnectString(string conName) { try { return ConfigurationManager.ConnectionStrings[conName].ConnectionString; } catch (Exception e) { throw e; } }二、SqlConnection對象
/// <summary> /// 功能:根據給定的連接字符串創建一個SqlConnection對象 /// 返回類型:SqlConnection /// </summary> /// <param name="conStr">參數:連接字符串</param> /// <returns>返回值:SqlConnection對象</returns> public static SqlConnection GetConnect(string conStr) { return new SqlConnection(conStr); }/// <summary> /// 功能:打開數據庫連接 /// </summary> /// <param name="Con">參數:SqlConnection對象</param> public static void OpenDBConnet(SqlConnection Con) { try { if (Con.State == ConnectionState.Open) { return; } else { Con.Open(); } } catch (SqlException e) { throw e; } }
/// <summary> /// 功能:關閉數據庫連接 /// </summary> /// <param name="Con">參數:SqlConnection對象</param> public static void CloseDBConnect(SqlConnection Con) { try { if (Con.State == ConnectionState.Closed) { return; } else { Con.Close(); } } catch (SqlException e) { throw e; } }三、同步操作數據庫
SqlDataReader對象
/// <summary> /// 功能:執行存儲過程并返回一個SqlDataReader對象 /// </summary> /// <param name="sql">參數:存儲過程名</param> /// <param name="Con">參數:SqlConnection對象</param> /// <param name="parameters">參數:SqlParameter參數數組</param> /// <returns>返回值:SqlDataReader對象</returns> public static SqlDataReader GetSdrBySp(string sql, SqlConnection Con, params SqlParameter[] parameters) { SqlCommand Cmd = null; try { Cmd = new SqlCommand(sql, Con); DBHelper.OpenDBConnet(Con); Cmd.CommandType = CommandType.StoredPRocedure; foreach (SqlParameter parameter in parameters) { Cmd.Parameters.Add(parameter); } } catch (SqlException s) { throw s; } return Cmd.ExecuteReader(CommandBehavior.CloseConnection); }
/// <summary> /// 功能:執行T-SQL語句語句并返回一個SqlDataReader對象 /// </summary> /// <param name="sql">參數:T-SQL語句</param> /// <param name="Con">參數:SqlConnection對象</param> /// <param name="parameters">參數:SqlParameter參數數組</param> /// <returns>返回值:SqlDataReader對象</returns> public static SqlDataReader GetSdrByTSql(string sql, SqlConnection Con, params SqlParameter[] parameters) { SqlCommand Cmd = null; try { Cmd = new SqlCommand(sql, Con); DBHelper.OpenDBConnet(Con); Cmd.CommandType = CommandType.Text; foreach (SqlParameter parameter in parameters) { Cmd.Parameters.Add(parameter); } } catch (SqlException s) { throw s; } return Cmd.ExecuteReader(CommandBehavior.CloseConnection); }ExecuteNonQuery
/// <summary> /// 功能:執行存儲過程返回受影響的行數 /// 返回類型:int /// </summary> /// <param name="sql">參數:存儲過程名</param> /// <param name="Con">參數:SqlConnection對象</param> /// <param name="parameters">參數:SqlParameter參數數組</param> /// <returns>返回值:int 受影響的行數</returns> public static int GetEnqBySp(string sql, SqlConnection Con, params SqlParameter[] parameters) { SqlCommand Cmd = null; try { Cmd = new SqlCommand(sql, Con); DBHelper.OpenDBConnet(Con); Cmd.CommandType = CommandType.StoredProcedure; foreach (SqlParameter parameter in parameters) { Cmd.Parameters.Add(parameter); } } catch (SqlException s) { throw s; } return Cmd.ExecuteNonQuery(); } /// <summary> /// 功能:執行T-SQL語句返回受影響的行數 /// </summary> /// <param name="sql">參數:T-SQL語句</param> /// <param name="Con">參數:SqlConnection對象</param> /// <param name="parameters">參數:SqlParameter參數數組</param> /// <returns>返回值:int 受影響的行數</returns> public static int GetEnqByTSql(string sql, SqlConnection Con, params SqlParameter[] parameters) { SqlCommand Cmd = null; try { Cmd = new SqlCommand(sql, Con); DBHelper.OpenDBConnet(Con); Cmd.CommandType = CommandType.Text; foreach (SqlParameter parameter in parameters) { Cmd.Parameters.Add(parameter); } } catch (SqlException s) { throw s; } return Cmd.ExecuteNonQuery(); }ExecuteScalar
/// <summary> /// 功能:通過T-SQl語句執行SqlCommand的ExecuteScalar()方法返回object類型對象 /// </summary> /// <param name="sql">參數:T-SQL語句</param> /// <param name="Con">參數:SqlConnection對象</param> /// <param name="parameters">參數:SqlParameter參數數組</param> /// <returns>返回值:object對象</returns> public static object GetEScalarByTSql(string sql, SqlConnection Con, params SqlParameter[] parameters) { SqlCommand Cmd = null; try { Cmd = new SqlCommand(sql, Con); DBHelper.OpenDBConnet(Con); Cmd.CommandType = CommandType.Text; foreach (SqlParameter parameter in parameters) { Cmd.Parameters.Add(parameter); } } catch (SqlException s) { throw s; } return Cmd.ExecuteScalar(); } /// <summary> /// 功能:通過執行T-SQL語句返回一個DataSet數據集對象 /// </summary> /// <param name="sql">參數:T-SQL語句</param> /// <param name="tableName">參數:DataSet表名</param> /// <param name="Con">參數:SqlConnection對象</param> /// <param name="parameters">參數:可變SqlParameter參數數組</param> /// <returns>返回值:DataSet數據集對象</returns> public static DataSet GetDsByTSql(string sql, string tableName, SqlConnection Con, params SqlParameter[] parameters) { SqlCommand Cmd = null; DataSet Ds = null; SqlDataAdapter Sda = null; try { Ds = new DataSet(tableName); Cmd = new SqlCommand(sql, Con); DBHelper.OpenDBConnet(Con); Cmd.CommandType = CommandType.Text;
新聞熱點
疑難解答