1. 程式人生 > >[C#]獲取連接MySql數據庫及常用的CRUD操作

[C#]獲取連接MySql數據庫及常用的CRUD操作

into 對象 new 常用 final 對數 stat void row

測試如下:

首先添加引用:MySql.Data.dll

鏈接:http://pan.baidu.com/s/1dEQgLpf 密碼:bnyu

①建立mysql數據庫鏈接

1         //建立mysql數據庫鏈接
2         public MySqlConnection getMySqlConn()
3         {
4             string constr = "server=localhost;User Id=root;password=123456;Database=qqmusicdistinct";
5             MySqlConnection mycon = new
MySqlConnection(constr); 6 return mycon; 7 }

②建立執行命令語句對象

1         //建立執行命令語句對象
2         public MySqlCommand getSqlCommand(String sql, MySqlConnection mysql)
3         {
4             MySqlCommand mySqlCommand = new MySqlCommand(sql, mysql);
5             return mySqlCommand;
6 }

③編寫sql語句,對數據做相應處理

 1         //編寫sql語句,對數據做相應處理
 2         public void setData()
 3         {
 4             MySqlConnection mysql = getMySqlConn();
 5             //查詢sql
 6             String sqlSearch = "select * from student";
 7             //插入sql
 8             //String sqlInsert = "insert into student values (12,‘張三‘,25,‘大專‘)
"; 9 //修改sql 10 //String sqlUpdate = "update student set name=‘李四‘ where id= 3"; 11 //刪除sql 12 //String sqlDel = "delete from student where id = 12"; 13 14 //四種語句對象 15 MySqlCommand mySqlCommand = getSqlCommand(sqlSearch, mysql); 16 //MySqlCommand mySqlCommand = getSqlCommand(sqlInsert, mysql); 17 //MySqlCommand mySqlCommand = getSqlCommand(sqlUpdate, mysql); 18 //MySqlCommand mySqlCommand = getSqlCommand(sqlDel, mysql); 19 20 mysql.Open(); 21         22 getResultset(mySqlCommand); 23 //getInsert(mySqlCommand); 24 //getUpdate(mySqlCommand); 25 //getDel(mySqlCommand); 26 //記得關閉 27 mysql.Close(); 28 }

④Ⅰ.查詢並獲得結果集並遍歷

 1         //查詢並獲得結果集並遍歷
 2         public void getResultset(MySqlCommand mySqlCommand)
 3         {
 4             MySqlDataReader reader = mySqlCommand.ExecuteReader();
 5             try
 6             {
 7                 while (reader.Read())
 8                 {
 9                     if (reader.HasRows)
10                     {
11                         //MessageBox.Show("歌曲名:" + reader.GetString(1) + "|歌手:" + reader.GetString(2));
12                     }
13                 }
14             }
15             catch (Exception)
16             {
17                 MessageBox.Show("查詢失敗了!");
18             }
19             finally
20             {
21                 reader.Close();
22             }
23         }

④Ⅱ.添加數據

 1         //添加數據
 2         public static void getInsert(MySqlCommand mySqlCommand)
 3         {
 4             try
 5             {
 6                 mySqlCommand.ExecuteNonQuery();
 7             }
 8             catch (Exception ex)
 9             {
10                 String message = ex.Message;
11                 Console.WriteLine("插入數據失敗了!" + message);
12             }
13 
14         }

④Ⅲ.修改數據

 1         //修改數據
 2         public static void getUpdate(MySqlCommand mySqlCommand)
 3         {
 4             try
 5             {
 6                 mySqlCommand.ExecuteNonQuery();
 7             }
 8             catch (Exception ex)
 9             {
10                 String message = ex.Message;
11                 Console.WriteLine("修改數據失敗了!" + message);
12             }
13         }

④Ⅳ.刪除數據

 1         //刪除數據
 2         public static void getDel(MySqlCommand mySqlCommand)
 3         {
 4             try
 5             {
 6                 mySqlCommand.ExecuteNonQuery();
 7             }
 8             catch (Exception ex)
 9             {
10                 String message = ex.Message;
11                 Console.WriteLine("刪除數據失敗了!" + message);
12             }
13         }

[C#]獲取連接MySql數據庫及常用的CRUD操作