c#与mysql连接和操作教程（增、删、改、查）

一、mysql的连接（使用的是vs2019）

1. 在一个项目中选择 工具 > NgtGet包管理器 > 管理解决方案的NuGet程序包

2. 搜索MySql.Data，然后下载，并在右边选着对应的项目进行安装（ps：每个项目要连接数据库的话，都得安装一次）

3. 数据库的连接

方法一：

//导入命名空间
using MySql.Data.MySqlClient;

static void Main(string[] args)
{
	 //定义mysql连接字符串
	string constring = "data source=localhost;database=test1;user id=root;password=root;pooling=true;charset=utf8;";
	 //连接mysql
	MySqlConnection msc = new MySqlConnection(constring);
}

1
2
3
4
5
6
7
8
9
10
11

方法二：使用SqlConnectionStringBuilder来帮助我们生成连接字符串，这样就可以这样就可以分开来写DataSource，InitialCatalog，UserID ，Password 等…

//与数据库连接的信息
	MySqlConnectionStringBuilder builder = new MySqlConnectionStringBuilder();
	//用户名
	builder.UserID = "root";
	//密码
	builder.Password = "root";
	//服务器地址
	builder.Server = "localhost";
	//连接时的数据库
	builder.Database = "lcz";
	//定义与数据连接的链接
	MySqlConnection connection = new MySqlConnection(builder.ConnectionString);
	
1
2
3
4
5
6
7
8
9
10
11
12
13

4. MySQL连接字符串参数详细解析

二、使用c#对MySql进行增加

//增加
	if (msc.State == System.Data.ConnectionState.Closed)
                msc.Open();
	string userName = Console.ReadLine();
	string userPassword = Console.ReadLine();
	
	//创建MySql语句
	string sql = "insert into subscribers values('" + userName + "','" + userPassword + "')";
	//创建用与实现MySql语句的对象
	MySqlCommand cmd = new MySqlCommand(sql, msc);
	// 执行MySql语句进行插入
	cmd.ExecuteNonQuery();
1
2
3
4
5
6
7
8
9
10
11
12

三、使用c#对MySql进行删除

//删除
//打开连接（处于关闭才打开，重复打开会报错）
    if (msc.State == System.Data.ConnectionState.Closed)
                msc.Open();
	string userName = Console.ReadLine();
	
	//创建MySql语句
	string sql = "delete from subscribers where user_name = '" + userName + "'";
	//创建用于实现MySql语句对象
	MySqlCommand cmd = new MySqlCommand(sql, msc);
	// 执行MySql语句进行操作
	cmd.ExecuteNonQuery();
1
2
3
4
5
6
7
8
9
10
11
12

四、使用c#对MySql进行修改

//修改
	if (msc.State == System.Data.ConnectionState.Closed)
		msc.Open();
	string userName = Console.ReadLine();
	string userPassword = Console.ReadLine();
	
	//创建Sql语句
	string sql = "update subscribers set user_password = '" + userPassword + "' where user_name = '" + userName + "'";
	//创建用于实现MySql语句对象
	MySqlCommand cmd = new MySqlCommand(sql, msc);
	// 执行Sql语句实现进行修改
	cmd.ExecuteNonQuery();
1
2
3
4
5
6
7
8
9
10
11
12

五、使用c#对MySql进行查询

// 查询
	//写入sql语句
	string sql = "select * from subscribers";
	//创建命令对象
	MySqlCommand cmd = new MySqlCommand(sql, msc);
	//执行命令,ExcuteReader返回的是DataReader对象
	MySqlDataReader reader = cmd.ExecuteReader();
	 
	while (reader.Read())
	{
	 Console.WriteLine(reader.GetString(0)); //第一个字段
	 //也可以写出：reader.GetString("字段名")
	 Console.WriteLine(reader.GetString(1)); //第二个字段
	}
1
2
3
4
5
6
7
8
9
10
11
12
13
14