如何同时调用两个不同函数的SQL连接方法？

Question

实际上，我正在尝试使用两个不同的函数来调用我的 mysqlconnection 函数，其中一个函数在 TASK 的帮助下在后台连续运行，另一个函数在单击按钮时运行。 当两个函数同时调用 mysqlconnection 函数时，我的代码给出了一个错误。

这是 MYSQL 连接函数代码：

public void executequeryy(CommandType type, string commandtext)
    {

        try
        {


            cmd.CommandText = commandtext;
            cmd.Connection = PublicClass.conn;
            if (type == CommandType.StoredProcedure)
            {
                cmd.CommandType = CommandType.StoredProcedure;
            }
            else
            {
                cmd.CommandType = CommandType.Text;
            }
     
                PublicClass.conn.Open();
                cmd.ExecuteNonQuery();
                PublicClass.conn.Close();
        }
        catch (Exception ex)
        {
            PublicClass.conn.Close();

        }
    }

如果有人有想法，请告诉我如何同时从多个函数调用此连接方法 2 次或更多次。

调用此 mysql 连接函数的示例代码： 连续运行函数：

 public async void fillalldata()
 {
   while(true)
   {
     await Task.Run(() =>
     {
         OverallData();   //this function fill data in continuous mode in background.
         //await Task.Delay(2000);
     });
   }
 }

这是由按钮单击调用的另一个示例函数：

  public void getenvlpdata()
  {
         
            DbClass objdata = new DbClass();
            objdata.executequeryy(CommandType.Text, "insert into OverallData(SensorID,SampleTime,Temperature,TempUnit,AlarmEnabled,AlarmLevel) values('" + SerialNumber + "','" + SampleTime + "','" + OverallValue + "','" + Unit + "','" + AlarmEnabled + "','" + AlarmLevel + "')");
  

     }

Answer 1

ADO.NET 不是线程安全的 API；您一次只能与单个逻辑流中的单个连接进行对话；这可以是单个线程，也可以是单个异步流，只要它正确await每个调用，这样事情就不会重叠。看来您在这里只有一个连接（可能还有一个命令，这是一个糟糕的主意）；这种情况是不允许的。

对单独的流使用单独的连接。

作为旁注（但很重要）：

1. 参数； 不要连接数据来创建 SQL ，您可能做错了什么
2. 任何时候输入 async void 时都

Answer 2

最后我得到了解决我的问题的方法。
我创建了两个不同的连接字符串。一种用于连续运行功能，第二种用于单次运行（单击按钮后）。
这是两个连接字符串的示例代码：

    //create connection for continuous running function..
    public static void CreateContinuousConnection() 
    {
        try
        {
            PublicClass.continuousconn.ConnectionString = "datasource = localhost;database=wivib_x;username= root; password=1234";

        }
        catch { }
    }



    //create connection for single running function.
    public static void CreateSingleConnection()
    {
        try
        {
            PublicClass.singleconn.ConnectionString = "datasource = localhost;database=wivib_x;username= root; password=1234";

        }
        catch { }
    }