Ado.Net连接Mysql数据库

private static string connStr = "Server=localhost;Port=3306;Database=xxx;Uid=xxx;Pwd=xxx;";

        public static void ExecuteNonQuery(string sqlQuery, params MySqlParameter[] p)

        {

            using (MySqlConnection conn = new MySqlConnection(connStr))

            {

                conn.Open();

                using (MySqlCommand cmd=new MySqlCommand())

                {

                    cmd.CommandText = sqlQuery;

                    cmd.Parameters.AddRange(p);

                    cmd.ExecuteNonQuery();

                }

            }

        }

        public static object ExcuteScalar(string sql,params MySqlParameter[] p)

        {

            using (MySqlConnection conn = new MySqlConnection(connStr))

            {

                conn.Open();

                using (MySqlCommand cmd = new MySqlCommand())

                {

                    cmd.Connection = conn;

                    cmd.CommandText = sql;

                    cmd.Parameters.AddRange(p);

                    return cmd.ExecuteScalar();

                }

            }

        }