c#:从SqlDataReader填充具有中断能力的数据表

本文关键字：中断 能力 数据表 SqlDataReader 填充 | 更新日期: 2023-09-27 18:02:42

我想通过SqlDataReader填充DataTable对象，并有能力中断操作(例如，在用户想要取消长时间运行查询的情况下通过u/I)。

不幸的是，我没有看到任何占用CancellationToken的DataTable.Load()过载。

是否有一个干净的方法来实现这一点?

(我唯一的想法是使用一个线程，看看Thread.Interrupt()是否奏效，如果没有，那么Thread.Abort()，但这似乎很不友好)。

c#:从SqlDataReader填充具有中断能力的数据表

您可以使用Task和取消令牌。当然，您必须手动填充DataTable，而不是使用Load方法。

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);
    }
}

你可以这样使用这个方法:

CancellationTokenSource tokenSource = new CancellationTokenSource();
Task.Factory.StartNew(() => FillTable(tokenSource.Token), tokenSource.Token);

则可以取消操作:

tokenSource.Cancel();

与SqlDataAdapter相结合，您可以处理DataTable RowChanged事件，并抛出异常或关闭数据适配器的连接，从而导致抛出InvalidOperationException。

看一下下面的例子(来源):

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
}
相关文章：