小编Mar*_*mis的帖子

我有一个postgres表(让我们调用此表Events)与另一个表的复合外键(让我们调用此表Logs).Events表如下所示:

CREATE TABLE Events (
   ColPrimary UUID,
   ColA VARCHAR(50),
   ColB VARCHAR(50),
   ColC VARCHAR(50),
   PRIMARY KEY (ColPrimary),
   FOREIGN KEY (ColA, ColB, ColC) REFERENCES Logs(ColA, ColB, ColC)
);

在这种情况下,我知道我可以通过主键有效地搜索事件,并加入到日志.

我感兴趣的是这个外键是否在Events表上创建了一个索引,即使没有加入也可以使用它.例如,以下查询是否会受益于FK？

SELECT * FROM Events
WHERE ColA='foo' AND ColB='bar'

注意:我已经针对一个非常类似的情况运行了POSTGRES EXPLAIN,并且看到该查询将导致全表扫描.我不确定这是因为FK对此查询没有帮助,或者我的数据大小很小并且扫描在我当前的规模上更有效.

我有代码从SQL流下来的数据并将其写入不同的商店.代码大致是这样的:

using (var cmd = new SqlCommand("select * from MyTable", connection))
{
     using (var reader = await cmd.ExecuteReaderAsync())
     {
         var list = new List<MyData>();
         while (await reader.ReadAsync())
         {
             var row = GetRow(reader);
             list.Add(row);
             if (list.Count == BatchSize)
             {
                 await WriteDataAsync(list);
                 list.Clear();
             }
         }
         if (list.Count > 0)
         {
             await WriteDataAsync(list);
         }
     }
 }

我想为此目的使用Reactive扩展.理想情况下,代码看起来像这样:

await StreamDataFromSql()
    .Buffer(BatchSize)
    .ForEachAsync(async batch => await WriteDataAsync(batch));

但是,似乎扩展方法ForEachAsync仅接受同步操作.是否可以编写一个可以接受异步操作的扩展？