diff options
| author | Federico Caselli <cfederico87@gmail.com> | 2021-03-30 23:15:04 +0200 |
|---|---|---|
| committer | Mike Bayer <mike_mp@zzzcomputing.com> | 2021-03-31 22:13:30 -0400 |
| commit | a357baec856bb73c511f8f8484d316f19a29252a (patch) | |
| tree | bcc2f6c4da109191e93e74bfb5558d9ab09b8c7f /lib/sqlalchemy/dialects/oracle/base.py | |
| parent | 62e68beea671215e98cb939bb87af95d6d9f35ee (diff) | |
| download | sqlalchemy-a357baec856bb73c511f8f8484d316f19a29252a.tar.gz | |
Fix MSSQL / Oracle limit/offset regressions
Fixed a regression in MSSQL 2012+ that prevented the order clause
to be rendered when ``offset=0`` is used in a subquery.
Fixed critical regression where the Oracle compiler would not maintain the
correct parameter values in the LIMIT/OFFSET for a select due to a caching
issue.
Co-authored-by: Mike Bayer <mike_mp@zzzcomputing.com>
Fixes: #6163
Fixes: #6173
Change-Id: Ieb12354271d09ad935d684ee0db4fa0128837215
Diffstat (limited to 'lib/sqlalchemy/dialects/oracle/base.py')
| -rw-r--r-- | lib/sqlalchemy/dialects/oracle/base.py | 43 |
1 files changed, 15 insertions, 28 deletions
diff --git a/lib/sqlalchemy/dialects/oracle/base.py b/lib/sqlalchemy/dialects/oracle/base.py index 88b101811..46fcbbbe1 100644 --- a/lib/sqlalchemy/dialects/oracle/base.py +++ b/lib/sqlalchemy/dialects/oracle/base.py @@ -561,7 +561,6 @@ from ...types import CHAR from ...types import CLOB from ...types import FLOAT from ...types import INTEGER -from ...types import Integer from ...types import NCHAR from ...types import NVARCHAR from ...types import TIMESTAMP @@ -1092,6 +1091,13 @@ class OracleCompiler(compiler.SQLCompiler): ): limit_clause = select._limit_clause offset_clause = select._offset_clause + + if select._simple_int_clause(limit_clause): + limit_clause = limit_clause._render_literal_execute() + + if select._simple_int_clause(offset_clause): + offset_clause = offset_clause._render_literal_execute() + # currently using form at: # https://blogs.oracle.com/oraclemagazine/\ # on-rownum-and-limiting-results @@ -1120,22 +1126,17 @@ class OracleCompiler(compiler.SQLCompiler): is not None ] ) + if ( limit_clause is not None and self.dialect.optimize_limits and select._simple_int_clause(limit_clause) ): - param = sql.bindparam( - "_ora_frow", - select._limit, - type_=Integer, - literal_execute=True, - unique=True, - ) limitselect = limitselect.prefix_with( expression.text( - "/*+ FIRST_ROWS(:_ora_frow) */" - ).bindparams(param) + "/*+ FIRST_ROWS(%s) */" + % self.process(limit_clause, **kwargs) + ) ) limitselect._oracle_visit = True @@ -1155,19 +1156,14 @@ class OracleCompiler(compiler.SQLCompiler): offset_clause is None or select._simple_int_clause(offset_clause) ): - max_row = select._limit + max_row = limit_clause if offset_clause is not None: - max_row += select._offset - max_row = sql.bindparam( - None, - max_row, - type_=Integer, - literal_execute=True, - unique=True, - ) + max_row = max_row + offset_clause + else: max_row = limit_clause + if offset_clause is not None: max_row = max_row + offset_clause limitselect = limitselect.where( @@ -1214,15 +1210,6 @@ class OracleCompiler(compiler.SQLCompiler): adapter.traverse(elem) for elem in for_update.of ] - if select._simple_int_clause(offset_clause): - offset_clause = sql.bindparam( - None, - select._offset, - Integer, - literal_execute=True, - unique=True, - ) - offsetselect = offsetselect.where( sql.literal_column("ora_rn") > offset_clause ) |
