Merge pull request #231 from slimbr/master

Compiler Compile Cte

Author: ahmad-moussawi

QueryBuilder/Compilers/Compiler.cs

@@ -121,27 +121,7 @@ protected virtual SqlResult CompileRaw(Query query)
             // handle CTEs
             if (query.HasComponent("cte", EngineCode))
             {
-                var cteFinder = new CteFinder(query, EngineCode);
-                var cteSearchResult = cteFinder.Find();
-
-                var rawSql = new StringBuilder("WITH ");
-                var cteBindings = new List<object>();
-
-                foreach (var cte in cteSearchResult)
-                {
-                    var cteCtx = CompileCte(cte);
-
-                    cteBindings.AddRange(cteCtx.Bindings);
-                    rawSql.Append(cteCtx.RawSql.Trim());
-                    rawSql.Append(",\n");
-                }
-
-                rawSql.Length -= 2; // remove last comma
-                rawSql.Append('\n');
-                rawSql.Append(ctx.RawSql);
-
-                ctx.Bindings.InsertRange(0, cteBindings);
-                ctx.RawSql = rawSql.ToString();
+                ctx = CompileCteQuery(ctx, query);
             }
 
             ctx.RawSql = Helper.ExpandParameters(ctx.RawSql, "?", ctx.Bindings.ToArray());
@@ -361,6 +341,33 @@ protected virtual SqlResult CompileInsertQuery(Query query)
             return ctx;
         }
 
+        protected virtual SqlResult CompileCteQuery(SqlResult ctx, Query query)
+        {
+            var cteFinder = new CteFinder(query, EngineCode);
+            var cteSearchResult = cteFinder.Find();
+
+            var rawSql = new StringBuilder("WITH ");
+            var cteBindings = new List<object>();
+
+            foreach (var cte in cteSearchResult)
+            {
+                var cteCtx = CompileCte(cte);
+
+                cteBindings.AddRange(cteCtx.Bindings);
+                rawSql.Append(cteCtx.RawSql.Trim());
+                rawSql.Append(",\n");
+            }
+
+            rawSql.Length -= 2; // remove last comma
+            rawSql.Append('\n');
+            rawSql.Append(ctx.RawSql);
+
+            ctx.Bindings.InsertRange(0, cteBindings);
+            ctx.RawSql = rawSql.ToString();
+
+            return ctx;
+        }
+
         /// <summary>
         /// Compile a single column clause
         /// </summary>