Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-2802 The implementation classes don't support orderByClause. 

This closes #1044.
This commit is contained in:
Byunghwa Yun 2016-09-22 19:00:16 +09:00 committed by Pierre Villard
parent 5198e70d14
commit 77f8503e98
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/db/impl/GenericDatabaseAdapter.java
View File

@ -48,7 +48,7 @@ public class GenericDatabaseAdapter implements DatabaseAdapter {
} }
if (!StringUtils.isEmpty(orderByClause)) { if (!StringUtils.isEmpty(orderByClause)) {
query.append(" ORDER BY "); query.append(" ORDER BY ");
query.append(whereClause); query.append(orderByClause);
} }
if (limit != null) { if (limit != null) {
query.append(" LIMIT "); query.append(" LIMIT ");

2
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/db/impl/OracleDatabaseAdapter.java
View File

@ -62,7 +62,7 @@ public class OracleDatabaseAdapter implements DatabaseAdapter {
} }
if (!StringUtils.isEmpty(orderByClause)) { if (!StringUtils.isEmpty(orderByClause)) {
query.append(" ORDER BY "); query.append(" ORDER BY ");
query.append(whereClause); query.append(orderByClause);
} }
if (nestedSelect) { if (nestedSelect) {
query.append(") a"); query.append(") a");

2
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/db/impl/DerbyDatabaseAdapter.java
View File

@ -49,7 +49,7 @@ public class DerbyDatabaseAdapter implements DatabaseAdapter {
} }
if (!StringUtils.isEmpty(orderByClause)) { if (!StringUtils.isEmpty(orderByClause)) {
query.append(" ORDER BY "); query.append(" ORDER BY ");
query.append(whereClause); query.append(orderByClause);
} }
if (offset != null && offset > 0) { if (offset != null && offset > 0) {
query.append(" OFFSET "); query.append(" OFFSET ");