diff options
| author | Mike Bayer <mike_mp@zzzcomputing.com> | 2018-03-14 11:04:43 -0400 |
|---|---|---|
| committer | Mike Bayer <mike_mp@zzzcomputing.com> | 2018-03-14 11:38:15 -0400 |
| commit | ef2859bbc8bb8104bf4e429a52efb50a712d834a (patch) | |
| tree | 50adbb257964a7295df87f7aea5eea53b56005bf /test/sql/test_cte.py | |
| parent | f3e18baa00489b2a85293edcdb4c98cb409c8c93 (diff) | |
| download | sqlalchemy-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.py | 44 |
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) |
