Skip to content

Commit e8828bf

Browse files
committed
Formating fix added. Signed off by gloul408@gmail.com
Signed-off-by: Rahul Kumar <gloul408@gmail.com>
1 parent 2cafaf5 commit e8828bf

2 files changed

Lines changed: 20 additions & 18 deletions

File tree

spring-batch-infrastructure/src/main/java/org/springframework/batch/infrastructure/item/database/support/SparkSqlPagingQueryProvider.java

Lines changed: 18 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -20,30 +20,31 @@
2020
import org.springframework.util.StringUtils;
2121

2222
/**
23-
* SparkSQL implementation of a {@link PagingQueryProvider} using database specific features.
23+
* SparkSQL implementation of a {@link PagingQueryProvider} using database specific
24+
* features.
2425
*
2526
* @author Rahul Kumar
2627
* @since 2.0
2728
*/
2829
public class SparkSqlPagingQueryProvider extends AbstractSqlPagingQueryProvider {
2930

30-
@Override
31-
public String generateFirstPageQuery(int pageSize) {
32-
return SqlPagingQueryUtils.generateLimitSqlQuery(this, false, buildLimitClause(pageSize));
33-
}
31+
@Override
32+
public String generateFirstPageQuery(int pageSize) {
33+
return SqlPagingQueryUtils.generateLimitSqlQuery(this, false, buildLimitClause(pageSize));
34+
}
3435

35-
@Override
36-
public String generateRemainingPagesQuery(int pageSize) {
37-
if (StringUtils.hasText(getGroupClause())) {
38-
return SqlPagingQueryUtils.generateLimitGroupedSqlQuery(this, buildLimitClause(pageSize));
39-
}
40-
else {
41-
return SqlPagingQueryUtils.generateLimitSqlQuery(this, true, buildLimitClause(pageSize));
42-
}
43-
}
36+
@Override
37+
public String generateRemainingPagesQuery(int pageSize) {
38+
if (StringUtils.hasText(getGroupClause())) {
39+
return SqlPagingQueryUtils.generateLimitGroupedSqlQuery(this, buildLimitClause(pageSize));
40+
}
41+
else {
42+
return SqlPagingQueryUtils.generateLimitSqlQuery(this, true, buildLimitClause(pageSize));
43+
}
44+
}
4445

45-
private String buildLimitClause(int pageSize) {
46-
return "LIMIT " + pageSize;
47-
}
46+
private String buildLimitClause(int pageSize) {
47+
return "LIMIT " + pageSize;
48+
}
4849

4950
}

spring-batch-infrastructure/src/main/java/org/springframework/batch/infrastructure/support/DatabaseType.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,8 @@ public enum DatabaseType {
4343

4444
DERBY("Apache Derby"), DB2("DB2"), DB2VSE("DB2VSE"), DB2ZOS("DB2ZOS"), DB2AS400("DB2AS400"),
4545
HSQL("HSQL Database Engine"), SQLSERVER("Microsoft SQL Server"), MYSQL("MySQL"), ORACLE("Oracle"),
46-
POSTGRES("PostgreSQL"), SYBASE("Sybase"), H2("H2"), SQLITE("SQLite"), HANA("HDB"), MARIADB("MariaDB"), SPARKSQL("SparkSQL");
46+
POSTGRES("PostgreSQL"), SYBASE("Sybase"), H2("H2"), SQLITE("SQLite"), HANA("HDB"), MARIADB("MariaDB"),
47+
SPARKSQL("SparkSQL");
4748

4849
private static final Map<String, DatabaseType> DATABASE_TYPES = Arrays.stream(DatabaseType.values())
4950
.collect(Collectors.toMap(DatabaseType::getProductName, Function.identity()));

0 commit comments

Comments
 (0)