To create a custom LINQ provider we need to implement the interfaces, IQueryable or IOrderedQueryable and IQueryProvider. <\/p>\n
This is a summary of several posts\/blogs I’ve read on the subject and source code available on github etc. See References below.<\/p>\n
IQueryable<T><\/strong><\/p>\n To implement a minimal LINQ provider we need to implement IQueryable<>. This interface inherits from IEnumerable. The actual IQueryable methods are minimal<\/p>\n IOrderedQueryable<T><\/strong><\/p>\n If we want to support the sorting query operators, then we need to implement IOrderedQueryable<T>. <\/p>\n IOrderedQueryable inherits from IEnumerable, IEnumerable<T>, IOrderedQueryable, IQueryable, and IQueryable<T>.<\/p>\n We can implement an IOrderedQueryable that’s reusable for most situations, as follows<\/p>\n Note: The IQueryContext is not part of the LINQ interfaces but one I’ve created to allow me to abstract the actual “custom” part of the code and allow maximum reuse of default functionality.<\/em><\/p>\n IQueryProvider<\/strong><\/p>\n The IQueryProvider basically requires two methods (a generic and non-generic version of both) to be implemented. Obviously the generic versions are for strongly typed and the non-generic are loosely typed.<\/p>\n CreateQuery<\/strong><\/p>\n The CreateQuery method is used to create a new instance of an IQueryable based upon the supplied expression tree. <\/p>\n Execute<\/strong> <\/p>\n The Execute method is used to actually execute a query expression, i.e. in a custom provider we will get the data from the datasource, for example a webservice or database etc. and it’s in the Execute method that we both get the data and do any conversion to, say SQL or the likes (if the LINQ query ultimately queries some other system.<\/p>\n An example of an implementation for an IQueryProvider might look like this…<\/p>\n Note: Again, the IQueryContext is not part of the LINQ interfaces but one I’ve created to allow me to abstract the actual “custom” part of the code and allow maximum reuse of default functionality.<\/em><\/p>\n The TypeSystem class is taken from the post Walkthrough: Creating an IQueryable LINQ Provider<\/a><\/em><\/p>\n IQueryContext<\/strong><\/p>\n The above shows some LINQ interfaces and some sample implementations. I’ve pointed out that IQueryContext is not part of LINQ but is instead something I’ve created (based upon reading various other implementations) to allow me to abstract the actual LINQ provider code specific to my provider’s implementation. Ofcourse we could have derived from QueryProvider, but for now we “plug-in” the data context instead. To change the implementation to derive from QueryProvider simple remove the IQueryContext (also from the Queryable implementation) and override the Execute methods.<\/p>\n For now I’ll continue this post using the IQueryContext, so here’s the interface<\/p>\n Implementing the IQueryContext<\/strong><\/p>\n Whether the implementation of the actual Execute code (on the IQueryProvider) is abstracted into the IQueryContext or implemented within an alternate implementation of IQueryProvider. This is where the fun of actually “running” the LINQ query against your custom provider takes place. <\/p>\n When writing something like this…<\/p>\n what we are really doing is creating the query. Hence the CreateQuery methods on the IQueryProvider are called, but the actual data source or whatever supplies the data for your custom LINQ provider should not<\/strong> be called until we reach the execution phase, this is known as deferred execution. The execution phase takes place when we enumerate over the query or call methods, such as Count() etc. against a query.<\/p>\n So at the point that we GetEnumerator implicitly via the foreach loop, that’s when the Execute method is called.<\/p>\n Executing the query<\/strong><\/p>\n So, the Execute method is called and we will have an expression tree defined by LINQ supplied as an argument. We now need to translate that query into something useful, i.e. turn it into an SQL query for a custom database LINQ provider and then get the data for this query, or get data from a webservice and allow the query to be executed against the returned data etc.<\/p>\n As the actual decoding of the Expression is a fairly large subject in itself, I’ll leave that for another post, but suffice to say, there’s a lot we need to implement to duplicate some if not all of the “standard” LINQ query operators etc.<\/p>\n References<\/strong><\/p>\n Walkthrough: Creating an IQueryable LINQ Provider<\/a> To create a custom LINQ provider we need to implement the interfaces, IQueryable or IOrderedQueryable and IQueryProvider. This is a summary of several posts\/blogs I’ve read on the subject and source code available on github etc. See References below. IQueryable<T> To implement a minimal LINQ provider we need to implement IQueryable<>. This interface inherits from […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"_jetpack_memberships_contains_paid_content":false,"footnotes":""},"categories":[49,3,64],"tags":[],"class_list":["post-1308","post","type-post","status-publish","format-standard","hentry","category-net","category-c","category-linq"],"jetpack_sharing_enabled":true,"jetpack_featured_media_url":"","_links":{"self":[{"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/posts\/1308","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/comments?post=1308"}],"version-history":[{"count":29,"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/posts\/1308\/revisions"}],"predecessor-version":[{"id":1403,"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/posts\/1308\/revisions\/1403"}],"wp:attachment":[{"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/media?parent=1308"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/categories?post=1308"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/putridparrot.com\/blog\/wp-json\/wp\/v2\/tags?post=1308"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}\n
\r\npublic class Queryable<T> : IOrderedQueryable<T>\r\n{\r\n public Queryable(IQueryContext queryContext)\r\n {\r\n Initialize(new QueryProvider(queryContext), null);\r\n }\r\n\r\n public Queryable(IQueryProvider provider)\r\n {\r\n Initialize(provider, null);\r\n }\r\n\r\n internal Queryable(IQueryProvider provider, Expression expression)\r\n {\r\n Initialize(provider, expression);\r\n }\r\n\r\n private void Initialize(IQueryProvider provider, Expression expression)\r\n {\r\n if (provider == null)\r\n throw new ArgumentNullException("provider");\r\n if (expression != null && !typeof(IQueryable<T>).\r\n IsAssignableFrom(expression.Type))\r\n throw new ArgumentException(\r\n String.Format("Not assignable from {0}", expression.Type), "expression");\r\n\r\n Provider = provider;\r\n Expression = expression ?? Expression.Constant(this);\r\n }\r\n\r\n public IEnumerator<T> GetEnumerator()\r\n {\r\n return (Provider.Execute<IEnumerable<T>>(Expression)).GetEnumerator();\r\n }\r\n\r\n System.Collections.IEnumerator System.Collections.IEnumerable.GetEnumerator()\r\n {\r\n return (Provider.Execute<System.Collections.IEnumerable>(Expression)).GetEnumerator();\r\n }\r\n\r\n public Type ElementType\r\n {\r\n get { return typeof(T); }\r\n }\r\n\r\n public Expression Expression { get; private set; }\r\n public IQueryProvider Provider { get; private set; }\r\n}\r\n<\/pre>\n\r\npublic class QueryProvider : IQueryProvider\r\n{\r\n private readonly IQueryContext queryContext;\r\n\r\n public QueryProvider(IQueryContext queryContext)\r\n {\r\n this.queryContext = queryContext;\r\n }\r\n\r\n public virtual IQueryable CreateQuery(Expression expression)\r\n {\r\n Type elementType = TypeSystem.GetElementType(expression.Type);\r\n try\r\n {\r\n return \r\n (IQueryable)Activator.CreateInstance(typeof(Queryable<>).\r\n MakeGenericType(elementType), new object[] { this, expression });\r\n }\r\n catch (TargetInvocationException e)\r\n {\r\n throw e.InnerException;\r\n }\r\n }\r\n\r\n public virtual IQueryable<T> CreateQuery<T>(Expression expression)\r\n {\r\n return new Queryable<T>(this, expression);\r\n }\r\n\r\n object IQueryProvider.Execute(Expression expression)\r\n {\r\n return queryContext.Execute(expression, false);\r\n }\r\n\r\n T IQueryProvider.Execute<T>(Expression expression)\r\n {\r\n return (T)queryContext.Execute(expression, \r\n (typeof(T).Name == "IEnumerable`1"));\r\n }\r\n}\r\n<\/pre>\n\r\npublic interface IQueryContext\r\n{\r\n object Execute(Expression expression, bool isEnumerable);\r\n}\r\n<\/pre>\n\r\nvar ctx = new Queryable<string>(new CustomContext())\r\n\r\nvar query = from s in ctx where s.StartsWith("T") select s;\r\n<\/pre>\n\r\nforeach (var q in query)\r\n{\r\n Console.WriteLine(q);\r\n}\r\n<\/pre>\n
\nLINQ: Building an IQueryable provider series<\/a>
\nLINQ and Deferred Execution<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"