C#连接mysql数据库完整实例

前言

本文将介绍在C#中如何连接mysql数据库。通过阅读本文，你将学到如下知识：

• 下载并安装与mysql连接的必备工具；
• C#连接mysql数据库的代码；
• 如何进行数据库的增加/删除/修改/查询。

步骤

步骤一：安装mysql和mysql .NET Connector

1. 下载并安装mysql数据库：从mysql官网下载安装mysql数据库，可采用默认的安装选项；
2. 下载并安装mysql connector .NET：从mysql官网下载mysql connector .NET并安装，注意安装后，你将在C#项目中使用mysql connector .NET。

步骤二：添加mysql .NET Connector引用到项目中

1. 启动Visual Studio并打开你的C#项目，单击右键解决方案并选择“添加引用…”；
2. 在“引用管理器”选项卡中，单击“浏览”按钮；
3. 找到mysql .NET Connector安装目录，例如：“C:\Program Files (x86)\MySQL\Connector NET 6.9.8\Assemblies\v4.5”；
4. 选中“MySql.Data.dll”文件并单击“添加”按钮；
5. 单击“确定”按钮。

步骤三：编写C#连接mysql的代码

下面是一个简单的示例，它用C#连接mysql数据库，并进行插入/删除/修改/查询操作：

using System;
using System.Data;
using MySql.Data.MySqlClient;

namespace MYSQLDemo
{
    class Program
    {
        static string connectionString = "Server=localhost;Database=test;Uid=root;Pwd=yourpassword;";

        static void Main(string[] args)
        {
            // Connect to mysql database.
            MySqlConnection conn = new MySqlConnection(connectionString);
            conn.Open();

            // Add data to database.
            AddData(conn, "john", 25);

            // Modify the data.
            ModifyData(conn, "john", 26);

            // Delete the data.
            DeleteData(conn, "john");

            // Query data from the database.
            QueryData(conn);

            // Disconnect from database.
            conn.Close();
        }

        static void ModifyData(MySqlConnection conn, string name, int age)
        {
            MySqlCommand cmd = new MySqlCommand("UPDATE user SET age=@age WHERE name=@name", conn);
            cmd.Parameters.AddWithValue("@name", name);
            cmd.Parameters.AddWithValue("@age", age);
            cmd.ExecuteNonQuery();
        }

        static void AddData(MySqlConnection conn, string name, int age)
        {
            MySqlCommand cmd = new MySqlCommand("INSERT INTO user (name, age) VALUES (@name, @age)", conn);
            cmd.Parameters.AddWithValue("@name", name);
            cmd.Parameters.AddWithValue("@age", age);
            cmd.ExecuteNonQuery();
        }

        static void DeleteData(MySqlConnection conn, string name)
        {
            MySqlCommand cmd = new MySqlCommand("DELETE FROM user WHERE name=@name", conn);
            cmd.Parameters.AddWithValue("@name", name);
            cmd.ExecuteNonQuery();
        }

        static void QueryData(MySqlConnection conn)
        {
            MySqlCommand cmd = new MySqlCommand("SELECT * FROM user", conn);
            MySqlDataAdapter adapter = new MySqlDataAdapter(cmd);
            DataSet ds = new DataSet();
            adapter.Fill(ds);

            foreach (DataRow row in ds.Tables[0].Rows)
            {
                Console.WriteLine(row["name"].ToString() + " " + row["age"].ToString());
            }
        }
    }
}

步骤四：运行C#连接到mysql的代码

若以上所有步骤都按照要求操作，在执行Run之后，你应该看到以下的输出信息：

john 25

执行该程序时，它将连接到mysql数据库、“添加”一个条目、“修改”该条目的数据、“删除”该条目并查询结果。当然，你需要确认在数据库中有“test”数据库和其对应的“user”表。

总结

现在你已经掌握了如何在C#中连接到mysql数据库，并进行诸如插入、删除、修改和查询这样的操作。若你还有其他问题，请参见mysql官方文档或者其他可靠的在线资源以获取帮助。

示例说明

为了更好地理解并记忆以上内容，下面介绍另外两个示例：

示例一：连接到另一个主机

在此示例中，你需要将mysql数据库连接到一个远程主机或服务器。

string connectionString = "Server=remotehost;Database=test;Uid=root;Pwd=yourpassword;";
MySqlConnection conn = new MySqlConnection(connectionString);

示例二：执行mysql存储过程

在此示例中，你需要了解如何调用mysql存储过程。

MySqlCommand cmd = new MySqlCommand("testprocedure", conn);
cmd.CommandType = CommandType.StoredProcedure;
MySqlDataReader reader = cmd.ExecuteReader();
while (reader.Read())
{
    Console.WriteLine(reader["name"].ToString() + " " + reader["age"].ToString());
}