diff --git a/src/main/java/fi/hsl/transitdata/pubtransredisconnect/MetroJourneyResultSetProcessor.java b/src/main/java/fi/hsl/transitdata/pubtransredisconnect/MetroJourneyResultSetProcessor.java index 8d4aa67..a71e0f4 100644 --- a/src/main/java/fi/hsl/transitdata/pubtransredisconnect/MetroJourneyResultSetProcessor.java +++ b/src/main/java/fi/hsl/transitdata/pubtransredisconnect/MetroJourneyResultSetProcessor.java @@ -13,7 +13,9 @@ import java.time.ZonedDateTime; import java.time.format.DateTimeFormatter; import java.time.temporal.ChronoUnit; +import java.util.ArrayList; import java.util.HashMap; +import java.util.List; import java.util.Map; public class MetroJourneyResultSetProcessor extends AbstractResultSetProcessor { @@ -26,6 +28,7 @@ public MetroJourneyResultSetProcessor(final RedisUtils redisUtils, final QueryUt public void processResultSet(final ResultSet resultSet) throws Exception { int rowCounter = 0; int redisCounter = 0; + List metroKeys = new ArrayList<>(); while (resultSet.next()) { rowCounter++; @@ -45,6 +48,7 @@ public void processResultSet(final ResultSet resultSet) throws Exception { values.put(TransitdataProperties.KEY_START_STOP_NUMBER, stopNumber); String metroKey = TransitdataProperties.formatMetroId(stopNumber, dateTime); + metroKeys.add(metroKey); String response = redisUtils.setValues(metroKey, values); if (redisUtils.checkResponse(response)) { redisUtils.setExpire(metroKey); @@ -55,6 +59,7 @@ public void processResultSet(final ResultSet resultSet) throws Exception { } log.info("Inserted {} redis metro id keys for {} DB rows", redisCounter, rowCounter); + log.info("Metro keys: " + metroKeys); } protected String getQuery() {