Сначала немного понимания того, почему я пытаюсь создать пользовательский IQueryProvider
:
Я ищу решение для универсального клиента OData, который поддерживает IQueryable
.Я не хочу использовать генератор кода клиента OData (потому что я не хочу обновлять клиента или создавать новые клиенты всякий раз, когда я меняю сервер).У меня есть реализация вызовов веб-API по умолчанию, основанная на WebClient
, и я хочу повторно использовать ее для OData.Мой сервис уже поддерживает OData и работает нормально.На стороне клиента мне сейчас нужен IQueryable
для назначения его DevExpress 'ODataInstantFeedbackSource
.
Моя проблема в том, что мне нужно выполнить HTTP-запрос для получения IQueryable
.Это приводит к запросу OData без каких-либо ограничений, что приводит к загрузке большого объема данных.Поэтому моя идея состоит в том, чтобы создать своего рода «делегируемый запрос», который принимает в своем конструкторе делегат Func
, который определяет вызов веб-API и может также обрабатывать дерево выражений.
Моя попыткаэто решение (пример проекта):
using System;
using System.Collections;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
namespace IQueryableTest
{
class Program
{
static void Main(string[] args)
{
var x = new FuncQueryable<int>((expr) =>
{
return new[] { 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20 }
.AsQueryable()
.Provider
.CreateQuery<int>(expr);
});
var y = x.Where(i => i % 2 == 0);
var z = y.ToList();
}
}
public class FuncQueryable<T> : IOrderedQueryable<T>
{
public FuncQueryable(Func<Expression, IQueryable<T>> source)
{
Provider = new ActionQueryProvider<T>(source);
}
public FuncQueryable(IQueryProvider provider, Expression expression)
{
Provider = provider;
Expression = expression;
}
public Expression Expression { get; set; }
public Type ElementType => typeof(T);
public IQueryProvider Provider { private set; get; }
public IEnumerator<T> GetEnumerator()
{
return (Provider.Execute<IEnumerable<T>>(Expression)).GetEnumerator();
}
IEnumerator IEnumerable.GetEnumerator()
{
return (Provider.Execute<IEnumerable>(Expression)).GetEnumerator();
}
}
public class ActionQueryProvider<T> : IQueryProvider
{
private readonly Func<Expression, IQueryable<T>> _source;
public ActionQueryProvider(Func<Expression, IQueryable<T>> source)
{
_source = source;
}
public IQueryable CreateQuery(Expression expression)
{
return new FuncQueryable<T>(this, expression);
}
public IQueryable<TElement> CreateQuery<TElement>(Expression expression)
{
return new FuncQueryable<TElement>(this, expression);
}
public object Execute(Expression expression)
{
return _source.Invoke(expression);
}
public TResult Execute<TResult>(Expression expression)
{
return (TResult)Execute(expression);
}
}
}
Я получаю следующее исключение:
Der Wert darf nicht NULL sein. (ArgumentNullException)
Parametername: arguments
bei System.Linq.Expressions.Expression.RequiresCanRead(Expression expression, String paramName)
bei System.Linq.Expressions.Expression.ValidateOneArgument(MethodBase method, ExpressionType nodeKind, Expression arg, ParameterInfo pi)
bei System.Linq.Expressions.Expression.ValidateArgumentTypes(MethodBase method, ExpressionType nodeKind, ReadOnlyCollection`1& arguments)
bei System.Linq.Expressions.Expression.Call(Expression instance, MethodInfo method, IEnumerable`1 arguments)
bei System.Linq.Queryable.Where[TSource](IQueryable`1 source, Expression`1 predicate)
bei IQueryableTest.Program.Main(String[] args)
в строке var y = x.Where(i => i % 2 == 0);
.