ToAsyncEnumerable（）。Single（）vs SingleAsync（）
.net-core entity-framework entity-framework-core linq system.reactive
題
我正在以獨立於EF-Core的方式構建和執行查詢，所以我依靠IQueryable<T>來獲得所需的抽象級別。我正在用等待的SingleAsync()替換等待的SingleAsync()調用ToAsyncEnumerable().Single()調用。我也用ToListAsync() ToAsyncEnumerable().ToList()調用替換ToListAsync() ToAsyncEnumerable().ToList()調用。但我剛發生在ToAsyncEnumerable()方法上，所以我不確定我是否正確使用它。
為了澄清我所指的擴展方法，它們的定義如下：
-
SingleAsync和ToListAsync在Microsoft.EntityFrameworkCore命名空間和程序集中的EntityFrameworkQueryableExtensions類上定義。 -
ToAsyncEnumerable在System.Interactive.Async程序集的System.Linq命名空間中的AsyncEnumerable類上定義。
當查詢針對EF-Core運行時，調用ToAsyncEnumerable().Single()/ToList()與SingleAsync()/ToListAsync()的功能和性能等效嗎？如果沒有，那麼它們有何不同？
一般承認的答案
對於返回序列的方法（如ToListAsync ， ToArrayAsync ），我不希望有任何區別。
但是對於單值返回方法（ First ， FirstOrDefault ， Single ， Min ， Max ， Sum等的異步版本）肯定會有區別。通過在IQueryable<T> vs IEnumerable<T>上執行這些方法，它與差異相同。在前一種情況下，它們由數據庫查詢處理，將單個值返回給客戶端，而在後一種情況下，整個結果集將返回到客戶端並在內存中處理。
因此，雖然通常抽象EF Core的想法很好，但它會導致IQueryable<T>性能問題，因為可查詢的異步處理不是標準化的，並且轉換為IEnumerable<T>改變執行上下文，因此實現單值返回LINQ方法。
PS標準化我指的是以下內容。 IQueryable的同步處理由IQueryProvider （ System.Core.dll程序集中的System.Linq命名空間的標準接口）提供Execute方法。異步處理需要引入另一個類似於EF Core 自定義 IAsyncQueryProvider 標準接口（在Microsoft.EntityFrameworkCore.dll程序IAsyncQueryProvider Microsoft.EntityFrameworkCore.Query.Internal命名空間內）。我想這需要BCL團隊的合作/批准並需要時間，這就是為什麼他們現在決定採取自定義路徑。
熱門答案
當原始源是DbSet ，在數據庫包含多個匹配行的例外情況下， ToAsyncEnumerable().Single()性能不如SingleAsync() 。但是在更可能發生的情況下，您既期望又只收到一行，那就是一樣的。比較生成的SQL：
SingleAsync():
SELECT TOP(2) [l].[ID]
FROM [Ls] AS [l]
ToAsyncEnumerable().Single():
SELECT [l].[ID]
FROM [Ls] AS [l]
ToAsyncEnumerable()斷開IQueryable調用鏈，並進入LINQ-to-Objects領域。任何下游過濾都會在內存中發生。您可以通過在上游進行過濾來緩解此問題。所以代替：
ToAsyncEnumerable().Single( l => l.Something == "foo" ):
SELECT [l].[ID], [l].[Something]
FROM [Ls] AS [l]
你可以做：
Where( l => l.Something == "foo" ).ToAsyncEnumerable().Single():
SELECT [l].[ID], [l].[Something]
FROM [Ls] AS [l]
WHERE [l].[Something] = N'foo'
如果這種方法仍然使您有些困惑，那麼可以考慮定義如下擴展方法：
using System.Linq;
using System.Threading.Tasks;
using Microsoft.EntityFrameworkCore;
using Microsoft.EntityFrameworkCore.Query.Internal;
static class Extensions
{
public static Task<T> SingleAsync<T>( this IQueryable<T> source ) =>
source.Provider is IAsyncQueryProvider
? EntityFrameworkQueryableExtensions.SingleAsync( source )
: Task.FromResult( source.Single() );
}
許可下: CC-BY-SA with attribution
不隸屬於 Stack Overflow