Skip to content

Commit

Permalink
Add try with resources to Challenge redislabs-training#3 solution
Browse files Browse the repository at this point in the history
  • Loading branch information
alex-d-bondarev committed Oct 9, 2024
1 parent aff471a commit effc875
Showing 1 changed file with 10 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -80,20 +80,20 @@ private void updateBasic(Jedis jedis, String key, MeterReading reading) {

// Challenge #3
private void updateOptimized(Jedis jedis, String key, MeterReading reading) {
CompareAndUpdateScript compareScript = new CompareAndUpdateScript(jedisPool);
String reportingTime = ZonedDateTime.now(ZoneOffset.UTC).toString();

Transaction jedisT = jedis.multi();
try (Transaction jedisT = jedis.multi()) {

String reportingTime = ZonedDateTime.now(ZoneOffset.UTC).toString();
jedisT.hset(key, SiteStats.reportingTimeField, reportingTime);
jedisT.hincrBy(key, SiteStats.countField, 1);
jedisT.expire(key, WEEK_SECONDS);
jedisT.hset(key, SiteStats.reportingTimeField, reportingTime);
jedisT.hincrBy(key, SiteStats.countField, 1);
jedisT.expire(key, WEEK_SECONDS);

compareScript.updateIfGreater(jedisT, key, SiteStats.maxWhField, reading.getWhGenerated());
compareScript.updateIfLess(jedisT, key, SiteStats.minWhField, reading.getWhGenerated());
compareScript.updateIfGreater(jedisT, key, SiteStats.maxCapacityField, getCurrentCapacity(reading));
compareAndUpdateScript.updateIfGreater(jedisT, key, SiteStats.maxWhField, reading.getWhGenerated());
compareAndUpdateScript.updateIfLess(jedisT, key, SiteStats.minWhField, reading.getWhGenerated());
compareAndUpdateScript.updateIfGreater(jedisT, key, SiteStats.maxCapacityField, getCurrentCapacity(reading));

jedisT.exec();
jedisT.exec();
}
}

private Double getCurrentCapacity(MeterReading reading) {
Expand Down

0 comments on commit effc875

Please sign in to comment.