Abp.EntityFrameworkCore 9.3 bug? Async operations for the LINQ provider 'Abp.EntityFrameworkCore.AbpEntityQueryProvider' are not supported #12105

5 Answer(s)

• 

  0

  m.aliozkaya created 4 months ago

  Support Team

  Hi @uxabp,

  Could you share your project with [email protected]?

  Save Cancel
• 

  0

  uxabp created 4 months ago

  Hi @uxabp,

  Could you share your project with [email protected]?

  Hi @m.aliozkaya,

  Due to the project involving the company's internal business secrets, I am unable to share it. However, I can explain the components I used. Since the development needs to continue, I have reverted to the old version for now.

  ABP Zero (with GitHub dev 2024/7/12) Core MVC & jQuery Project DevExpress 24.1.3 using Html.DevExtreme().DataGrid

  Code

  [DontWrapResult(WrapOnError = true, WrapOnSuccess = false, LogError = true)]
  [HttpGet]
  public async Task<JsonResult> GetAll(DataSourceLoadOptions loadOptions)
  {
      var dataQuery = _metricsProxyRepository.GetAll();
      dataQuery = dataQuery.WhereIf(!await _commonDomainService.IsCurrentUserInRoleAsync(AbpRoles.Role_Admin), x => x.CreatorUserId == _session.GetUserId());
  
      var result = await DataSourceLoader.LoadAsync(dataQuery, loadOptions);  //HERE ABP v9.3.0 Error
      if (loadOptions.Group == null)
      {
          result.data = ObjectMapper.Map<List<DevCarDto>>(result.data);
      }
      return new JsonResult(result, JsonSerializerOptionsCollection.DefaultOptions);
  }
  

  ABP v9.2.2 was working fine, but after upgrading to ABP v9.3.0, the same program started having errors(see //HERE ABP v9.3.0 Error).

  Using Abp.ZeroCore.EntityFrameworkCore v9.3.0 ERROR Message:
  
  Async operations for the LINQ provider 'Abp.EntityFrameworkCore.AbpEntityQueryProvider' are not supported. 
  You can implement a custom async adapter (DevExtreme.AspNet.Data.Async.IAsyncAdapter) and register it via 'DevExtreme.AspNet.Data.Async.CustomAsyncAdapters.RegisterAdapter'.
  

  I estimate that users of DevExpress will be affected. It would be great if you could help. Regardless, thank you for response.

  Save Cancel
• 

  0

  maliming created 4 months ago

  Support Team

  hi @uxabp,

  Can you try the code below?

  
  //Add these lines to your ef core module Initialize method.
  var adapter = new AbpDevExtremeAsyncAdapter();
  CustomAsyncAdapters.RegisterAdapter(typeof(AbpEntityQueryProvider), adapter);
  

  using System;
  using System.Collections.Generic;
  using System.Linq;
  using System.Linq.Expressions;
  using System.Reflection;
  using System.Threading;
  using System.Threading.Tasks;
  using DevExtreme.AspNet.Data.Async;
  
  namespace Abp.EntityFrameworkCore;
  
  public class AbpDevExtremeAsyncAdapter : IAsyncAdapter
  {
      private readonly MethodInfo _countAsyncMethod;
      private readonly MethodInfo _toListAsyncMethod;
  
      public AbpDevExtremeAsyncAdapter()
      {
          var extensionsType = Type.GetType("Microsoft.EntityFrameworkCore.EntityFrameworkQueryableExtensions, Microsoft.EntityFrameworkCore");
          _countAsyncMethod = FindQueryExtensionMethod(extensionsType, "CountAsync");
          _toListAsyncMethod = FindQueryExtensionMethod(extensionsType, "ToListAsync");
      }
  
      public Task<int> CountAsync(IQueryProvider provider, Expression expr, CancellationToken cancellationToken)
      {
          return InvokeCountAsync(_countAsyncMethod, provider, expr, cancellationToken);
      }
  
      public Task<IEnumerable<T>> ToEnumerableAsync<T>(IQueryProvider provider, Expression expr, CancellationToken cancellationToken)
      {
          return InvokeToListAsync<T>(_toListAsyncMethod, provider, expr, cancellationToken);
      }
  
      static MethodInfo FindQueryExtensionMethod(Type extensionsType, string name)
      {
          return extensionsType.GetMethods().First(m =>
          {
              if (!m.IsGenericMethod || m.Name != name)
              {
                  return false;
              }
              var parameters = m.GetParameters();
              return parameters.Length == 2 && parameters[1].ParameterType == typeof(CancellationToken);
          });
      }
  
      static Task<int> InvokeCountAsync(MethodInfo method, IQueryProvider provider, Expression expr, CancellationToken cancellationToken)
      {
          var countArgument = ((MethodCallExpression)expr).Arguments[0];
          var query = provider.CreateQuery(countArgument);
          return (Task<int>)InvokeQueryExtensionMethod(method, query.ElementType, query, cancellationToken);
      }
  
      static async Task<IEnumerable<T>> InvokeToListAsync<T>(MethodInfo method, IQueryProvider provider, Expression expr, CancellationToken cancellationToken)
      {
          return await (Task<List<T>>)InvokeQueryExtensionMethod(method, typeof(T), provider.CreateQuery(expr), cancellationToken);
      }
  
      static object InvokeQueryExtensionMethod(MethodInfo method, Type elementType, IQueryable query, CancellationToken cancellationToken)
      {
          return method.MakeGenericMethod(elementType).Invoke(null, new object[] { query, cancellationToken });
      }
  }
  
  

  Save Cancel
• 

  0

  uxabp created 4 months ago

  hi @uxabp,

  Can you try the code below?

  The program works, thank you.

  Save Cancel
• 

  0

  maliming created 4 months ago

  Support Team

  : )

  Save Cancel