summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy/sql
diff options
context:
space:
mode:
authormike bayer <mike_mp@zzzcomputing.com>2017-09-14 15:40:22 -0400
committerGerrit Code Review <gerrit@awstats.zzzcomputing.com>2017-09-14 15:40:22 -0400
commitd8cddf61f9de1570257c575a149738ecec6a9d91 (patch)
treecbc8629d867be7de1b70d094ca99ebf1d6b68b4d /lib/sqlalchemy/sql
parentd0c46d9ae53f2e6d1863633b5fb0a7d2328180cc (diff)
parent509d19e6fd38b8e9fec1c588ec958ad1246414a1 (diff)
downloadsqlalchemy-d8cddf61f9de1570257c575a149738ecec6a9d91.tar.gz
Merge "Implement placeholders for CUBE, ROLLUP, GROUPING SETS"
Diffstat (limited to 'lib/sqlalchemy/sql')
-rw-r--r--lib/sqlalchemy/sql/compiler.py5
-rw-r--r--lib/sqlalchemy/sql/elements.py2
-rw-r--r--lib/sqlalchemy/sql/functions.py62
3 files changed, 67 insertions, 2 deletions
diff --git a/lib/sqlalchemy/sql/compiler.py b/lib/sqlalchemy/sql/compiler.py
index 2dec3a5c3..b0f0807d6 100644
--- a/lib/sqlalchemy/sql/compiler.py
+++ b/lib/sqlalchemy/sql/compiler.py
@@ -121,7 +121,10 @@ FUNCTIONS = {
functions.random: 'random%(expr)s',
functions.sysdate: 'sysdate',
functions.session_user: 'SESSION_USER',
- functions.user: 'USER'
+ functions.user: 'USER',
+ functions.cube: 'CUBE%(expr)s',
+ functions.rollup: 'ROLLUP%(expr)s',
+ functions.grouping_sets: 'GROUPING SETS%(expr)s',
}
EXTRACT_MAP = {
diff --git a/lib/sqlalchemy/sql/elements.py b/lib/sqlalchemy/sql/elements.py
index 36a6a6557..9213d616c 100644
--- a/lib/sqlalchemy/sql/elements.py
+++ b/lib/sqlalchemy/sql/elements.py
@@ -3293,7 +3293,7 @@ class WithinGroup(ColumnElement):
"""Represent a WITHIN GROUP (ORDER BY) clause.
This is a special operator against so-called
- so-called "ordered set aggregate" and "hypothetical
+ "ordered set aggregate" and "hypothetical
set aggregate" functions, including ``percentile_cont()``,
``rank()``, ``dense_rank()``, etc.
diff --git a/lib/sqlalchemy/sql/functions.py b/lib/sqlalchemy/sql/functions.py
index 08f1d32a5..9a9396fec 100644
--- a/lib/sqlalchemy/sql/functions.py
+++ b/lib/sqlalchemy/sql/functions.py
@@ -811,3 +811,65 @@ class cume_dist(GenericFunction):
"""
type = sqltypes.Numeric()
+
+
+class cube(GenericFunction):
+ r"""Implement the ``CUBE`` grouping operation.
+
+ This function is used as part of the GROUP BY of a statement,
+ e.g. :meth:`.Select.group_by`::
+
+ stmt = select(
+ [func.sum(table.c.value), table.c.col_1, table.c.col_2]
+ ).group_by(func.cube(table.c.col_1, table.c.col_2))
+
+ .. versionadded:: 1.2
+
+ """
+
+
+class rollup(GenericFunction):
+ r"""Implement the ``ROLLUP`` grouping operation.
+
+ This function is used as part of the GROUP BY of a statement,
+ e.g. :meth:`.Select.group_by`::
+
+ stmt = select(
+ [func.sum(table.c.value), table.c.col_1, table.c.col_2]
+ ).group_by(func.rollup(table.c.col_1, table.c.col_2))
+
+ .. versionadded:: 1.2
+
+ """
+
+
+class grouping_sets(GenericFunction):
+ r"""Implement the ``GROUPING SETS`` grouping operation.
+
+ This function is used as part of the GROUP BY of a statement,
+ e.g. :meth:`.Select.group_by`::
+
+ stmt = select(
+ [func.sum(table.c.value), table.c.col_1, table.c.col_2]
+ ).group_by(func.grouping_sets(table.c.col_1, table.c.col_2))
+
+ In order to group by multiple sets, use the :func:`.tuple_` construct::
+
+ from sqlalchemy import tuple_
+
+ stmt = select(
+ [
+ func.sum(table.c.value),
+ table.c.col_1, table.c.col_2,
+ table.c.col_3]
+ ).group_by(
+ func.grouping_sets(
+ tuple_(table.c.col_1, table.c.col_2),
+ tuple_(table.c.value, table.c.col_3),
+ )
+ )
+
+
+ .. versionadded:: 1.2
+
+ """