C#語言連接Mysql數據庫實現增刪改查

實現效果如圖

在此之前先下載一個mysql.dll 庫 如下
鏈接：https://pan.baidu.com/s/17Nv_1W3KbXfWgdOvWf_Stg
提取碼：hi3w
難度 : ???（全星5顆星的情況下）
在工程 添加引用，直接瀏覽到那個文件即可，選中那個dll庫

這個增刪改查可以抽離成一個SqlHelper 類，直接新建一個類庫，選中Framwork 框架下的，然后在其他工程添加引用即可;
數據庫建表語句

/* SQLyog Ultimate v10.00 Beta1 MySQL - 5.7.18-log ********************************************************************* */ /*!40101 SET NAMES utf8 */;create table `tt_user` (`id` int ,`name` varchar ,`age` int ,`address` varchar ); insert into `tt_user` (`id`, `name`, `age`, `address`) values('1','大軍','26','上海市'); insert into `tt_user` (`id`, `name`, `age`, `address`) values('2','小楊','24','云南'); insert into `tt_user` (`id`, `name`, `age`, `address`) values('3','趙劉','27','陜西'); insert into `tt_user` (`id`, `name`, `age`, `address`) values('4','李四','23','安徽'); insert into `tt_user` (`id`, `name`, `age`, `address`) values('5','老劉','30','安徽安慶'); insert into `tt_user` (`id`, `name`, `age`, `address`) values('6','王二','22','北京市'); insert into `tt_user` (`id`, `name`, `age`, `address`) values('7','123','213','213');

增刪改查核心代碼如下

using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using MySql.Data.MySqlClient;namespace ASPNetSql {class Program{static void Main(string[] args){// AddUser();// UpdateUser();QueryData();// DeleteUser();// CalcCount();}static void CalcCount(){String connetStr = "server=localhost;port=3306;user=root;password=root; database=test;";// server=127.0.0.1/localhost 代表本機，端口號port默認是3306可以不寫MySqlConnection conn = new MySqlConnection(connetStr);try{conn.Open();//開啟數據庫Console.WriteLine("已連接。。");string sql = "select count(*) from tt_user";MySqlCommand cmd = new MySqlCommand(sql, conn);object o = cmd.ExecuteScalar();//返回值即為查詢結果int count = Convert.ToInt32(o.ToString());Console.WriteLine(count);}catch (Exception e){Console.WriteLine(e.ToString());}conn.Close();//關閉連接Console.ReadKey();}static void DeleteUser(){String connetStr = "server=localhost;port=3306;user=root;password=root; database=test;";// server=127.0.0.1/localhost 代表本機，端口號port默認是3306可以不寫MySqlConnection conn = new MySqlConnection(connetStr);try{conn.Open();//開啟數據庫Console.WriteLine("已連接。。");string sql = "delete from tt_user where id=10";MySqlCommand cmd = new MySqlCommand(sql, conn);int result = cmd.ExecuteNonQuery();//返回值受數據庫中數據的行數影響Console.WriteLine("刪除完成");}catch (Exception e){Console.WriteLine(e.ToString());}conn.Close();//關閉連接Console.ReadKey();}static void UpdateUser(){String connetStr = "server=localhost;port=3306;user=root;password=root; database=test;";// server=127.0.0.1/localhost 代表本機，端口號port默認是3306可以不寫MySqlConnection conn = new MySqlConnection(connetStr);try{conn.Open();//開啟數據庫Console.WriteLine("已連接。。");string sql = "update tt_user set name='軍',address='上海市123' where id=8";MySqlCommand cmd = new MySqlCommand(sql, conn);int result = cmd.ExecuteNonQuery();//返回值受數據庫中數據的行數影響Console.WriteLine("更新完成");}catch (Exception e){Console.WriteLine(e.ToString());}conn.Close();//關閉連接Console.ReadKey();}static void AddUser(){String connetStr = "server=localhost;port=3306;user=root;password=root; database=test;";// server=127.0.0.1/localhost 代表本機，端口號port默認是3306可以不寫MySqlConnection conn = new MySqlConnection(connetStr);try{conn.Open();//開啟數據庫Console.WriteLine("已連接。。");string sql = "insert into tt_user(name,age,address) values('君','27','安徽省')";//當前時間MySqlCommand cmd = new MySqlCommand(sql, conn);int result = cmd.ExecuteNonQuery();//返回值受數據庫中數據的行數影響Console.WriteLine("插入完成");}catch (Exception e){Console.WriteLine(e.ToString());}conn.Close();//關閉連接Console.ReadKey();}static void QueryData(){String connetStr = "server=localhost;port=3306;user=root;password=root; database=test;";// server=127.0.0.1/localhost 代表本機，端口號port默認是3306可以不寫MySqlConnection conn = new MySqlConnection(connetStr);try{conn.Open();//建立連接，可能出現異常,使用try catch語句Console.WriteLine("已經建立連接");//在這里可以使用代碼對數據庫進行增刪查改的操作string sql = "select * from tt_user";MySqlCommand cmd = new MySqlCommand(sql, conn);MySqlDataReader reader = cmd.ExecuteReader();//查詢while (reader.Read())//Read（）返回值bool{//Console.WriteLine(reader[0].ToString() + " " + reader[1].ToString() + " " + reader[2].ToString());//通過read數組取值//Console.WriteLine(reader.GetString(0) + " " + reader.GetString(1) + " " + reader.GetInt16(2));//通過get方法讀取Console.WriteLine(reader.GetInt16("id") + " " + reader.GetString("name") + " " + reader.GetInt16("age") + " " + reader.GetString("address"));//通過列名索引讀取}}catch (MySqlException ex){Console.WriteLine(ex.Message);//有錯則報出錯誤}finally{conn.Close();//關閉通道}Console.ReadLine();}} }

總結

以上是生活随笔為你收集整理的C#语言连接Mysql数据库实现增删改查的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。