C#连接数据库插入数据

首先是安装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[0];
            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[0];
            String Value = "'" + value[0];
            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 (name.Length > 0)
            {
                if (password.Length > 0)
                {
                    if (ip.Length > 0)
                    {
                        if (port.Length > 0)
                        {
                            if (database.Length > 0)
                            {
                                if (charset.Length > 0)
                                {
                                    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("用户名不能为空", "提示！");
            }
        }

 

 

 。。。不能写了，忘了一件事情。。需要先安装数据库