C#连接MySQL操作详细教程

介绍

C#是一种广泛使用的编程语言，MySQL是一种流行的关系型数据库管理系统。在开发过程中，我们可能会需要使用C#连接MySQL来读写数据库中的数据。本文将介绍如何使用C#连接MySQL并进行相应的操作。

环境准备

在进行C#连接MySQL操作前，需要安装MySQL数据库，并且安装C#的MySQL连接组件（MySQL Connector）。可以在MySQL官网下载MySQL Connector安装包。

连接MySQL

连接MySQL需要使用MySqlConnection类，并指定相应的服务器地址、用户名、密码和数据库名称。以下是连接MySQL的示例代码：

using MySql.Data.MySqlClient;

string connStr = "server=localhost;user=root;database=test;password=root;";
MySqlConnection conn = new MySqlConnection(connStr);
try
{
    conn.Open();
    Console.WriteLine("Connected to MySQL!");
}
catch (Exception ex)
{
    Console.WriteLine(ex.ToString());
}
finally
{
    conn.Close();
}

在示例代码中，connStr变量指定了连接MySQL所需的信息，包括服务器地址、用户名、密码和数据库名称。MySqlConnection类的实例用于连接MySQL。在try块中，使用Open方法打开连接。在catch块中，处理连接时可能出现的异常。在finally块中，使用Close方法关闭连接。

执行SQL语句

连接MySQL后，可以使用MySqlCommand类执行SQL语句。以下是执行查询语句的示例代码：

using MySql.Data.MySqlClient;

string connStr = "server=localhost;user=root;database=test;password=root;";
MySqlConnection conn = new MySqlConnection(connStr);
try
{
    conn.Open();

    string sql = "SELECT * FROM users";
    MySqlCommand cmd = new MySqlCommand(sql, conn);
    MySqlDataReader rdr = cmd.ExecuteReader();

    while (rdr.Read())
    {
        Console.WriteLine("{0} {1} {2}",
            rdr.GetInt32(0), rdr.GetString(1), rdr.GetString(2));
    }
    rdr.Close();
}
catch (Exception ex)
{
    Console.WriteLine(ex.ToString());
}
finally
{
    conn.Close();
}

在示例代码中，使用MySqlCommand类的实例cmd执行查询语句sql。使用ExecuteReader方法执行查询，并返回一个MySqlDataReader类的实例rdr。使用rdr.Read()方法读取每一条查询结果，并使用GetInt32和GetString方法获取相应的字段值。

以下是执行插入语句的示例代码：

using MySql.Data.MySqlClient;

string connStr = "server=localhost;user=root;database=test;password=root;";
MySqlConnection conn = new MySqlConnection(connStr);
try
{
    conn.Open();

    string sql = "INSERT INTO users(name, email) VALUES(@name, @email)";
    MySqlCommand cmd = new MySqlCommand(sql, conn);
    cmd.Parameters.AddWithValue("@name", "John");
    cmd.Parameters.AddWithValue("@email", "john@example.com");
    int rowsAffected = cmd.ExecuteNonQuery();
    Console.WriteLine("Rows affected: {0}", rowsAffected);
}
catch (Exception ex)
{
    Console.WriteLine(ex.ToString());
}
finally
{
    conn.Close();
}

在示例代码中，使用MySqlCommand类的实例cmd执行插入语句sql。使用Parameters.AddWithValue方法设置参数值。使用ExecuteNonQuery方法执行插入，并返回受影响的行数。