C# 操作Mysql数据库例子

怼烎@ 2021-11-04 16:12 332阅读 0赞

1.using MySql.Data.MySqlClient;  
2.编写如下代码，基本上代码套路和SqlServer是类似的，把前面的My去掉，感觉就是SqlServer的代码了

代码如下：

using MySql.Data.MySqlClient;
    using System;
    using System.Data;
    
    
    namespace ToolsTest
    {
        class Program
        {
    
            static DataSet dataSet = new DataSet();
            static MySqlConnection conn;
            static void Main(string[] args)
            {
                try
                {
                    RequestDbData();
                    var datatable = dataSet.Tables[0];
                    foreach (DataRow dataRow in datatable.Rows)
                    {
                        DoUpdateDbData("zhengting", (datatable.Rows.IndexOf(dataRow) + 1).ToString());
                    }
                }
                catch(Exception ex)
                {
                    Console.WriteLine(ex.Message);
                }
                Console.ReadLine();
            }
    
            static void DoUpdateDbData(string new_str,string id)
            {
                try
                {
                    string sqlstr = $"UPDATE  user SET name='{new_str}' WHERE ID='{id}'";
                    MySqlCommand cmd = new MySqlCommand(sqlstr, conn);
                    cmd.ExecuteNonQuery();
                }
                catch(Exception ex)
                {
                    Console.WriteLine(ex.Message);
                    Console.ReadLine();
                }
            }
    
            static void RequestDbData()
            {
                Console.WriteLine("Connect to Server DataBase");
                string connectStr = "server=191.2.201.80;port=3306;database=maindb;user=root;password=123456;";
                conn = new MySqlConnection(connectStr);
                try
                {
                    conn.Open();  
                    string sqlstr = "SELECT * FROM user";
                    MySqlCommand cmd = new MySqlCommand(sqlstr, conn);
                    MySqlDataAdapter mySqlDataAdapter = new MySqlDataAdapter(cmd);
                    mySqlDataAdapter.Fill(dataSet);
                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.ToString());
                    Console.ReadLine();
                }
            }
        }
    }