Spring/spring-batch
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

BATCH-760: added order by clause to all generated sql

Browse Source
This commit is contained in:
trisberg
2008-08-27 23:57:45 +00:00
parent 6ef4c3b44a
commit 31109f0a4d
15 changed files with 72 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/support/Db2PagingQueryProvider.java
View File

@@ -15,6 +15,7 @@ public class Db2PagingQueryProvider extends SqlWindowingPagingQueryProvider {
sql.append("SELECT ").append(getSelectClause());
sql.append(" FROM ").append(getFromClause());
sql.append(getWhereClause() == null ? "" : " WHERE " + getWhereClause());
sql.append(" ORDER BY ").append(getSortKey()).append(" ASC");
sql.append(" FETCH FIRST ").append(pageSize).append(" ROWS ONLY");
return sql.toString();
@@ -27,6 +28,7 @@ public class Db2PagingQueryProvider extends SqlWindowingPagingQueryProvider {
sql.append(" FROM ").append(getFromClause());
sql.append(" WHERE ").append(getSortKey()).append(" > ?");
sql.append(getWhereClause() == null ? "" : " AND " + getWhereClause());
sql.append(" ORDER BY ").append(getSortKey()).append(" ASC");
sql.append(" FETCH FIRST ").append(pageSize).append(" ROWS ONLY");
return sql.toString();

3
spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/support/HsqlPagingQueryProvider.java
View File

@@ -29,6 +29,7 @@ public class HsqlPagingQueryProvider extends AbstractSqlPagingQueryProvider {
sql.append("SELECT ").append("TOP ").append(pageSize).append(" ").append(getSelectClause());
sql.append(" FROM ").append(getFromClause());
sql.append(getWhereClause() == null ? "" : " WHERE " + getWhereClause());
sql.append(" ORDER BY ").append(getSortKey()).append(" ASC");
return sql.toString();
}
@@ -40,6 +41,7 @@ public class HsqlPagingQueryProvider extends AbstractSqlPagingQueryProvider {
sql.append(" FROM ").append(getFromClause());
sql.append(" WHERE ").append(getSortKey()).append(" > ?");
sql.append(getWhereClause() == null ? "" : " AND " + getWhereClause());
sql.append(" ORDER BY ").append(getSortKey()).append(" ASC");
return sql.toString();
}
@@ -53,6 +55,7 @@ public class HsqlPagingQueryProvider extends AbstractSqlPagingQueryProvider {
sql.append("SELECT LIMIT ").append(offset).append(" 1 ").append(getSortKey()).append(" AS SORT_KEY");
sql.append(" FROM ").append(getFromClause());
sql.append(getWhereClause() == null ? "" : " WHERE " + getWhereClause());
sql.append(" ORDER BY ").append(getSortKey()).append(" ASC");
return sql.toString();
}

6
spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/support/MySqlPagingQueryProvider.java
View File

@@ -29,6 +29,7 @@ public class MySqlPagingQueryProvider extends AbstractSqlPagingQueryProvider {
sql.append("SELECT ").append(getSelectClause());
sql.append(" FROM ").append(getFromClause());
sql.append(getWhereClause() == null ? "" : " WHERE " + getWhereClause());
sql.append(" ORDER BY ").append(getSortKey()).append(" ASC");
sql.append(" LIMIT ").append(pageSize);
return sql.toString();
@@ -41,6 +42,7 @@ public class MySqlPagingQueryProvider extends AbstractSqlPagingQueryProvider {
sql.append(" FROM ").append(getFromClause());
sql.append(" WHERE ").append(getSortKey()).append(" > ?");
sql.append(getWhereClause() == null ? "" : " AND " + getWhereClause());
sql.append(" ORDER BY ").append(getSortKey()).append(" ASC");
sql.append(" LIMIT ").append(pageSize);
return sql.toString();
@@ -53,7 +55,9 @@ public class MySqlPagingQueryProvider extends AbstractSqlPagingQueryProvider {
StringBuilder sql = new StringBuilder();
sql.append("SELECT ").append(getSortKey()).append(" AS SORT_KEY");
sql.append(" FROM ").append(getFromClause()).append(getWhereClause() == null ? "" : " WHERE " + getWhereClause());
sql.append(" FROM ").append(getFromClause());
sql.append(getWhereClause() == null ? "" : " WHERE " + getWhereClause());
sql.append(" ORDER BY ").append(getSortKey()).append(" ASC");
sql.append(" LIMIT ").append(offset).append(" 1");
return sql.toString();

2
spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/support/OraclePagingQueryProvider.java
View File

@@ -16,6 +16,7 @@ public class OraclePagingQueryProvider extends SqlWindowingPagingQueryProvider {
sql.append(" FROM ").append(getFromClause());
sql.append(" WHERE ROWNUM <= ").append(pageSize);
sql.append(getWhereClause() == null ? "" : " AND " + getWhereClause());
sql.append(" ORDER BY ").append(getSortKey()).append(" ASC");
return sql.toString();
}
@@ -28,6 +29,7 @@ public class OraclePagingQueryProvider extends SqlWindowingPagingQueryProvider {
sql.append(" WHERE ").append(getSortKey()).append(" > ?");
sql.append(" AND ROWNUM <= ").append(pageSize);
sql.append(getWhereClause() == null ? "" : " AND " + getWhereClause());
sql.append(" ORDER BY ").append(getSortKey()).append(" ASC");
return sql.toString();
}

6
spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/support/PostgresPagingQueryProvider.java
View File

@@ -14,6 +14,7 @@ public class PostgresPagingQueryProvider extends AbstractSqlPagingQueryProvider
sql.append("SELECT ").append(getSelectClause());
sql.append(" FROM ").append(getFromClause());
sql.append(getWhereClause() == null ? "" : " WHERE " + getWhereClause());
sql.append(" ORDER BY ").append(getSortKey()).append(" ASC");
sql.append(" LIMIT ").append(pageSize);
return sql.toString();
@@ -26,6 +27,7 @@ public class PostgresPagingQueryProvider extends AbstractSqlPagingQueryProvider
sql.append(" FROM ").append(getFromClause());
sql.append(" WHERE ").append(getSortKey()).append(" > ?");
sql.append(getWhereClause() == null ? "" : " AND " + getWhereClause());
sql.append(" ORDER BY ").append(getSortKey()).append(" ASC");
sql.append(" LIMIT ").append(pageSize);
return sql.toString();
@@ -38,7 +40,9 @@ public class PostgresPagingQueryProvider extends AbstractSqlPagingQueryProvider
StringBuilder sql = new StringBuilder();
sql.append("SELECT ").append(getSortKey()).append(" AS SORT_KEY");
sql.append(" FROM ").append(getFromClause()).append(getWhereClause() == null ? "" : " WHERE " + getWhereClause());
sql.append(" FROM ").append(getFromClause());
sql.append(getWhereClause() == null ? "" : " WHERE " + getWhereClause());
sql.append(" ORDER BY ").append(getSortKey()).append(" ASC");
sql.append(" LIMIT ").append(offset).append(" 1");
return sql.toString();

2
spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/support/SqlServerPagingQueryProvider.java
View File

@@ -15,6 +15,7 @@ public class SqlServerPagingQueryProvider extends SqlWindowingPagingQueryProvide
sql.append("SELECT ").append("TOP ").append(pageSize).append(" ").append(getSelectClause());
sql.append(" FROM ").append(getFromClause());
sql.append(getWhereClause() == null ? "" : " WHERE " + getWhereClause());
sql.append(" ORDER BY ").append(getSortKey()).append(" ASC");
return sql.toString();
}
@@ -26,6 +27,7 @@ public class SqlServerPagingQueryProvider extends SqlWindowingPagingQueryProvide
sql.append(" FROM ").append(getFromClause());
sql.append(" WHERE ").append(getSortKey()).append(" > ?");
sql.append(getWhereClause() == null ? "" : " AND " + getWhereClause());
sql.append(" ORDER BY ").append(getSortKey()).append(" ASC");
return sql.toString();
}

2
spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/support/SybasePagingQueryProvider.java
View File

@@ -15,6 +15,7 @@ public class SybasePagingQueryProvider extends SqlWindowingPagingQueryProvider {
sql.append("SELECT ").append("TOP ").append(pageSize).append(" ").append(getSelectClause());
sql.append(" FROM ").append(getFromClause());
sql.append(getWhereClause() == null ? "" : " WHERE " + getWhereClause());
sql.append(" ORDER BY ").append(getSortKey()).append(" ASC");
return sql.toString();
}
@@ -26,6 +27,7 @@ public class SybasePagingQueryProvider extends SqlWindowingPagingQueryProvider {
sql.append(" FROM ").append(getFromClause());
sql.append(" WHERE ").append(getSortKey()).append(" > ?");
sql.append(getWhereClause() == null ? "" : " AND " + getWhereClause());
sql.append(" ORDER BY ").append(getSortKey()).append(" ASC");
return sql.toString();
}