Function rewriteOracleSelectFetch

backend/plugin/db/oracle/query.go:255–269

(sql string, selectStmt *oracleast.SelectStmt, limitCount int)

}

func rewriteOracleSelectFetch(sql string, selectStmt *oracleast.SelectStmt, limitCount int) (string, error) {
	target := rightmostOracleSetSelect(selectStmt)
	if target.FetchFirst != nil {
		return rewriteOracleFetchClause(sql, target.FetchFirst, limitCount)
	}
	if target.ForUpdate != nil && target.ForUpdate.Loc.Start > 0 && target.ForUpdate.Loc.Start <= len(sql) {
		return sql[:target.ForUpdate.Loc.Start] + fmt.Sprintf("FETCH NEXT %d ROWS ONLY ", limitCount) + sql[target.ForUpdate.Loc.Start:], nil
	}

	loc := oracleast.NodeLoc(target)
	if loc.End < 0 || loc.End > len(sql) {
		return "", errors.Errorf("invalid SELECT end position %d", loc.End)
	}
	return sql[:loc.End] + fmt.Sprintf(" FETCH NEXT %d ROWS ONLY", limitCount) + sql[loc.End:], nil
}

func rightmostOracleSetSelect(selectStmt *oracleast.SelectStmt) *oracleast.SelectStmt {
	if selectStmt.Op != oracleast.SETOP_NONE && selectStmt.Rarg != nil {