如何异步调度数千个SQL请求

• 构建数以千计的SQL select语句
• 使用BeginExecuteReader运行每个选择

我们是:

• 在回调处理程序中调用EndExecuteReader。
• 递归地启动另一个调用

public static void StartQuery() {
  // build the query for array[i]
  // ...
  SqlConnection conn = new SqlConnection(AsyncConnectionString);
  conn.Open();
  cmd.BeginExecuteReader(CallbackHandler, cmd);

  i++;
}



public static void CallbackHandler(IAsyncResult ar) {
     // unpack the cmd
     cmd.EndExecuteReader();

     // read some stuff to a DataTable...

     // SqlBulkCopy to another database (synchronously)

     cmd.Connection.Close();
     cmd.Connection.Dispose();

     StartQuery();
 }

谢谢!