diff options
| author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-03-03 14:11:07 +0000 |
|---|---|---|
| committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-03-03 14:11:07 +0000 |
| commit | 42a1548cecf48d18233f56e3385cf9c89abcb9c2 (patch) | |
| tree | 5e0fff4ecbd1fd7dd1022a7580139038df2a824c /sqlglot/optimizer/unnest_subqueries.py | |
| parent | Releasing debian version 21.1.2-1. (diff) | |
| download | sqlglot-42a1548cecf48d18233f56e3385cf9c89abcb9c2.tar.xz sqlglot-42a1548cecf48d18233f56e3385cf9c89abcb9c2.zip | |
Merging upstream version 22.2.0.
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'sqlglot/optimizer/unnest_subqueries.py')
| -rw-r--r-- | sqlglot/optimizer/unnest_subqueries.py | 14 |
1 files changed, 13 insertions, 1 deletions
diff --git a/sqlglot/optimizer/unnest_subqueries.py b/sqlglot/optimizer/unnest_subqueries.py index b4c7475..36d9da4 100644 --- a/sqlglot/optimizer/unnest_subqueries.py +++ b/sqlglot/optimizer/unnest_subqueries.py @@ -94,8 +94,20 @@ def unnest(select, parent_select, next_alias_name): else: _replace(predicate, join_key_not_null) + group = select.args.get("group") + + if group: + if {value.this} != set(group.expressions): + select = ( + exp.select(exp.column(value.alias, "_q")) + .from_(select.subquery("_q", copy=False), copy=False) + .group_by(exp.column(value.alias, "_q"), copy=False) + ) + else: + select = select.group_by(value.this, copy=False) + parent_select.join( - select.group_by(value.this, copy=False), + select, on=column.eq(join_key), join_type="LEFT", join_alias=alias, |