У меня есть простой пользовательский QueryProvider, который принимает выражение, переводит его в SQL и запрашивает базу данных sql.
Я хочу создать в QueryProvider небольшой кэш, в котором будут храниться часто используемые объекты, чтобы поиск мог происходить без обращения к базе данных.
У QueryProvider есть метод
public object Execute(System.Linq.Expressions.Expression expression)
{
/// Builds an SQL statement from the expression,
/// executes it and returns matching objects
}
Кэш находится в виде поля в этом классе QueryProvider и представляет собой простой общий список.
Если я использую метод List.AsQueryable и передаю приведенное выше выражение в метод Execute поставщика List.AsQueryable, это не работает должным образом. Похоже, что когда выражение компилируется, исходный QueryProvider становится его неотъемлемой частью.
Можно ли передать выражение следующему QueryProvider и выполнить его по желанию?
Вызывающий код смутно выглядит следующим образом:
public class QueryProvider<Entity>()
{
private List<TEntity> cache = new List<Entity>();
public object Execute(System.Linq.Expressions.Expression expression)
{
/// check whether expression expects single or multiple result
bool isSingle = true;
if (isSingle)
{
var result = this.cache.AsQueryable<Entity>().Provider.Execute(expression);
if (result != null)
return result;
}
/// cache failed, hit database
var qt = new QueryTranslator();
string sql = qt.Translate(expression);
/// .... hit database
}
}
Он не возвращает ошибку, вместо этого он застревает в цикле, когда один и тот же провайдер вызывается снова и снова.
Вот еще код, показывающий, что я пытаюсь сделать:
Collection:
class Collection<Entity>
{
internal List<Entity> cacheOne { get; private set; }
internal Dictionary<Guid, Entity> cacheTwo { get; private set; }
internal Collection()
{
this.cacheOne = new List<Entity>();
this.cacheTwo = new Dictionary<Guid, Entity>();
}
public IQueryable<Entity> Query()
{
return new Query<Entity>(this.cacheOne, this.cacheTwo);
}
}
Query:
class Query<Entity> : IQueryable<Entity>
{
internal Query(List<Entity> cacheOne, Dictionary<Guid, Entity> cacheTwo)
{
this.Provider = new QueryProvider<Entity>(cacheOne, cacheTwo);
this.Expression = Expression.Constant(this);
}
internal Query(IQueryProvider provider, Expression expression)
{
this.Provider = provider;
if (expression != null)
this.Expression = expression;
}
public IEnumerator<Entity> GetEnumerator()
{
return this.Provider.Execute<IEnumerator<Entity>>(this.Expression);
}
System.Collections.IEnumerator System.Collections.IEnumerable.GetEnumerator()
{
return this.GetEnumerator();
}
public Type ElementType
{
get { return typeof(Entity); }
}
public System.Linq.Expressions.Expression Expression { get; private set; }
public IQueryProvider Provider { get; private set; }
}
QueryProvider:
class QueryProvider<Entity> : IQueryProvider
{
private List<Entity> cacheOne;
private Dictionary<Guid, Entity> cacheTwo;
internal QueryProvider(List<Entity> cacheOne, Dictionary<Guid, Entity> cacheTwo)
{
this.cacheOne = cacheOne;
this.cacheTwo = cacheTwo;
}
public IQueryable<TElement> CreateQuery<TElement>(System.Linq.Expressions.Expression expression)
{
return new Query<TElement>(this, expression);
}
public IQueryable CreateQuery(System.Linq.Expressions.Expression expression)
{
throw new NotImplementedException();
}
public TResult Execute<TResult>(System.Linq.Expressions.Expression expression)
{
return (TResult)this.Execute(expression);
}
public object Execute(System.Linq.Expressions.Expression expression)
{
Iterator<Entity> iterator = new Iterator<Entity>(expression, cacheOne, cacheTwo);
return (iterator as IEnumerable<Entity>).GetEnumerator();
}
}
Iterator:
class Iterator<Entity> : IEnumerable<Entity>
{
private Expression expression;
private List<Entity> cacheOne;
private Dictionary<Guid, Entity> cacheTwo;
internal Iterator(Expression expression, List<Entity> cacheOne, Dictionary<Guid, Entity> cacheTwo)
{
this.expression = expression;
this.cacheOne = cacheOne;
this.cacheTwo = cacheTwo;
}
public IEnumerator<Entity> GetEnumerator()
{
foreach (var result in (IEnumerable<Entity>)this.cacheOne.AsQueryable<Entity>().Provider.Execute(expression))
{
yield return result;
}
foreach (var more in (IEnumerable<Entity>)this.cacheTwo.Values.AsQueryable<Entity>().Provider.Execute(expression))
{
yield return more;
}
}
System.Collections.IEnumerator System.Collections.IEnumerable.GetEnumerator()
{
return this.GetEnumerator();
}
}
Program:
class Program
{
static void Main(string[] args)
{
/// Create collection + caches
var collection = new Collection<Giraffe>();
collection.cacheOne.AddRange(new Giraffe[] {
new Giraffe() { Id = Guid.NewGuid(), DateOfBirth = new DateTime(2011, 03, 21), Height = 192, Name = "Percy" },
new Giraffe() { Id = Guid.NewGuid(), DateOfBirth = new DateTime(2005, 12, 25), Height = 188, Name = "Santa" },
new Giraffe() { Id = Guid.NewGuid(), DateOfBirth = new DateTime(1999, 04, 01), Height=144, Name="Clown" }
});
var cachetwo = new List<Giraffe>(new Giraffe[] {
new Giraffe() { Id = Guid.NewGuid(), DateOfBirth = new DateTime(1980, 03,03), Height = 599, Name="Big Ears" },
new Giraffe() { Id = Guid.NewGuid(), DateOfBirth = new DateTime(1985, 04, 02), Height= 209, Name="Pug" }
});
foreach (var giraffe in cachetwo)
collection.cacheTwo.Add(giraffe.Id, giraffe);
/// Iterate through giraffes born before a certain date
foreach (var result in collection.Query().Where(T => T.DateOfBirth < new DateTime(2006, 01, 01)))
{
Console.WriteLine(result.Name);
}
}
}
Giraffe:
class Giraffe
{
public Guid Id { get; set; }
public string Name { get; set; }
public long Height { get; set; }
public DateTime DateOfBirth { get; set; }
}
Special дела, например SingleAndDefault и т. д. не учитываются. Часть, с которой я хочу работать, происходит в итераторе, где он в первую очередь выполняет QueryProvider списка перед выполнением словаря.
Один из двух объектов Queryable может быть базой данных или чем-то еще.