C#处理MySql多个返回集的方法

    MySqlDataAdapter mysqldata = new MySqlDataAdapter();
    MySqlCommand sqlCommand = new MySqlCommand();
    sqlCommand.CommandText = StoredName;//存储过程名称
    sqlCommand.CommandType = CommandType.StoredProcedure;
    sqlCommand.Connection = conn;

    for (int i = 0; i < Parameters.Count; i++)
    {
 sqlCommand.Parameters.AddWithValue(Parameters[i].name, Parameters[i].pvalue);
    }
    conn.Open();
    List<DataTable> dts = new List<DataTable>();
    MySqlDataReader mysqlreser = sqlCommand.ExecuteReader();//mysqlreader无构造函数
    bool re = true;
    System.Threading.CancellationToken _cts;//用于Cancel用的
    while (re)
    {
 DataTable dt = new DataTable();
 mysqldata.FillAsync(dt, mysqlreser).Wait(_cts);//等待线程完成
   dts.Add(dt);
 re = mysqlreser.NextResult();//取下一个结果集
      //  Trace.WriteLine(dt.Rows.Count);       

    }
    conn.Close();
    return dts;
}

 

这里我用的阻塞主线程等待dt完成填充，不知道是否合适

复制代码 mysqldata.FillAsync(dt, mysqlreser).Wait(_cts);//等待线程完成
补充一下

 

conn是连接数据库用的连接实例MySqlConnection

sqlparameters是我声明的一个结构体，用来保存mysql的存储过程的输入参数

复制代码 public struct sqlparameters
{
        public string name;//存储过程的输入字符名称
        public object pvalue;//存储过程的输入变量
        public sqlparameters(string names, object pvalues)
        {
            name = names;
            pvalue = pvalues;
        }
}

 

希望本文所述对大家的C#程序设计有所帮助。