C＃：SqlDataReaderのDataTableに割り込み機能を実装しますか？

Question

私はSqlDataReaderでDataTableオブジェクトを記入し、操作を中断する能力を持っています（例えば、長い実行中のクエリをキャンセルしたい場合は、u/iを使用します）。

残念ながら、DataTable.Load()のオーバーロードは表示されず、CancellationTokenが必要です。

これを達成するためのきれいな方法はありますか？

（私の唯一の考えは、スレッドを使用して、Thread.Interrupt()がトリックを行うかどうかを確認し、そうでなければThread.Abort()ですが、それはかなり不公平です）。

Answer 1

SqlDataAdapterと組み合わせて、DataTableのRowChangedイベントを処理し、例外をスローするか、InvalidOperationExceptionをスローするデータアダプタの接続を閉じることができます。

は、次の例（source）を見てみましょう：

private BackgroundWorker worker; 
private DataTable table; 

private void button2_Click(object sender, EventArgs e) 
{ 
    if (worker != null) 
    { 
    worker.CancelAsync(); 
    } 
} 

private void button1_Click(object sender, EventArgs e) 
{ 
    this.worker = new BackgroundWorker(); 
    worker.WorkerReportsProgress = true; 
    worker.WorkerSupportsCancellation = true; 

    worker.DoWork += new DoWorkEventHandler(worker_DoWork); 
    worker.RunWorkerCompleted += new RunWorkerCompletedEventHandler(worker_RunWorkerCompleted); 

    worker.RunWorkerAsync(); 
} 

void worker_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e) 
{ 
    MessageBox.Show(this.table.Rows.Count.ToString()); 
} 

[System.Diagnostics.DebuggerStepThrough] 
void worker_DoWork(object sender, DoWorkEventArgs e) 
{ 
    this.table = new DataTable(); 

    using (SqlConnection connection= new SqlConnection()) 
    using (SqlDataAdapter da = new SqlDataAdapter("SELECT * FROM table", connection)) 
    { 
    table.RowChanged += new DataRowChangeEventHandler(table_RowChanged); 
    da.Fill(table);   
    } 
} 

[System.Diagnostics.DebuggerStepThrough] 
void table_RowChanged(object sender, DataRowChangeEventArgs e) 
{ 
    if (worker.CancellationPending) 
    { 
    throw new ApplicationException("Canceled"); // throw a spanner in the works 
    } 
    Thread.Sleep(5); // Just slow things down for testing 
} 

Answer 2

あなたはタスクとキャンセルトークンを使用することができます。もちろん、Loadメソッドを使用する代わりに、DataTableを手動で入力する必要があります。

private void FillTable(CancellationToken token) 
{ 
    var reader = new SqlDataReader(); 
    var dt = CreateDataTable(); 
    while(reader.Read() && !token.IsCancellationRequested) 
    { 
     var row = dt.NewRow(); 
     // fill row from reader.... 
     dt.Rows.Add(row); 
    } 
} 

あなたはこのように、このメソッドを使用します。それは数千行を埋めるためにミリ秒を要する

tokenSource.Cancel();