沃梦达 / 编程技术 / 数据库 / 正文

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

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

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());
}

本文标题为:C#连接mysql数据库完整实例

基础教程推荐