mysql数据通讯方式_c# 与 Mysql 的通讯方式总结
兩種開發方式
1.使用 vs 自帶的可視化工具,不推薦。
在 vs 的項目中添加 ‘數據集’,然后通過可視化的工具添加數據庫為數據源,默認可添加 SQL Server 和 Oracle 等,添加 Mysql 前需要額外安裝組件。
優點,自帶 sql 語句中特殊字符的轉義,不會出現 sql 注入的問題,配合數據綁定可以在項目前期快速推進項目進度。
缺點:可視化工具的使用并不流行,不利于開發團隊的招募和項目后期的修改維護。許多常用的功能很難使用,如:存儲過程,事務,連接池控制等。
2.引用 mysql.data.dll ,在此基礎上進行開發,推薦。
完全由代碼完成通訊過程。
優點:可以方便的使用各種功能,
缺點:需要手寫代碼,開發速度稍慢。
完整的通訊過程
1.建立連接,連接分 “長連接” 和 “短連接”
長連接在高頻次的通訊時快速高效,但是占用資源,在并發訪問下容易耗盡網絡資源,對于帶寬較低的局域網來說,如果大量使用長連接,會占用網速,影響使用體驗。
短連接在使用時 open, 使用完成后 close,此時連接資源會進入連接池,等待下次連接時使用。雖然資源未被釋放掉,但連接池的開銷不大,是完全可以接受的。短連接一樣需要考慮并發問題。
短連接在使用完成后可以直接 dispose,或者使用 using(){} 來限定連接的作用域,使用完成后自動釋放掉,不進入連接池,這種方式資源占用最少,但在需要反復建立連接的情況下連接效率較低。
在實際開發的時候最好使用短連接,并在使用結束后關閉并放入連接池。
string connStr = "server=127.0.0.1; port=3306; user id=user1; Password=pass1; database=data1; pooling = true";
MySqlConnection conn= newMySqlConnection(connStr);
conn.Open();
conn.Close();
2.使用連接創建 sql 命令并執行
1.純 sql 語句,執行后有三種返回方式:
cmd.ExecuteScalar(); // 查詢結果僅一行一列,直接接收
string connStr = "server=127.0.0.1; port=3306; user id=user1; Password=pass1; database=data1; pooling = true";
MySqlConnection conn= newMySqlConnection(connStr);
conn.Open();
MySqlCommand cmd=conn.CreateCommand();string name = "Tom";
cmd.CommandText= string.Format("select count(*) from student where Name = '{0}';", name);object obj = cmd.ExecuteScalar(); //可能未nullint count = 0;
if (!obj.Equals(DBNull.Value))
{
count = Convert.ToInt32(obj);}conn.Close();
MySqlDataReader reader = cmd.ExecuteReader();? // 通過 reader 獲得大量數據
string connStr = "server=127.0.0.1; port=3306; user id=user1; Password=pass1; database=data1; pooling = true";
MySqlConnection conn= newMySqlConnection(connStr);
conn.Open();
MySqlCommand cmd=conn.CreateCommand();
cmd.CommandText= string.Format("select Name from student;");
MySqlDataReader reader=cmd.ExecuteReader();
List list = new List();while(reader.Read())
{
list.Add(reader.GetString("Name"));
}
reader.Close();
conn.Close();
cmd.ExecuteNonQuery(); // 獲得增刪改語句執行后影響的行數
string connStr = "server=127.0.0.1; port=3306; user id=user1; Password=pass1; database=data1; pooling = true";
MySqlConnection conn= newMySqlConnection(connStr);
conn.Open();
MySqlCommand cmd=conn.CreateCommand();string name = "Tom";
cmd.CommandText= string.Format("update student SET Name='Tommy' where Name = '{0}';", name);int count =cmd.ExecuteNonQuery();
conn.Close();
普通 sql 語句的缺點:如果上面例子中的 name 參數中帶有單引號,整個 sql 語句將執行錯誤,因為未對特殊字符進行轉義。主要特殊字符有單引號,反斜杠,# 等,而這些特殊字符在不同的使用情況下有時需要轉義,有時不需要轉義。Mysql 提供了類似 QUOTE(str) 這樣的字符串處理函數,但不能完全滿足要求。
這就是 sql 注入,sql 注入的概念網上資料較多,在此不再贅述,而常用的解決方案是采用參數化的 sql 語句。
2.sql 語句和 sql 參數
帶有參數的 sql 語句和 sql 參數會分開傳入數據庫服務器中,服務器先將 sql 語句進行編譯,然后將 sql 參數導入編譯后的 sql 語句中(在此過程中自動對特殊字符進行轉義),從而從根源上防止了 sql 注入的發生。
string connStr = "server=127.0.0.1; port=3306; user id=user1; Password=pass1; database=data1; pooling = true";
MySqlConnection conn= newMySqlConnection(connStr);
conn.Open();
MySqlCommand cmd=conn.CreateCommand();
cmd.CommandText= "select count(*) from student where Name = @Name;";cmd.Parameters.AddWithValue("@Name", "Tom");
object obj = cmd.ExecuteScalar(); //可能為null int count = 0;if (!obj.Equals(DBNull.Value)) { count=Convert.ToInt32(obj); } conn.Close();
3.DataAdapter
private static void Test(MySqlCommand cmd)
{
//獲取記錄
DataTable dt1 = new DataTable();
cmd.CommandText = "select * from table1;";
MySqlDataAdapter da = new MySqlDataAdapter(cmd);
da.Fill(dt1);
//插入記錄
cmd.CommandText = "select * from pet where 1=0;";
da = new MySqlDataAdapter(cmd);
MySqlCommandBuilder cb = new MySqlCommandBuilder(da);
da.UpdateCommand = cb.GetInsertCommand();
DataTable dt2 = new DataTable();
da.Fill(dt2);
//對dt2進行賦值
da.Update(dt2);
}
4.事務
多條 sql 語句的組合會出現某一條 sql 語句執行出錯,而其他 sql 語句順利執行的情況,這可能與預期不符合。此時需要使用事務。
事務在執行出錯時可以回滾。
事務往往帶有多條 sql 語句,在使用參數化的 sql 語句時要注意參數名稱不能相同。
conn.Open();
MySqlCommand cmd=conn.CreateCommand();
MySqlTransaction myTrans=conn.BeginTransaction();
cmd.Connection=conn;
cmd.Transaction=myTrans;
cmd.CommandText= "";
cmd.ExecuteNonQuery();
myTrans.Commit();
conn.Close();
5.存儲過程
不論是 sql 語句還是事務,在傳輸指令的時候都需要耗費大量的時間,數據庫編譯這些指令也需要耗費大量時間,這不利于高訪問量的數據庫的運行。
存儲過程是將 sql 指令寫在數據庫中,此時數據庫直接完成編譯,與數據庫通訊是只需要傳遞參數即可。節省了傳輸時間和編譯時間。
conn.Open();
MySqlCommand cmd=conn.CreateCommand();
cmd.CommandType=CommandType.StoredProcedure;
cmd.CommandText= "SpFillStudent";
MySqlParameter paraMoney;
paraMoney= cmd.Parameters.Add("@inMoney", MySqlDbType.Decimal);
paraMoney.Direction=ParameterDirection.Input;
paraMoney.Value= 50;
MySqlParameter paraTradeType;
paraTradeType= cmd.Parameters.Add("@inTradeType", MySqlDbType.String);
paraTradeType.Direction=ParameterDirection.Input;
paraTradeType.Value= "會員卡充值";
MySqlParameter paraPayDetailStr;
paraPayDetailStr= cmd.Parameters.Add("@inPayDetailStr", MySqlDbType.String);
paraPayDetailStr.Direction=ParameterDirection.Input;
paraPayDetailStr.Value= "";
MySqlParameter paraOutResult;
paraOutResult= cmd.Parameters.Add("@outResult", MySqlDbType.String);
paraOutResult.Direction=ParameterDirection.Output;
cmd.ExecuteNonQuery();string result = (string)paraOutResult.Value;
conn.Close();
總結
以上是生活随笔為你收集整理的mysql数据通讯方式_c# 与 Mysql 的通讯方式总结的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: mysql long raw_读取Ora
- 下一篇: 手写识别底层原理_LinkedList底