

方法一:
//导入命名空间
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;";//连接mysqlMySqlConnection msc = new MySqlConnection(constring);
}
方法二:使用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);



//增加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();
//删除
//打开连接(处于关闭才打开,重复打开会报错)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();
//修改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();
// 查询//写入sql语句steing sql = "select * from subscribers";//创建命令对象MySqlCommand cmd = new MySqlCommand(sql, msc);//执行命令,ExcuteReader返回的是DataReader对象MySqlDataReader reader = cmd.ExecuteReader();while (reader.Read()){Console.WriteLine(reader.GetString(0));Console.WriteLine(reader.GetStrin}