C＃参照付きのスレッドからデータテーブルを返す

Question

参照を持つクラスから別のメソッドを呼び出すメソッドがあり、そのメソッドはデータテーブルを返します。

スレッド内でクエリを実行しようとしていますが、スレッド内でクエリ自体を実行するのは簡単ですが、スレッドからデータテーブルを返すにはどうすればよいですか？クラスを呼び出すメソッドの

例：

private void loadCombo(string sqlComand, string value, ComboBox loadBox) 
     {   
      DataTable dt = new DataTable(); 

      //Thread thread = new Thread(() => sqlScript.loadCombo(sqlComand, value, loadBox)); 
      //thread.start(); 

      dt = sqlScript.loadCombo(sqlComand, value, loadBox); 
      loadBox.ValueMember = value; 
      loadBox.DataSource = dt; 
      loadBox.Refresh(); 
     } 

Answer 1

別のスレッドでデータベースクエリを実行する代わりに、async-awaitアプローチを使用します。これは、1つのスレッドで実行され、UIをブロックしません。

public class SqlScript 
{ 
    public async Task<DataTable> LoadDataAsync(string command, object value) 
    { 
     // Load data asynchronously by using ..Async methods 
    } 
} 

private async Task loadComboAsync(string sqlComand, string value, ComboBox loadBox) 
{   
    var data = await sqlScript.LoadDataAsync(sqlComand, value); 

    loadBox.ValueMember = columnNameWhichRepresentValue; 
    loadBox.DataSource = data; 
} 

を設定するあなたは、「データの照会」の操作を分離する必要があり、これとComboBoxのために

そして、あなたはとにかくそれを行います新しいデータソースを設定し、loadBox.Refreshメソッドを呼び出す必要はありません。

Task.Runを使用しないでください。データベース操作は、他のスレッドで実行する必要がある「重い」ものは何もしません。データベース操作はコマンドを送信して応答を待つだけなので、待機のために別のスレッドを使うことはリソースの無駄です。
は、代わりにSqlConnection.OpenAsyncとSqlCommand.ExecuteReaderAsync方法

public async Task<DataTable> loadCombo(string sqlCommand, string value) 
{ 
    var yourConnectionString = "DataSource=..."; 
    using (var connection = new SqlConnection(yourConnectionString)) 
    using (var command = new SqlCommand(sqlCommand, connection)) 
    { 
     await connection.OpenAsync(); 
     var reader = await command.ExecuteReaderAsync(); 

     var data = new DataTable(); 
     data.Load(reader); 
     return data; 
    } 
} 

Answer 2

これは単純な質問のように聞こえます。

あなたはTask使用することができます（同様にasync/awaitを、それは通常、複数実行を防ぐために、ボタンに対応する有効/無効にするために使用されます、オプションであるかもしれない）UIをブロックせずにイベントハンドラで、長時間実行されるコードを実行します。あなたはまだUI要素にアセスを起動する必要があります。

async void loadCombo(string sqlComand, string value, ComboBox loadBox) 
{ 
    // disable button 

    await Task.Run(() => 
    { 
     var dt = sqlScript.loadCombo(sqlComand, value, loadBox); 
     Invoke((Action)(() => 
     { 
      loadBox.ValueMember = value; // is it out parameter? anyway, copying your code 
      loadBox.DataSource = dt; 
      loadBox.Refresh(); 
     })); 
    } 

    // enable button 
} 

別のスレッドからDataTableを作成し、合格するために何の問題があるべきではありません。

Answer 3

を使用し、あなたに@Sinatrをありがとう、私はちょうどあなたの答えビットをtwekしなければならなかった、以下のコードは動作するようです。

private async void loadCombo(string sqlCommand, string value, ComboBox loadBox) 
     { 
      await Task.Run(() => 
      { 
       var dt = sqlScript.loadCombo(sqlCommand, value, loadBox); 
       Invoke((Action)(() => 
       { 
        loadBox.ValueMember = value; 
        loadBox.DataSource = dt; 
       })); 
      }); 
     } 

Answer 4

は@Sinatrと@Fabioが、私はあなたの答えの組み合わせをテストし、以下の私の最速復帰時間を与えるようで、ありがとうございます。

メインフォームのメソッドコール：

private async Task loadCombo(string sqlCommand, string value, ComboBox loadBox) 
     { 
      var data = await sqlScript.loadCombo(sqlCommand, value); 
      loadBox.ValueMember = value; 
      loadBox.DataSource = data; 
     } 

sqlScriptクラスメソッド：

public async Task<DataTable> loadCombo(string sqlCommand, string value) 
     { 
      SqlConnection myConn; 
      SqlCommand myCmd = default(SqlCommand); 
      SqlDataReader oResult; 
      DataTable dt = new DataTable(); 

      await Task.Run(() => 
      { 

       using (myConn = new SqlConnection("Data Source=" + frmMain.sqlServer + ";" + "Initial Catalog=" + frmMain.sqlData + ";User Id=" + frmMain.sqlUser + ";Password=" + frmMain.sqlPwd + ";")) 
       { 
        try 
        { 
         myConn.Open(); 

         if (myConn.State == ConnectionState.Open) 
         { 
          myCmd = new SqlCommand((sqlCommand), myConn); 
          oResult = myCmd.ExecuteReader(); 
          dt.Load(oResult); 
          myConn.Close(); 
         } 
         else 
         { 

         } 
        } 
        catch (Exception err) 
        { 
         using (StreamWriter w = File.AppendText("ErrorLog.log")) 
         { 
          frmMain.Log("sqlScripts.loadCombo: " + err.Message, w); 
         } 
        }//End Try 
       }//End using 
      }); 
      return dt; 
     }