C#连接MYSQL数据库，包括增删查改_MySQL

C#连接MYSQL数据库，包括增删查改！

public class DBLINK

    {

          public MySqlConnection GetConn()

        {

            MySqlConnection mysqlconn = new MySqlConnection("server=localhost;pwd=123;user=root;database=pfms;charset='gb2312'");//1,服务器 2 Mysql的密码 3 mysql的用户名 4 数据库名 5 数据库编码方式

            return mysqlconn;

        }

    }

    public class SQLEXQ : DBLINK

    {

        /// 查询操作

        public DataTable Select(string sql)

        {

            MySqlConnection mysqlconn = null;

            MySqlDataAdapter sda = null;

            DataTable dt = null;

            try

            {

                mysqlconn = base.GetConn();

新智能企业网站管理系统2.1

系统管理：密码管理、系统配置、数据库备份、后台日志管理 管理员管理模块：管理员的添删改查以及管理员的权限设置 会员管理系统：注册会员的管理 IP锁定管理：IP地址的锁定 企业信息模块：公司简介、公司文化等栏目的随意设置 新闻系统模块：公司新闻、文章发布 产品系统模块：包括产品类别管理 友情连接模块：友情连接管理 招聘系统模块：招聘发布以及应聘管理 在线留言系统：客户留言信息的管理

0

查看详情

                sda = new MySqlDataAdapter(sql, mysqlconn);

                dt = new DataTable();

                sda.Fill(dt);

                return dt;

            }

            catch (Exception)

            {

                throw;

            }

        }

        /// 增操作

        public int Add(string sql)

        {

            MySqlConnection conn = null;

            MySqlCommand cmd = null;

            try

            {

                conn = base.GetConn();

                conn.Open();

                cmd = new MySqlCommand(sql, conn);

                int i = cmd.ExecuteNonQuery();

                conn.Close();

                return i;

            }

            catch (Exception)

            {

                throw;

            }

        }

       // 修改

        public int Change(string sql)

        {

            MySqlConnection conn = null;

            MySqlCommand cmd = null;

            try

            {

                conn = base.GetConn();

                conn.Open();

                cmd = new MySqlCommand(sql, conn);

                int i = cmd.ExecuteNonQuery();

                conn.Close();

                return i;

            }

            catch (Exception)

            {

                throw;

            }

        }

      //删除

        public int Delete(string sql)

        {

            MySqlConnection conn = null;

            MySqlCommand cmd = null;

            try

            {

                conn = base.GetConn();

                conn.Open();

                cmd = new MySqlCommand(sql, conn);

                int i = cmd.ExecuteNonQuery();

                conn.Close();

                return i;

            }

            catch (Exception)

            {

                throw;

            }

        }

    }

}

具体使用方法：

            //查询

            string sql1 = "select max(inumber)+1 as num  from income ";//查询sql语句

            DataTable dt = mysql.Select(sql1);//放到数据表里

            if (dt.Rows.Count > 0)//是否有数据

             {

               for (int i = 0; i 

                {

                    ia.textBox_bh.Text = dt.Rows[i]["num"].ToString();//显示到编辑框中

                }

             }

             其他类似，只要把sql语句换一下，就OK了！for里边是做具体的操作，把数据读出来，放到哪里，或者删除，或者修改，你做主！

对了，我用的是ＭＹＳＱＬ．data来连接数据库的，所以需要using MySql.Data.MySqlClient;//导入用MySql的包，这就话！还需要把MySql.Data.dll先导入到C#项目的应用中去！控件下载地址;http://download.csdn.net/my