Skip to content
Snippets Groups Projects
Verified Commit e5fecf65 authored by Jesper Zedlitz's avatar Jesper Zedlitz
Browse files

marked old CKAN stuff

parent f4569272
Branches piveau
No related tags found
No related merge requests found
Pipeline #1685 failed
...@@ -34,7 +34,6 @@ import java.time.LocalDate; ...@@ -34,7 +34,6 @@ import java.time.LocalDate;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter; import java.time.format.DateTimeFormatter;
import java.util.*; import java.util.*;
import java.util.stream.Collectors;
/** /**
* Bearbeiten von Datenänderungen direkt über das CKAN API. * Bearbeiten von Datenänderungen direkt über das CKAN API.
...@@ -58,7 +57,7 @@ public class OpenDataUpdatesPiveau { ...@@ -58,7 +57,7 @@ public class OpenDataUpdatesPiveau {
public static void main(String[] args) throws Exception { public static void main(String[] args) throws Exception {
if (args.length < 1 || !new File(args[0]).exists()) { if (args.length < 1 || !new File(args[0]).exists()) {
System.out.println("USAGE: java OpenDataUpdatesCkan config.yml [single_dataset_id]"); System.out.println("USAGE: java OpenDataUpdatesPiveau config.yml [single_dataset_id]");
System.exit(2); System.exit(2);
} }
...@@ -96,6 +95,10 @@ public class OpenDataUpdatesPiveau { ...@@ -96,6 +95,10 @@ public class OpenDataUpdatesPiveau {
} }
/**
* @deprecated old CKAN stuff
*/
@Deprecated
public static String getExtrasValue(JSONObject dataset, String key) { public static String getExtrasValue(JSONObject dataset, String key) {
final JSONArray extras = dataset.getJSONArray("extras"); final JSONArray extras = dataset.getJSONArray("extras");
for (Object o : extras) { for (Object o : extras) {
...@@ -125,6 +128,10 @@ public class OpenDataUpdatesPiveau { ...@@ -125,6 +128,10 @@ public class OpenDataUpdatesPiveau {
return result; return result;
} }
/**
* @deprecated old CKAN stuff
*/
@Deprecated
static void removeExtraValue(JSONObject dataset, String key) { static void removeExtraValue(JSONObject dataset, String key) {
JSONArray extras = dataset.getJSONArray("extras"); JSONArray extras = dataset.getJSONArray("extras");
int foundAtPosition = -1; int foundAtPosition = -1;
...@@ -139,6 +146,10 @@ public class OpenDataUpdatesPiveau { ...@@ -139,6 +146,10 @@ public class OpenDataUpdatesPiveau {
} }
} }
/**
* @deprecated old CKAN stuff
*/
@Deprecated
static void setExtraValue(JSONObject dataset, String key, String value) { static void setExtraValue(JSONObject dataset, String key, String value) {
final JSONObject entry = new JSONObject(); final JSONObject entry = new JSONObject();
entry.put("key", key); entry.put("key", key);
...@@ -319,14 +330,14 @@ public class OpenDataUpdatesPiveau { ...@@ -319,14 +330,14 @@ public class OpenDataUpdatesPiveau {
return false; return false;
} }
final String newestDatasetId = ckanAPI.findNewestDataset(update.collectionId); final Optional<String> newestDatasetId = findNewestDataset(update.collectionId);
if (newestDatasetId == null) { if (newestDatasetId.isEmpty()) {
log.error("In der Collection {} gibt es keinen Datensatz.", update.collectionId); log.error("In der Collection {} gibt es keinen Datensatz.", update.collectionId);
return false; return false;
} }
final JSONObject existingDataset = ckanAPI.readDataset(newestDatasetId); final JSONObject existingDataset = ckanAPI.readDataset(newestDatasetId.get());
log.info("Änderung erkannt an Dataset " + newestDatasetId); log.info("Änderung erkannt an Dataset " + newestDatasetId);
final String timeNow = LocalDateTime.now().format(DateTimeFormatter.ISO_DATE_TIME); final String timeNow = LocalDateTime.now().format(DateTimeFormatter.ISO_DATE_TIME);
final DatasetMetadata metadata = readMetadata(localDataDir); final DatasetMetadata metadata = readMetadata(localDataDir);
...@@ -418,6 +429,10 @@ public class OpenDataUpdatesPiveau { ...@@ -418,6 +429,10 @@ public class OpenDataUpdatesPiveau {
} }
Optional<String> findNewestDataset(String collectionId) throws IOException {
return Optional.ofNullable(ckanAPI.findNewestDataset(collectionId));
}
/** /**
* Datei wird einfach überschrieben und ist nicht öffentlich erreichbar. * Datei wird einfach überschrieben und ist nicht öffentlich erreichbar.
* <p> * <p>
...@@ -431,14 +446,14 @@ public class OpenDataUpdatesPiveau { ...@@ -431,14 +446,14 @@ public class OpenDataUpdatesPiveau {
return false; return false;
} }
final String newestDatasetId = ckanAPI.findNewestDataset(update.collectionId); final Optional<String> newestDatasetId = findNewestDataset(update.collectionId);
if (newestDatasetId == null) { if (newestDatasetId.isEmpty()) {
log.error("In der Collection {} gibt es keinen Datensatz.", update.collectionId); log.error("In der Collection {} gibt es keinen Datensatz.", update.collectionId);
return false; return false;
} }
final JSONObject existingDataset = ckanAPI.readDataset(newestDatasetId); final JSONObject existingDataset = ckanAPI.readDataset(newestDatasetId.get());
log.info("Änderung erkannt an Dataset " + newestDatasetId); log.info("Änderung erkannt an Dataset " + newestDatasetId);
final String timeNow = LocalDateTime.now().format(DateTimeFormatter.ISO_DATE_TIME); final String timeNow = LocalDateTime.now().format(DateTimeFormatter.ISO_DATE_TIME);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment