C# 訪問 MySql 數據庫（通過 MySql.Data）

1. 添加 NuGet 包

　　在解決方案管理器視圖中的目標項目上右鍵  -> 管理 NuGet 程序包；

添加 MySql.Data 包，如下圖所示：　　

 

 

2. 通過代碼訪問 MySQL 數據庫

• 　數據庫幫助類： 　　

using MySql.Data.MySqlClient;

namespace MySqlDatabaseHelper
{
    public class MySqlDatabaseHelper
    {
        public string dbConnStr;
        private MySqlConnection dbConn = null;
        private MySqlCommand dbCmd = null;
        private MySqlDataReader dbDataReader = null;

        public MySqlDatabaseHelper(string connectionString)
        {
            dbConnStr = connectionString;
            dbConn = new MySqlConnection(dbConnStr);
            dbCmd = new MySqlCommand();

            dbCmd.Connection = dbConn;
        }

        ~MySqlDatabaseHelper()
        {
            Close();
        }

        public void Open()
        {
            dbConn.Open();
        }

        public void Close()
        {
            dbConn.Close();
        }

        public MySqlDataReader ExecuteReader(string sqlStr_Read)
        {
            dbCmd.CommandText = sqlStr_Read;

            dbDataReader = dbCmd.ExecuteReader();

            return dbDataReader;
        }

        public int ExecuteNonQuery(string sqlStr_Insert)
        {
            dbCmd.CommandText = sqlStr_Insert;

            int result = dbCmd.ExecuteNonQuery();

            return result;
        }
    }
}

 

• 訪問調用示例：

using MySql.Data.MySqlClient;

namespace MySqlDatabaseHelper
{
    class Program
    {
        static void Main(string[] args)
        {
            string ConnectionString = "server = 127.0.0.1; userid = root; password = 123456; database = test_db; persistsecurityinfo = True;";
            MySqlDatabaseHelper db_Test = new MySqlDatabaseHelper(ConnectionString);

            // 打開數據庫
            db_Test.Open();

            // sql 查詢語句
            string sqlCmdStr = null;

            // 新增記錄
            sqlCmdStr = "insert into chipinfo_20200209(chipid, chiptype) values('5','S10')";
            db_Test.ExecuteNonQuery(sqlCmdStr);

            // 刪除記錄
            sqlCmdStr = "delete from chipinfo_20200209 where chipid = 4";
            db_Test.ExecuteNonQuery(sqlCmdStr);

            // 修改數據
            sqlCmdStr = "update chipinfo_20200209 set boardid = '666' where chipid = '5'";
            db_Test.ExecuteNonQuery(sqlCmdStr);

            // 查詢數據
            sqlCmdStr = "select * from chipinfo_20200209";
            MySqlDataReader dataReader = db_Test.ExecuteReader(sqlCmdStr);
            while (dataReader.Read())
            {
                string str = dataReader["chiptype"].ToString();
            }
            dataReader.Close();

            // 關閉數據庫
            db_Test.Close();
        }
    }
}