天天看點

C#連接配接MySql資料庫C#連接配接MySql資料庫

C#連接配接MySql資料庫

連接配接資料庫

private void btn(object sender, RoutedEventArgs e)
        {
            string connect = "server=localhost;database=book;uid=root;pwd=123456";
            MySqlConnection conn = new MySqlConnection(connect);
            try
            {
                conn.Open();
                MessageBox.Show("連接配接成功!");
            }
            catch (Exception ex)
            {
                MessageBox.Show("連接配接失敗!");
                throw;
            }
        }
           

運作結果

C#連接配接MySql資料庫C#連接配接MySql資料庫

查詢

查詢條件固定

#region 查-查詢條件固定
                string sql = "select * from book";
                MySqlCommand cmd = new MySqlCommand(sql, conn);
                MySqlDataReader reader = cmd.ExecuteReader();   //執行executeReader()傳回一個MySqlReader對象
                string str = "";
                while (reader.Read())
                {
                    str += reader.GetInt32("id") + "===" + reader.GetString("name") + "===" + reader.GetString("writer") + "\n";
                }
                MessageBox.Show(str);
                #endregion
           
C#連接配接MySql資料庫C#連接配接MySql資料庫

查詢條件不固定

#region 查-查詢條件不固定
                string sql = "select * from book where writer='籽月'";
                MySqlCommand cmd = new MySqlCommand(sql, conn);
                MySqlDataReader reader = cmd.ExecuteReader();   //執行executeReader()傳回一個MySqlReader對象
                string str = "";
                while (reader.Read())
                {
                    str += reader.GetInt32("id") + "===" + reader.GetString("name") + "===" + reader.GetString("writer") + "\n";
                }
                MessageBox.Show(str);
                #endregion
           
C#連接配接MySql資料庫C#連接配接MySql資料庫

查詢傳回一個值

string sql = "select count(*) from book";
                MySqlCommand cmd = new MySqlCommand(sql, conn);
                object result = cmd.ExecuteScalar();//執行查詢,并傳回查詢結果集中的第一行的第一列,所有其他的行和列将被忽略,select語句無記錄傳回時,executeScalar()傳回null值
                if (result != null)
                {
                    int count = int.Parse(result.ToString());
                    MessageBox.Show(count.ToString());
                }
           

增删改

#region 增
                //string sql = "insert into book(id,name,price,count,writer) values('5','深入淺出WPF','33','2','劉鐵猛')";
                //MySqlCommand cmd = new MySqlCommand(sql, conn);
                //int result = cmd.ExecuteNonQuery();
                //if (result == 1)
                //{
                //    MessageBox.Show("添加成功!");
                //}
                #endregion
                #region 删
                //string sql = "delete from book where id=5";
                //MySqlCommand cmd = new MySqlCommand(sql, conn);
                //int result = cmd.ExecuteNonQuery();
                //if (result == 1)
                //{
                //    MessageBox.Show("删除成功!");
                //}
                #endregion
                #region 改
                //string sql = "update  book set price=99 where writer='劉鐵猛'";
                //MySqlCommand cmd = new MySqlCommand(sql, conn);
                //int result = cmd.ExecuteNonQuery();
                //if (result == 1)
                //{
                //    MessageBox.Show("修改成功!");
                //}
                #endregion