Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
HHH-14624 Oracle from version 12 started supporting the syntax for pa…
…gination
- Loading branch information
Showing
5 changed files
with
207 additions
and
3 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
181 changes: 181 additions & 0 deletions
181
hibernate-core/src/main/java/org/hibernate/dialect/pagination/Oracle12LimitHandler.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,181 @@ | ||
| /* | ||
| * Hibernate, Relational Persistence for Idiomatic Java | ||
| * | ||
| * License: GNU Lesser General Public License (LGPL), version 2.1 or later. | ||
| * See the lgpl.txt file in the root directory or <http://www.gnu.org/licenses/lgpl-2.1.html>. | ||
| */ | ||
| package org.hibernate.dialect.pagination; | ||
|
|
||
| import java.util.Locale; | ||
|
|
||
| import org.hibernate.LockMode; | ||
| import org.hibernate.LockOptions; | ||
| import org.hibernate.engine.spi.QueryParameters; | ||
| import org.hibernate.engine.spi.RowSelection; | ||
|
|
||
| /** | ||
| * A {@link LimitHandler} for databases which support the | ||
| * ANSI SQL standard syntax {@code FETCH FIRST m ROWS ONLY} | ||
| * and {@code OFFSET n ROWS FETCH NEXT m ROWS ONLY}. | ||
| * | ||
| * @author Gavin King | ||
| */ | ||
| public class Oracle12LimitHandler extends AbstractLimitHandler { | ||
|
|
||
| public boolean bindLimitParametersInReverseOrder; | ||
| public boolean useMaxForLimit; | ||
|
|
||
| public static final Oracle12LimitHandler INSTANCE = new Oracle12LimitHandler(); | ||
|
|
||
| Oracle12LimitHandler() { | ||
| } | ||
|
|
||
| @Override | ||
| public String processSql(String sql, RowSelection selection) { | ||
| final boolean hasFirstRow = LimitHelper.hasFirstRow( selection ); | ||
| final boolean hasMaxRows = LimitHelper.hasMaxRows( selection ); | ||
|
|
||
| if ( !hasMaxRows ) { | ||
| return sql; | ||
| } | ||
|
|
||
| return processSql( sql, getForUpdateIndex( sql ), hasFirstRow ); | ||
| } | ||
|
|
||
| @Override | ||
| public String processSql(String sql, QueryParameters queryParameters) { | ||
| final RowSelection selection = queryParameters.getRowSelection(); | ||
|
|
||
| final boolean hasFirstRow = LimitHelper.hasFirstRow( selection ); | ||
| final boolean hasMaxRows = LimitHelper.hasMaxRows( selection ); | ||
|
|
||
| if ( !hasMaxRows ) { | ||
| return sql; | ||
| } | ||
|
|
||
| final LockOptions lockOptions = queryParameters.getLockOptions(); | ||
| if ( lockOptions != null ) { | ||
| final LockMode lockMode = lockOptions.getLockMode(); | ||
| switch ( lockMode ) { | ||
| case UPGRADE: | ||
| case PESSIMISTIC_READ: | ||
| case PESSIMISTIC_WRITE: | ||
| case UPGRADE_NOWAIT: | ||
| case FORCE: | ||
| case PESSIMISTIC_FORCE_INCREMENT: | ||
| case UPGRADE_SKIPLOCKED: | ||
| return processSql( sql, selection ); | ||
| default: | ||
| return processSqlOffsetFetch( sql, hasFirstRow ); | ||
| } | ||
| } | ||
| return processSqlOffsetFetch( sql, hasFirstRow ); | ||
| } | ||
|
|
||
| private String processSqlOffsetFetch(String sql, boolean hasFirstRow) { | ||
|
|
||
| final int forUpdateLastIndex = getForUpdateIndex( sql ); | ||
|
|
||
| if ( forUpdateLastIndex > -1 ) { | ||
| return processSql( sql, forUpdateLastIndex, hasFirstRow ); | ||
| } | ||
|
|
||
| bindLimitParametersInReverseOrder = false; | ||
| useMaxForLimit = false; | ||
|
|
||
| sql = normalizeStatement( sql ); | ||
| final int offsetFetchLength; | ||
| final String offsetFetchString; | ||
| if ( hasFirstRow ) { | ||
| offsetFetchString = " offset ? rows fetch next ? rows only"; | ||
| } | ||
| else { | ||
| offsetFetchString = " fetch first ? rows only"; | ||
| } | ||
| offsetFetchLength = sql.length() + offsetFetchString.length(); | ||
|
|
||
| return new StringBuilder( offsetFetchLength ).append( sql ).append( offsetFetchString ).toString(); | ||
| } | ||
|
|
||
| private String processSql(String sql, int forUpdateIndex, boolean hasFirstRow) { | ||
| bindLimitParametersInReverseOrder = true; | ||
| useMaxForLimit = true; | ||
| sql = normalizeStatement( sql ); | ||
|
|
||
| String forUpdateClause = null; | ||
| boolean isForUpdate = false; | ||
| if ( forUpdateIndex > -1 ) { | ||
| // save 'for update ...' and then remove it | ||
| forUpdateClause = sql.substring( forUpdateIndex ); | ||
| sql = sql.substring( 0, forUpdateIndex - 1 ); | ||
| isForUpdate = true; | ||
| } | ||
|
|
||
| final StringBuilder pagingSelect; | ||
|
|
||
| final int forUpdateClauseLength; | ||
| if ( forUpdateClause == null ) { | ||
| forUpdateClauseLength = 0; | ||
| } | ||
| else { | ||
| forUpdateClauseLength = forUpdateClause.length() + 1; | ||
| } | ||
|
|
||
| if ( hasFirstRow ) { | ||
| pagingSelect = new StringBuilder( sql.length() + forUpdateClauseLength + 98 ); | ||
| pagingSelect.append( "select * from ( select row_.*, rownum rownum_ from ( " ); | ||
| pagingSelect.append( sql ); | ||
| pagingSelect.append( " ) row_ where rownum <= ?) where rownum_ > ?" ); | ||
| } | ||
| else { | ||
| pagingSelect = new StringBuilder( sql.length() + forUpdateClauseLength + 37 ); | ||
| pagingSelect.append( "select * from ( " ); | ||
| pagingSelect.append( sql ); | ||
| pagingSelect.append( " ) where rownum <= ?" ); | ||
| } | ||
|
|
||
| if ( isForUpdate ) { | ||
| pagingSelect.append( " " ); | ||
| pagingSelect.append( forUpdateClause ); | ||
| } | ||
|
|
||
| return pagingSelect.toString(); | ||
| } | ||
|
|
||
| private String normalizeStatement(String sql) { | ||
| return sql.trim().replaceAll( "\\s+", " " ); | ||
| } | ||
|
|
||
| private int getForUpdateIndex(String sql) { | ||
| final int forUpdateLastIndex = sql.toLowerCase( Locale.ROOT ).lastIndexOf( "for update" ); | ||
| // We need to recognize cases like : select a from t where b = 'for update'; | ||
| final int lastIndexOfQuote = sql.lastIndexOf( "'" ); | ||
| if ( forUpdateLastIndex > -1 ) { | ||
| if ( lastIndexOfQuote == -1 ) { | ||
| return forUpdateLastIndex; | ||
| } | ||
| if ( lastIndexOfQuote > forUpdateLastIndex ) { | ||
| return -1; | ||
| } | ||
| return forUpdateLastIndex; | ||
| } | ||
| return forUpdateLastIndex; | ||
| } | ||
|
|
||
| @Override | ||
| public final boolean supportsLimit() { | ||
| return true; | ||
| } | ||
|
|
||
| @Override | ||
| public boolean bindLimitParametersInReverseOrder() { | ||
| return bindLimitParametersInReverseOrder; | ||
| } | ||
|
|
||
| @Override | ||
| public boolean useMaxForLimit() { | ||
| return useMaxForLimit; | ||
| } | ||
|
|
||
|
|
||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters