ASP.NET Core Web API实现不终止搜索的部分结果返回方案

完全可以实现，你需要用**异步可枚举（IAsyncEnumerable）**结合yield return语法，就能在不终止搜索进程的前提下，每完成一张表的查询就返回对应的结果，让客户端逐步接收数据，不用等整个遍历完成。

你的示例代码问题 #

你当前的代码里用return会直接终止方法执行，无法继续遍历后续表。正确的做法是用yield return返回当前批次结果后，方法会自动回到循环继续执行下一轮查询。

修正后的代码 #

public async IAsyncEnumerable<List<DataRow>> DbSearch(...parameters)
{
    int processedTables = 0;
    foreach (var schemaRow in schemaDatabase.Rows)
    {
        processedTables++;
        var tableName = schemaRow["TABLE_NAME"].ToString();
        
        // 注意：直接拼接表名有SQL注入风险，务必验证表名合法性（比如和schema中的表名比对）
        using var sqlCommand = new SqlCommand($"SELECT ... FROM {tableName} WHERE ...", yourSqlConnection);
        
        // 使用异步读取避免阻塞线程
        using var reader = await sqlCommand.ExecuteReaderAsync();
        
        var resultTable = new DataTable();
        await resultTable.LoadAsync(reader); // 异步加载数据到DataTable
        
        var currentBatch = resultTable.Rows.Cast<DataRow>().ToList();
        // 返回当前表的查询结果，方法会继续执行下一次循环
        yield return currentBatch;
    }

    // 可选：如果需要最后返回全量汇总结果，可以在这里添加
    // yield return listResult;
}

Web API端配置 #

在ASP.NET Core中，直接返回IAsyncEnumerable<T>即可，框架会自动以分块传输编码（Chunked Transfer Encoding）的方式流式返回数据：

[HttpGet("db-search")]
public async IAsyncEnumerable<List<DataRow>> RunDbSearch([FromQuery] SearchParameters parameters)
{
    return _dbService.DbSearch(parameters);
}

关键注意事项 #

• 避免SQL注入：直接拼接表名存在安全风险，必须验证表名是否属于目标数据库的合法表（比如和schemaDatabase.Rows中的表名比对），防止恶意注入。
• 异步操作：全程使用异步方法（ExecuteReaderAsync、LoadAsync），避免阻塞API线程池，提升服务并发能力。
• 进度跟踪：如果需要让客户端知道搜索进度，可以自定义返回模型，包含当前处理的表名、已完成数量等信息，比如：

  public class SearchBatch
  {
      public string TableName { get; set; }
      public int ProcessedCount { get; set; }
      public List<DataRow> Data { get; set; }
  }
  

  然后修改方法返回IAsyncEnumerable<SearchBatch>，让客户端能实时掌握进度。

内容的提问来源于stack exchange，提问作者Matteo Zambon