c#数据连接mysql数据库代码

using System;
using MySql.Data.MySqlClient;

public class MySQLConnector
{
    private MySqlConnection connection;
    private string server;
    private string database;
    private string uid;
    private string password;

    public MySQLConnector()
    {
        Initialize();
    }

    private void Initialize()
    {
        server = "localhost"; // MySQL数据库服务器的地址
        database = "mydatabase"; // 数据库名称
        uid = "username"; // 用户名
        password = "password"; // 密码

        string connectionString = $"SERVER={server};DATABASE={database};UID={uid};PASSWORD={password};";
        connection = new MySqlConnection(connectionString);
    }

    // 打开数据库连接
    private bool OpenConnection()
    {
        try
        {
            connection.Open();
            return true;
        }
        catch (MySqlException ex)
        {
            Console.WriteLine(ex.Message);
            return false;
        }
    }

    // 关闭数据库连接
    private bool CloseConnection()
    {
        try
        {
            connection.Close();
            return true;
        }
        catch (MySqlException ex)
        {
            Console.WriteLine(ex.Message);
            return false;
        }
    }

    // 执行查询语句，并返回结果集
    public MySqlDataReader ExecuteQuery(string query)
    {
        if (OpenConnection() == true)
        {
            MySqlCommand cmd = new MySqlCommand(query, connection);
            return cmd.ExecuteReader();
        }
        else
        {
            return null;
        }
    }

    // 执行插入、更新、删除等非查询语句
    public bool ExecuteNonQuery(string query)
    {
        if (OpenConnection() == true)
        {
            MySqlCommand cmd = new MySqlCommand(query, connection);
            int rowsAffected = cmd.ExecuteNonQuery();
            CloseConnection();
            return rowsAffected > 0;
        }
        else
        {
            return false;
        }
    }
}

MySQLConnector connector = new MySQLConnector();

// 执行查询语句
string query = "SELECT * FROM users";
MySqlDataReader reader = connector.ExecuteQuery(query);
if (reader != null)
{
    while (reader.Read())
    {
        Console.WriteLine($"User ID: {reader["id"]}, Name: {reader["name"]}, Email: {reader["email"]}");
    }
    reader.Close();
}

// 执行插入语句
string insertQuery = "INSERT INTO users (name, email) VALUES ('John Doe', 'john@example.com')";
bool insertSuccess = connector.ExecuteNonQuery(insertQuery);
if (insertSuccess)
{
    Console.WriteLine("Insertion successful.");
}

// 执行更新语句
string updateQuery = "UPDATE users SET email='updated@example.com' WHERE id=1";
bool updateSuccess = connector.ExecuteNonQuery(updateQuery);
if (updateSuccess)
{
    Console.WriteLine("Update successful.");
}

// 执行删除语句
string deleteQuery = "DELETE FROM users WHERE id=2";
bool deleteSuccess = connector.ExecuteNonQuery(deleteQuery);
if (deleteSuccess)
{
    Console.WriteLine("Deletion successful.");
}