C#项目连接MySQL数据库

• 这里我是将方法全部都放在一个新建的MySQL类中了。也可以单独实现方法。
• 这里只提供了简单的增删改查。
• 这里是用C#的控制台应用程序做示范。也可以在Web Form或者Win Form等C#项目中通过这个方法实现连接并操作MySQL数据库。
• 在进行操作前，请确保MySQL和Visual Studio已经安装完成，并且MySQL的服务已经打开。
• 数据库名字和表名：
  
  

1.新建C#控制台项目，添加MySQL的引用，新建MySQL类。

C:\Program Files (x86)\MySQL\Connector.NET 6.9\Assemblies\v4.5

2.编写MySQL类的代码。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using MySql.Data.MySqlClient;
using System.Data;

namespace _001_MySQL的连接
{
    class MySQL
    {
        string connStr;
        MySqlConnection conn;
        string cmdText;
        MySqlCommand cmd;

        public MySQL(string dataBaseName)
        {
            connStr = string.Format(
                "Database={0};DataSource=127.0.0.1;User=root;Pwd=root;port=3306",
                dataBaseName
                );
            conn = new MySqlConnection(connStr);
        }
        /// <summary>
        /// 通过DataAdapter类和DataSet类来实现查询一个表的数据。
        /// 需要输入的形参是：想要查询的表名
        /// </summary>
        /// <param name="tableName"></param>
        public void Select(string tableName)
        {
            conn.Open();

            cmdText = string.Format(
                "SELECT * FROM {0}", tableName
                );
            cmd = new MySqlCommand(cmdText, conn);

            MySqlDataAdapter dad = new MySqlDataAdapter(cmd);
            DataSet dset = new DataSet();
            dad.Fill(dset, tableName);
            for (int i = 0; i < dset.Tables[0].Rows.Count; i++)
            {
                for (int j = 0; j < dset.Tables[0].Columns.Count; j++)
                {
                    if (j == dset.Tables[0].Columns.Count - 1)
                        Console.Write(dset.Tables[0].Rows[i][j].ToString());
                    else
                        Console.Write(dset.Tables[0].Rows[i][j].ToString() + ":");
                }
                Console.WriteLine();
            }

            conn.Close();
        }
        /// <summary>
        /// 通过DataReader类来实现查询一个表的数据。
        /// 需要输入的形参是：想要查询的表名，不固定个数的列名。
        /// </summary>
        /// <param name="tableName"></param>
        /// <param name="columnsName"></param>
        public void Select(string tableName, params string[] columnsName)
        {
            conn.Open();

            cmdText = string.Format(
                "SELECT * FROM {0}", tableName
                );
            cmd = new MySqlCommand(cmdText, conn);

            MySqlDataReader dataReader = cmd.ExecuteReader();
            while (dataReader.Read())
            {
                Console.WriteLine(
                    dataReader.GetString(columnsName[0])
                    + ":" +
                    dataReader.GetString(columnsName[1])
                    );
            }
            dataReader.Close();

            conn.Close();
        }
        /// <summary>
        /// 输入表名、ID列和Name列的名称来插入一条数据。
        /// </summary>
        /// <param name="tableName"></param>
        /// <param name="id"></param>
        /// <param name="name"></param>
        public void Insert(string tableName, int id, string name)
        {
            conn.Open();

            cmdText = string.Format(
                "INSERT INTO {0} VALUES({1},'{2}')",
                tableName, id, name
                );
            cmd = new MySqlCommand(cmdText, conn);
            cmd.ExecuteNonQuery();

            conn.Close();

        }
        /// <summary>
        /// 通过ID来删除表中的一条数据
        /// </summary>
        /// <param name="tableName"></param>
        /// <param name="id"></param>
        public void Delete(string tableName, int id)
        {
            conn.Open();

            cmdText = string.Format(
                "DELETE FROM {0} WHERE ID={1}",
                tableName, id
                );
            cmd = new MySqlCommand(cmdText, conn);
            cmd.ExecuteNonQuery();

            conn.Close();
        }
        /// <summary>
        /// 通过ID来修改表中的一条数据的Name值
        /// </summary>
        /// <param name="tableName"></param>
        /// <param name="id"></param>
        /// <param name="name"></param>
        public void Update(string tableName, int id, string name)
        {
            conn.Open();
            
            cmdText = string.Format(
                "UPDATE {0} SET NAME='{1}' WHERE ID={2}",
                tableName, name, id
                );
            cmd = new MySqlCommand(cmdText, conn);            
            cmd.ExecuteNonQuery();

            conn.Close();
        }
        /// <summary>
        /// @ 和 cmd.Parameters.AddWithValue("string","str");。
        /// 这种方法不能用AddWithValue方法来添加表的名字，会报错，
        /// 只能添加列的属性的值。
        /// 因为通过这种方法来添加表名的时候，
        /// 它会这样添加表名的信息：UPDATE 'TABLENAME' SET ...。
        /// 多了一对单引号，所以会报错。
        /// </summary>
        /// <param name="id"></param>
        /// <param name="name"></param>
        public void UpdateByParameters(int id, string name)
        {
            conn.Open();

            cmdText = 
                "UPDATE TEST_CONNECTION SET [email protected]_NAME WHERE [email protected]_ID";
            cmd = new MySqlCommand(cmdText, conn);
            //cmd.Parameters.AddWithValue("TABLENAME", tableName);
            cmd.Parameters.AddWithValue("INPUT_NAME", name);
            cmd.Parameters.AddWithValue("INPUT_ID", id);
            cmd.ExecuteNonQuery();

            conn.Close();
        }
    }
}

3.编写主函数的测试代码。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace _001_MySQL的连接
{
    class Program
    {
        static void Main(string[] args)
        {
            MySQL mySql = new MySQL("yyymarshal");

            Console.WriteLine("Select()方法：");
            mySql.Select("test_connection");

            Console.WriteLine("\nInsert()方法：\n插入id=5，name=Test的一条数据");
            mySql.Insert("test_connection", 5, "Test");
            Console.WriteLine("---------------");
            Console.WriteLine("Select()方法：");
            mySql.Select("test_connection", "id", "name");

            Console.WriteLine("\nUpdate()方法：\n将id=5的数据的name修改为PPP");
            mySql.Update("test_connection", 5, "PPP");
            Console.WriteLine("---------------");
            Console.WriteLine("Select()方法：");
            mySql.Select("test_connection");

            Console.WriteLine("\nUpdateByParameters()方法：\n将id=5的数据的name修改为OOO");
            mySql.UpdateByParameters(5, "OOO");
            Console.WriteLine("---------------");
            Console.WriteLine("Select()方法：");
            mySql.Select("test_connection");

            Console.WriteLine("\nDelete()方法：\n删除id=5的数据");
            mySql.Delete("test_connection", 5);
            Console.WriteLine("---------------");
            Console.WriteLine("Select()方法：");
            mySql.Select("test_connection");

            Console.ReadKey();
        }
    }
}

4.运行测试

运行前的数据表的数据：

运行结果：