using System;using System.Data;using System.Windows.Forms;using MySql.Data.MySqlClient;
namespace WindowsFormsApp1{ public partial class Form1 : Form { public Form1() { InitializeComponent(); }
private void button1_Click(object sender, EventArgs e) { string connStr = "Data Source=IP地址;Port=端口号;User ID=账号;Password=密码;Database=数据库;Pooling=true;Charset=utf8mb4"; string cmdStr = "SELECT * FROM 数据表";
#region DataAdapter方式 MySqlDataAdapter adp = new MySqlDataAdapter(cmdStr, connStr); //用 SelectCommand 初始化 DataAdapter 类的新实例 DataSet set = new DataSet(); adp.Fill(set); //填充 DataSet dgv.DataSource = set.Tables[0]; //操作数据 #endregion
#region Connection方式 MySqlConnection conn = new MySqlConnection(connStr); //使用指定的连接字符串初始化 Connection 类的新实例 MySqlCommand cmd = new MySqlCommand(cmdStr, conn); //初始化具有查询文本和 Connection 的 Command 类的新实例 conn.Open(); //使用连接字符串所指定的属性设置打开数据库连接 MySqlDataReader reader = cmd.ExecuteReader(); //将 CommandText 发送到 Connection 并生成一个 DataReader object[] row = new object[reader.FieldCount]; while (reader.Read()) //使 DataReader 前进到下一条记录 { //一次读取该行所有字段 reader.GetValues(row); txt.AppendText(string.Join("\t", row));
//一次读取该行某个字段 //for (int i = 0; i < reader.FieldCount; i++) //{ // txt.AppendText(reader.IsDBNull(i) ? "(NULL)\t" : $"{reader.GetString(i)}\t"); //}
txt.AppendText(Environment.NewLine); } conn.Close(); //关闭到数据源的连接
cmd.CommandText = "INSERT INTO 数据表 VALUES (...);"; //重新设置要对数据源执行的 SQL 语句或存储过程 conn.Open(); //使用连接字符串所指定的属性设置打开数据库连接 //int affect = cmd.ExecuteNonQuery(); //针对 Connection 执行 SQL 语句并返回受影响的行数 conn.Close(); //关闭到数据源的连接
#region 参数化SQL（可以防止SQL注入） //使用： // 1.定义包含参数的SQL语句，用@符号声明参数； // 2.为SQL语句中出现的每一个参数定义参数对象SqlParameter，并将参数对象加入到SqlCommand对象中； cmd.CommandText = "SELECT * FROM 数据表 WHERE 字段1=@参数1 AND 字段2=@参数2"; //声明参数 cmd.Parameters.AddRange( new MySqlParameter[] { new MySqlParameter("@参数1", MySqlDbType.数据类型) { Value = 参数值1 }, new MySqlParameter("@参数2", MySqlDbType.数据类型) { Value = 参数值2 } }); //定义参数对象、赋值，添加 conn.Open(); reader = cmd.ExecuteReader(); DataTable dt = new DataTable(); dt.Load(reader); dgv.DataSource = dt; conn.Close(); #endregion #endregion } }}
