summaryrefslogtreecommitdiff
path: root/test/sql/test_cte.py
diff options
context:
space:
mode:
authorMike Bayer <mike_mp@zzzcomputing.com>2018-03-14 11:04:43 -0400
committerMike Bayer <mike_mp@zzzcomputing.com>2018-03-14 11:38:15 -0400
commitef2859bbc8bb8104bf4e429a52efb50a712d834a (patch)
tree50adbb257964a7295df87f7aea5eea53b56005bf /test/sql/test_cte.py
parentf3e18baa00489b2a85293edcdb4c98cb409c8c93 (diff)
downloadsqlalchemy-ef2859bbc8bb8104bf4e429a52efb50a712d834a.tar.gz
Track if we're rendering within the CTE recursively
Fixed a regression that occurred from the previous fix to :ticket:`4204` in version 1.2.5, where a CTE that refers to itself after the :meth:`.CTE.alias` method has been called would not refer to iself correctly. Change-Id: Iaa63d65ad2b90c8693f9953fbb32dbb10c73a037 Fixes: #4204
Diffstat (limited to 'test/sql/test_cte.py')
-rw-r--r--test/sql/test_cte.py44
1 files changed, 44 insertions, 0 deletions
diff --git a/test/sql/test_cte.py b/test/sql/test_cte.py
index 2c19ed032..efc4640ed 100644
--- a/test/sql/test_cte.py
+++ b/test/sql/test_cte.py
@@ -122,6 +122,50 @@ class CTETest(fixtures.TestBase, AssertsCompiledSQL):
"JOIN parts ON anon_1.part = parts.part "
"GROUP BY anon_1.sub_part", dialect=mssql.dialect())
+ def test_recursive_inner_cte_unioned_to_alias(self):
+ parts = table('parts',
+ column('part'),
+ column('sub_part'),
+ column('quantity'),
+ )
+
+ included_parts = select([
+ parts.c.sub_part,
+ parts.c.part,
+ parts.c.quantity]).\
+ where(parts.c.part == 'our part').\
+ cte(recursive=True)
+
+ incl_alias = included_parts.alias('incl')
+ parts_alias = parts.alias()
+ included_parts = incl_alias.union(
+ select([
+ parts_alias.c.sub_part,
+ parts_alias.c.part,
+ parts_alias.c.quantity]).
+ where(parts_alias.c.part == incl_alias.c.sub_part)
+ )
+
+ s = select([
+ included_parts.c.sub_part,
+ func.sum(included_parts.c.quantity).label('total_quantity')]).\
+ select_from(included_parts.join(
+ parts, included_parts.c.part == parts.c.part)).\
+ group_by(included_parts.c.sub_part)
+ self.assert_compile(
+ s, "WITH RECURSIVE incl(sub_part, part, quantity) "
+ "AS (SELECT parts.sub_part AS sub_part, parts.part "
+ "AS part, parts.quantity AS quantity FROM parts "
+ "WHERE parts.part = :part_1 UNION "
+ "SELECT parts_1.sub_part AS sub_part, "
+ "parts_1.part AS part, parts_1.quantity "
+ "AS quantity FROM parts AS parts_1, incl "
+ "WHERE parts_1.part = incl.sub_part) "
+ "SELECT incl.sub_part, "
+ "sum(incl.quantity) AS total_quantity FROM incl "
+ "JOIN parts ON incl.part = parts.part "
+ "GROUP BY incl.sub_part")
+
def test_recursive_union_no_alias_one(self):
s1 = select([literal(0).label("x")])
cte = s1.cte(name="cte", recursive=True)