天天看點

C#編寫Mysql資料庫插入、修改、删除資料

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using MySql.Data.MySqlClient;
namespace mysqltest
{
    class mysql
    {
        public static List<string> list_tblName, coltype;
        static String connetStr = "server=127.0.0.1;port=3306;user=root;password=mysql123; database=mytest;";
       // static String connetStr = "server=127.0.0.1;port=3306;user=root;password=mysql123;";
        // server=127.0.0.1/localhost 代表本機,端口号port預設是3306可以不寫
        static MySqlConnection conn = new MySqlConnection(connetStr);
          public static void InsertData(string tableName, string ColName1, string Data1,
            string ColName2, string Data2)
        {
            try
            {
                  conn.open();
                MySqlCommand cmd = new MySqlCommand("insert into " + tableName + " set " + ColName1 + " = '" + Data1 + "'"
                    + "," + ColName2 + "= '" + Data2 + "'", conn);
                cmd.ExecuteNonQuery();
            }
            catch (Exception ex)
            {
                main.AddMsgErr(ex.Message);
            }

        }
        public static void DeltRow(string tableName, int RowId)
        {
            try
            {
            conn.open();
                MySqlCommand cmd = new MySqlCommand("delete from " + tableName + " where id = @id", conn);
                cmd.Parameters.AddWithValue("id", RowId);
                cmd.ExecuteNonQuery();
            }
            catch (Exception ex)
            {


                main.AddMsgErr(ex.Message);
            }
        }
        public static void AlterRow(string tableName, string RowId, string ColName1, string Data1)
        {
            try
            {
                  conn.open();
                MySqlCommand cmd = new MySqlCommand("update " + tableName + " set " + ColName1 + " = @pwd where id = 2" , conn);
                cmd.Parameters.AddWithValue("pwd", Data1);
                cmd.ExecuteNonQuery();
            }
            catch (Exception ex)
            {
                
                main.AddMsgErr(ex.Message);
            }
        }
        }