/* * Copyright [2021] [MaxKey of copyright http://www.maxkey.top] * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.dromara.mybatis.jpa.dialect; import java.sql.PreparedStatement; import java.sql.SQLException; import org.dromara.mybatis.jpa.entity.JpaPage; public class OracleDialect extends Dialect { public OracleDialect() { super(); } @Override public boolean supportsLimit() { return true; } @Override public String getLimitString(String sql, JpaPage page) { if ( page.getPageSize() == 0 ) { return sql + " fetch first " + page.getStartRow() + " rows only"; } StringBuilder pagingSelect = new StringBuilder( sql.length() + 200 ) .append( "select * from (select inner_table_.*, rownum as rownumber_ from ( " ) .append( sql ) //nest the main query in an outer select .append( ") inner_table_ ) where rownumber_ > " ) .append( page.getStartRow() ) .append(" and rownumber_ <=") .append( page.getEndRow() ) .append( " order by rownumber_" ); return pagingSelect.toString(); } @Override public String getPreparedStatementLimitString(String sql, JpaPage pagination) { //LIMIT #{pageResults} OFFSET #{startRow} if(pagination.getPageSize()>0&&pagination.getStartRow()>0){ return sql + " limit ? , ?"; }else if(pagination.getPageSize()>0){ return sql + " limit ? "; }else{ return sql + " limit ?"; } } @Override public void setLimitParamters(PreparedStatement preparedStatement,int parameterSize,JpaPage page) { try { if(page.getPageSize()>0&&page.getStartRow()>0){ preparedStatement.setInt(++parameterSize, page.getPageSize()); preparedStatement.setInt(++parameterSize, page.getPageSize()); }else if(page.getPageSize()>0){ preparedStatement.setInt(++parameterSize, page.getPageSize()); }else{ preparedStatement.setInt(++parameterSize, 1000); } } catch (SQLException e) { e.printStackTrace(); } } /* (non-Javadoc) * @see java.lang.Object#toString() */ @Override public String toString() { return "OracleDialect [" + OracleDialect.class + "]"; } }