這期內(nèi)容當(dāng)中小編將會(huì)給大家?guī)?lái)有關(guān)C#中怎么編寫一個(gè)SqlHelper類,文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述,閱讀完這篇文章希望大家可以有所收獲。
創(chuàng)新互聯(lián),專注為中小企業(yè)提供官網(wǎng)建設(shè)、營(yíng)銷型網(wǎng)站制作、響應(yīng)式網(wǎng)站、展示型做網(wǎng)站、網(wǎng)站制作等服務(wù),幫助中小企業(yè)通過(guò)網(wǎng)站體現(xiàn)價(jià)值、有效益。幫助企業(yè)快速建站、解決網(wǎng)站建設(shè)與網(wǎng)站營(yíng)銷推廣問(wèn)題。
1.接著需要?jiǎng)?chuàng)建一個(gè)名為SqlHepler類,然后創(chuàng)建一個(gè)方法來(lái)獲取app.config文件中配置的連接字符串。
public static string GetSqlConnectionString() { return ConfigurationManager. ConnectionStrings["Sql"].ConnectionString; }
2.下面來(lái)封裝第一個(gè)SqlHepler方法,封裝一個(gè)執(zhí)行的sql 返回受影響的行數(shù)。
public static int ExecuteNonQuery(string sqlText,params SqlParameter[] parameters) { using (SqlConnection conn = new SqlConnection(GetSqlConnectionString())) { using (SqlCommand cmd=conn.CreateCommand()) { conn.Open(); //打開數(shù)據(jù)庫(kù) cmd.CommandText = sqlText; //對(duì)CommandText進(jìn)行賦值 cmd.Parameters.AddRange(parameters); //對(duì)數(shù)據(jù)庫(kù)使用參數(shù)進(jìn)行賦值 return cmd.ExecuteNonQuery(); } } }
參數(shù)說(shuō)明:sqlText:需要執(zhí)行的sql腳本,parameters:需要的參數(shù)集合
該方法主要是用于執(zhí)行,刪除、更新和插入操作,返回受影響的行數(shù)。
3.繼續(xù)封裝一個(gè)查詢操作,返回查詢結(jié)果中的第一行第一列的值
public static object ExecuteScalar(string sqlText, params SqlParameter[] parameters) { using (SqlConnection conn=new SqlConnection(GetSqlConnectionString())) { using (SqlCommand cmd=conn.CreateCommand()) { conn.Open(); cmd.CommandText = sqlText; cmd.Parameters.AddRange(parameters); return cmd.ExecuteScalar(); } } }
參數(shù)說(shuō)明:如上。
該方法的返回值第object,所以當(dāng)我們查詢的數(shù)據(jù)不知道是什么類型的時(shí)候可以使用該類。
4.在封裝個(gè)常用的查詢方法,返回一個(gè)DataTable
public static DataTable ExecuteDataTable(string sqlText, params SqlParameter[] parameters) { using (SqlDataAdapter adapter =new SqlDataAdapter(sqlText,GetSqlConnectionString())) { DataTable dt = new DataTable(); adapter.SelectCommand.Parameters.AddRange(parameters); adapter.Fill(dt); return dt; } }
參數(shù)說(shuō)明:如上。
該方法主要用于一些查詢數(shù)據(jù),dt將被填充查詢出來(lái)的數(shù)據(jù),然后返回?cái)?shù)據(jù)。
5.最后在寫封裝一個(gè)查詢方法,該方法返回的是一個(gè)SqlDataReader類型
public static SqlDataReader ExecuteReader(string sqlText, params SqlParameter[] parameters) { //SqlDataReader要求,它讀取數(shù)據(jù)的時(shí)候有,它獨(dú)占它的SqlConnection對(duì)象,而且SqlConnection必須是Open狀態(tài) SqlConnection conn = new SqlConnection(GetSqlConnectionString());//不要釋放連接,因?yàn)楹竺孢€需要連接打開狀態(tài) SqlCommand cmd = conn.CreateCommand(); conn.Open(); cmd.CommandText = sqlText; cmd.Parameters.AddRange(parameters); //CommandBehavior.CloseConnection當(dāng)SqlDataReader釋放的時(shí)候,順便把SqlConnection對(duì)象也釋放掉 return cmd.ExecuteReader(CommandBehavior.CloseConnection); }
參數(shù)說(shuō)明:依舊如上。
該方法返回的SqlDataReader 類型對(duì)象需要一直使用SqlConnection對(duì)象,所以不能釋放。該類型讀取數(shù)據(jù)是一行一行的讀取。讀取使用的是該類的Read()方法,返回值為bool判斷數(shù)據(jù)是否為空(也就是是否讀取到最后一行),該方法將自動(dòng)讀取下到下一條記錄。
作為一個(gè)初學(xué)者,本次只是簡(jiǎn)單的介紹,并復(fù)習(xí)了一下SqlHepler類。
附上全部代碼:
using System.Configuration; using System.Data; using System.Data.SqlClient; namespace UserInfoMgr { class SqlHelper { ////// 獲取連接字符串 /// ///連接字符串 public static string GetSqlConnectionString() { return ConfigurationManager.ConnectionStrings["Sql"].ConnectionString; } ////// 封裝一個(gè)執(zhí)行的sql 返回受影響的行數(shù) /// /// 執(zhí)行的sql腳本 /// 參數(shù)集合 ///受影響的行數(shù) public static int ExecuteNonQuery(string sqlText,params SqlParameter[] parameters) { using (SqlConnection conn = new SqlConnection(GetSqlConnectionString())) { using (SqlCommand cmd=conn.CreateCommand()) { conn.Open(); cmd.CommandText = sqlText; cmd.Parameters.AddRange(parameters); return cmd.ExecuteNonQuery(); } } } ////// 執(zhí)行sql,返回查詢結(jié)果中的第一行第一列的值 /// /// 執(zhí)行的sql腳本 /// 參數(shù)集合 ///查詢結(jié)果中的第一行第一列的值 public static object ExecuteScalar(string sqlText, params SqlParameter[] parameters) { using (SqlConnection conn=new SqlConnection(GetSqlConnectionString())) { using (SqlCommand cmd=conn.CreateCommand()) { conn.Open(); cmd.CommandText = sqlText; cmd.Parameters.AddRange(parameters); return cmd.ExecuteScalar(); } } } ////// 執(zhí)行sql 返回一個(gè)DataTable /// /// 執(zhí)行的sql腳本 /// 參數(shù)集合 ///返回一個(gè)DataTable public static DataTable ExecuteDataTable(string sqlText, params SqlParameter[] parameters) { using (SqlDataAdapter adapter =new SqlDataAdapter(sqlText,GetSqlConnectionString())) { DataTable dt = new DataTable(); adapter.SelectCommand.Parameters.AddRange(parameters); adapter.Fill(dt); return dt; } } ////// 執(zhí)行sql腳本 /// /// 執(zhí)行的sql腳本 /// 參數(shù)集合 ///返回一個(gè)SqlDataReader public static SqlDataReader ExecuteReader(string sqlText, params SqlParameter[] parameters) { //SqlDataReader要求,它讀取數(shù)據(jù)的時(shí)候有,它獨(dú)占它的SqlConnection對(duì)象,而且SqlConnection必須是Open狀態(tài) SqlConnection conn = new SqlConnection(GetSqlConnectionString());//不要釋放連接,因?yàn)楹竺孢€需要連接打開狀態(tài) SqlCommand cmd = conn.CreateCommand(); conn.Open(); cmd.CommandText = sqlText; cmd.Parameters.AddRange(parameters); //CommandBehavior.CloseConnection當(dāng)SqlDataReader釋放的時(shí)候,順便把SqlConnection對(duì)象也釋放掉 return cmd.ExecuteReader(CommandBehavior.CloseConnection); } } }
上述就是小編為大家分享的C#中怎么編寫一個(gè)SqlHelper類了,如果剛好有類似的疑惑,不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識(shí),歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。