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("用户名不能为空", "提示！");
            }
        }