首先是安装JDBC操作数据库的包,,当然自己看着办哈,可以自己下载以后导入,或者直接让软件本身下载
第一种方式
第二种 咱自己下载个低版本的
点击这个链接
点击以后呢可以直接下载下来,然后导入(大家百度怎么导入.dll哈)
也可以直接让软件自己弄
安装好了
namespace MqttDemo { class DataBase { public static MySqlConnection getMySqlCon(string username, string password, string ip, string port, string iotdatebase, string charset) { String connetStr = "server= " + ip + ";port=" + port + ";user =" + username + ";password=" + password + ";database =" + iotdatebase + ";charset =" + charset; // String mySqlCon = ConfigurationManager.ConnectionStrings["MySqlCon"].ConnectionString; MySqlConnection mysql = new MySqlConnection(connetStr); return mysql; } public static void getInsert(MySqlCommand mySqlCommand) { try { mySqlCommand.ExecuteNonQuery(); } catch (Exception ex) { String message = ex.Message; Console.WriteLine("插入数据失败了!" + message); } } //插入SQL组合 public static String groupInsert(String from, params String[] arg) { String Value = arg[]; bool bl = false; foreach (String str in arg) { if (bl == true) Value = Value + "," + str; else bl = true; } String sql = "insert into " + from + " values(NULL," + Value + ")"; return sql; } public static String groupInsert(String from, String[] option, String[] value) { String Option = option[]; String Value = ]; bool bl = false; foreach (String str in option) { if (bl == true) Option = Option + "," + str; else bl = true; } bl = false; foreach (String str in value) { if (bl == true) Value = Value + "'" + "," + "'" + str; else bl = true; } Value = Value + "'"; String sql = "insert into " + from + "(" + Option + ")" + " values(" + Value + ")"; return sql; } } }
点击按钮连接数据库
private void button18_Click(object sender, EventArgs e) { string name = textBox21.Text.ToString(); string password = textBox22.Text.ToString(); string ip = textBox23.Text.ToString(); string port = textBox24.Text.ToString(); string database = textBox26.Text.ToString(); string charset = textBox27.Text.ToString(); ) { ) { ) { ) { ) { ) { if (button18.Text == "连接") { mySqlConnection = DataBase.getMySqlCon(name, password, ip, port, database, charset); mySqlConnection.Open(); //MessageBox.Show("连接了", "234324"); button18.Text = "断开"; } else { button18.Text = "连接"; try { mySqlConnection.Close(); } catch (Exception) { throw; } } } else { MessageBox.Show("编码方式不能为空", "提示!"); } } else { MessageBox.Show("数据库名字不能为空", "提示!"); } } else { MessageBox.Show("端口号不能为空", "提示!"); } } else { MessageBox.Show("密码不能为空", "提示!"); } } else { MessageBox.Show("密码不能为空", "提示!"); } } else { MessageBox.Show("用户名不能为空", "提示!"); } }
。。。不能写了,忘了一件事情。。需要先安装数据库