fix empty file
This commit is contained in:
parent
2e07b2c417
commit
5c4672ba47
1 changed files with 4 additions and 3 deletions
|
|
@ -119,6 +119,7 @@ public class DownloadService {
|
|||
if (request.getRequestArgumentLimit() != null) {
|
||||
limit = request.getRequestArgumentLimit();
|
||||
}
|
||||
List<String[]> results = new ArrayList<>();
|
||||
try (Connection connection = DatabaseConnection.getConnection(
|
||||
request.getSqlConnectionParams())) {
|
||||
Map<String, Object> query = buildSqlQuery(request, ids, startDate, endDate,
|
||||
|
|
@ -136,7 +137,7 @@ public class DownloadService {
|
|||
url = url.replace("${" + paramName + "}",
|
||||
resultSet
|
||||
);
|
||||
List<String[]> results = new ArrayList<>(executeSqlQuery(connection, url));
|
||||
results = new ArrayList<>(executeSqlQuery(connection, url));
|
||||
if (results.size() <= 1) {
|
||||
break;
|
||||
}
|
||||
|
|
@ -148,7 +149,7 @@ public class DownloadService {
|
|||
else {
|
||||
String requestURL = (String) query.get("requestURL");
|
||||
while (true) {
|
||||
List<String[]> results = new ArrayList<>(executeSqlQuery(connection, requestURL));
|
||||
results = new ArrayList<>(executeSqlQuery(connection, requestURL));
|
||||
if (results.size() <= 1) {
|
||||
break;
|
||||
}
|
||||
|
|
@ -166,7 +167,7 @@ public class DownloadService {
|
|||
}
|
||||
}
|
||||
if (allFiles.isEmpty()) {
|
||||
return writeSingleSqlCsvFile(new ArrayList<>(), "download-part 0", ".csv");
|
||||
return writeSingleSqlCsvFile(results, "download-part 0", ".csv");
|
||||
}
|
||||
if (allFiles.size() == 1) {
|
||||
return allFiles.get(0);
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue