LinqAsync 1.0.1

This package allow you to do the asynchronous query with IQueryable. Implements async query interface IAsyncQueryableMethodsProvider for your code.

Here is an implementation of IAsyncQueryableMethodsProvider for Entity Framework Core.

Usage

Abstraction layer project

The abstraction layer project does not know/implement any async method of the underlying db. It's just focus the business logic in here.

There is no technical implementation here

Install the NuGet package from nuget.org

PM> Install-Package LinqAsync

The following code example does a query for Contract. Use async method FirstOrDefaultAsync to find the first item.

public interface IContactRepository : IQueryable<Contact>
{
}

public class ContactQuery
{
    private readonly IContactRepository _repo;
    
    public ContactQuery(IContactRepository repo)
    {
        _repo = repo;
    } 

    public Task<Contact?> GetContactOrDefaultAsync(Guid id)
    {
        var q = from x in _repo
                where x.Id == id
                select x;
               
        // Here we can use the static extension method for async query without EFCore dependences. 
        return _repo.FirstOrDefaultAsync(q);
    }
}

Repo implementation with EFCore project

This project will install EFCore packages and LinqAsync.EFCore

Install the NuGet package from nuget.org

PM> Install-Package LinqAsync.EFCore

Then we just register the EFCore async query implement to AsyncQueryableExtensions, no more code needed.

// register async query EFCore implementation to AsyncQueryableExtensions at startup
var efCoreAsyncQueryable = new EntityFrameworkCoreAsyncQueryableMethodsProvider();
AsyncQueryableExtensions.RegisterAsyncQueryableMethodsProvider(efCoreAsyncQueryable); 

All async query will pass-thru the provider (EntityFrameworkCoreAsyncQueryableMethodsProvider in this case) to make async query in Entity Framework Core.

Final

Leave a comment on GitHub if you have any questions or suggestions.

Turn on the "Star" icon to support if you like it.

License

This project is licensed under the MIT License