C# 与 MySql 的操作介绍 下载 远程访问

直接上代码.

/// <summary>
        /// 建立mysql数据库链接
        /// </summary>
        /// <returns></returns>
        public static MySqlConnection getMySqlCon()
        {
            String mysqlStr = "Database=数据库名称;Data Source=数据库远程ip;User Id=数据库里面的用户名;Password=数据库用户名的密码;pooling=false;CharSet=utf8;port=3306";
            // String mySqlCon = ConfigurationManager.ConnectionStrings["MySqlCon"].ConnectionString;
            MySqlConnection mysql = new MySqlConnection(mysqlStr);
            return mysql;
        }
        /// <summary>
        /// 建立执行命令语句对象
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="mysql"></param>
        /// <returns></returns>
        public static MySqlCommand getSqlCommand(String sql, MySqlConnection mysql)
        {
            MySqlCommand mySqlCommand = new MySqlCommand(sql, mysql);
            //  MySqlCommand mySqlCommand = new MySqlCommand(sql);
            // mySqlCommand.Connection = mysql;
            return mySqlCommand;
        }
        /// <summary>
        /// 查询并获得结果集并遍历
        /// </summary>
        /// <param name="mySqlCommand"></param>
        public static void getResultset(MySqlCommand mySqlCommand)
        {
            MySqlDataReader reader = mySqlCommand.ExecuteReader();
            try
            {
                while (reader.Read())
                {
                    if (reader.HasRows)
                    {
                        Console.WriteLine("name:" + reader.GetString(0));
                    }
                }
            }
            catch (Exception)
            {

                Console.WriteLine("查询失败了！");
            }
            finally
            {
                reader.Close();
            }
        }
        /// <summary>
        /// 添加数据
        /// </summary>
        /// <param name="mySqlCommand"></param>
        public static void getInsert(MySqlCommand mySqlCommand)
        {
            try
            {
                mySqlCommand.ExecuteNonQuery();
            }
            catch (Exception ex)
            {
                String message = ex.Message;
                Console.WriteLine("插入数据失败了！" + message);
            }

        }
        /// <summary>
        /// 修改数据
        /// </summary>
        /// <param name="mySqlCommand"></param>
        public static void getUpdate(MySqlCommand mySqlCommand)
        {
            try
            {
                mySqlCommand.ExecuteNonQuery();
            }
            catch (Exception ex)
            {

                String message = ex.Message;
                Console.WriteLine("修改数据失败了！" + message);
            }
        }
        /// <summary>
        /// 删除数据
        /// </summary>
        /// <param name="mySqlCommand"></param>
        public static void getDel(MySqlCommand mySqlCommand)
        {
            try
            {
                mySqlCommand.ExecuteNonQuery();
            }
            catch (Exception ex)
            {
                String message = ex.Message;
                Console.WriteLine("删除数据失败了！" + message);
            }
        }

下面是操作.

  MySqlConnection mysql = getMySqlCon();
            //查询sql
            String sqlSearch = "select * from 你数据库的表名";
            ////插入sql
            //String sqlInsert = "insert into test values ('中方')";
            ////修改sql
            //String sqlUpdate = "update test set name='李四' where id= 3";
            ////删除sql
            //String sqlDel = "delete from test where id = 12";
            ////打印SQL语句
            //Console.WriteLine(sqlDel);
            ////四种语句对象
            //MySqlCommand mySqlCommand = getSqlCommand(sqlSearch, mysql);
            //MySqlCommand mySqlCommand = getSqlCommand(sqlInsert, mysql);
            //MySqlCommand mySqlCommand = getSqlCommand(sqlUpdate, mysql);
            MySqlCommand mySqlCommand = getSqlCommand(sqlSearch, mysql);
            mysql.Open();
            getResultset(mySqlCommand);
           // getInsert(mySqlCommand);
            //getUpdate(mySqlCommand);
            //getDel(mySqlCommand);
            //记得关闭
            mysql.Close();
            Console.WriteLine("完成");
            Console.ReadLine();

记录清是多久前在网上copy的.今天发到这里做个记录.

上面的代码需要引用 MySql.Data.dll 这个dll文件.我在我的机器上,vs2010 + net 2.0 测试我的服务器上远程连接成功.如果你和我一样是用的cPanel X,在cPanel X里面需要设置一个远程MySql,使用通配符%就可以了.