NuGet包引入MySql.Data

连接

string str_sqlcon = string.Format("server={0};user id={1};password={2};database={3};port={4};Charset=utf8", '数据库地址','用户名', '密码', '库', '端口');
MySqlConnection conn = new MySqlConnection(str_sqlcon);

查询

conn.Open();
string sql = string.Format("SELECT title FROM 表");
MySqlCommand cmd = new MySqlCommand(sql, conn);
MySqlDataReader reader = cmd.ExecuteReader();
while (reader.Read())
{
textbox1.AppendText(reader["title"].ToString() + "\r\n");
}
conn.Close();
reader.Close();

插入

conn.Open();
string strSql = “INSERT INTO `表` ( `title` ) VALUES(@title);”;
MySqlCommand cmd = new MySqlCommand();
cmd.Connection = conn;
cmd.CommandText = strSql;
cmd.Parameters.AddWithValue(“title”, “内容”);
int result = cmd.ExecuteNonQuery();
textbox1.AppendText(“影响行数”+result + “\r\n”);
conn.Close();

改

string sqls = “UPDATE `表`  SET `title` = @title”;
conn.Open();
MySqlCommand cmd = new MySqlCommand();
cmd.Connection = conn;
cmd.CommandText = sqls;
cmd.Parameters.AddWithValue(“title”, “值”);
int result = cmd.ExecuteNonQuery();
conn.Close();
textbox1.AppendText(“影响行数”+result + “\r\n”);

删

string sqls = “DELETE FROM 表WHERE `title` = @title”;
conn.Open();
MySqlCommand cmd = new MySqlCommand();
cmd.Connection = conn;
cmd.CommandText = sqls;
cmd.Parameters.AddWithValue(“title”, “值”);
int result = cmd.ExecuteNonQuery();
conn.Close();
textbox1.AppendText(“影响行数”+result + “\r\n”);