alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-4404 Added signal table support for Oracle 11G

Browse Source
This commit is contained in:
nathan-smit-1 2022-01-19 13:24:38 +02:00 committed by Chris Cranford
parent 7fb833166f
commit d188366c3d
1 changed files with 17 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleConnection.java
View File

@ -454,12 +454,23 @@ public String buildSelectWithRowLimits(TableId tableId,
.append(" WHERE ")
.append(condition.get());
}
sql
.append(" ORDER BY ")
.append(orderBy)
.append(" FETCH NEXT ")
.append(limit)
.append(" ROWS ONLY");
if (getOracleVersion().getMajor() < 12) {
sql
.insert(0, " SELECT * FROM (")
.append(" ORDER BY ")
.append(orderBy)
.append(")")
.append(" WHERE ROWNUM <=")
.append(limit);
}
else {
sql
.append(" ORDER BY ")
.append(orderBy)
.append(" FETCH NEXT ")
.append(limit)
.append(" ROWS ONLY");
}
return sql.toString();
}