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

測試如下：

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

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

*將鏈接數據庫的信息放入配置文件中(app.config)

    <appSettings>
        <add key="mysql" value="server=127.0.0.1;User Id=******;password=******;Database="******"/>
    </appSettings>

*在程序啟動時進行啟動

  private string mysqlString = ConfigurationManager.AppSettings["mysql"].ToString();

 

①建立mysql數據庫鏈接

 

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

 

②建立執行命令語句對象

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

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

 

        //編寫sql語句，對數據做相應處理
        public void setData()
        {
            MySqlConnection mysql = getMySqlConn();
            //查詢sql
            String sqlSearch = "select * from student";
            //插入sql
            //String sqlInsert = "insert into student values (12,'張三',25,'大專')";
            //修改sql
            //String sqlUpdate = "update student set name='李四' where id= 3";
            //刪除sql
            //String sqlDel = "delete from student where id = 12";
            
            //四種語句對象
            MySqlCommand mySqlCommand = getSqlCommand(sqlSearch, mysql);
            //MySqlCommand mySqlCommand = getSqlCommand(sqlInsert, mysql);
            //MySqlCommand mySqlCommand = getSqlCommand(sqlUpdate, mysql);
            //MySqlCommand mySqlCommand = getSqlCommand(sqlDel, mysql);

            mysql.Open();
　　　　　　　
            getResultset(mySqlCommand);
            //getInsert(mySqlCommand);
            //getUpdate(mySqlCommand);
            //getDel(mySqlCommand);
            //記得關閉
            mysql.Close();
        }

 

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

        //查詢並獲得結果集並遍歷
        public void getResultset(MySqlCommand mySqlCommand)
        {
            MySqlDataReader reader = mySqlCommand.ExecuteReader();
            try
            {
                while (reader.Read())
                {
                    if (reader.HasRows)
                    {
                        //MessageBox.Show("歌曲名:" + reader.GetString(1) + "|歌手:" + reader.GetString(2));
                    }
                }
            }
            catch (Exception)
            {
                MessageBox.Show("查詢失敗了！");
            }
            finally
            {
                reader.Close();
            }
        }

④Ⅱ.添加數據

 

        //添加數據
        public static void getInsert(MySqlCommand mySqlCommand)
        {
            try
            {
                mySqlCommand.ExecuteNonQuery();
            }
            catch (Exception ex)
            {
                String message = ex.Message;
                Console.WriteLine("插入數據失敗了！" + message);
            }

        }

 

④Ⅲ.修改數據

 

        //修改數據
        public static void getUpdate(MySqlCommand mySqlCommand)
        {
            try
            {
                mySqlCommand.ExecuteNonQuery();
            }
            catch (Exception ex)
            {
                String message = ex.Message;
                Console.WriteLine("修改數據失敗了！" + message);
            }
        }

 

④Ⅳ.刪除數據

 

        //刪除數據
        public static void getDel(MySqlCommand mySqlCommand)
        {
            try
            {
                mySqlCommand.ExecuteNonQuery();
            }
            catch (Exception ex)
            {
                String message = ex.Message;
                Console.WriteLine("刪除數據失敗了！" + message);
            }
        }