1 package de.juplo.kafka.outbox.postage;
3 import lombok.AllArgsConstructor;
4 import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
5 import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
6 import org.springframework.stereotype.Repository;
8 import java.sql.Timestamp;
9 import java.time.ZonedDateTime;
14 public class OutboxRepository
16 private static final String SQL_UPDATE =
17 "INSERT INTO outbox (key, value, issued) VALUES (:key, :value, :issued)";
19 private final NamedParameterJdbcTemplate jdbcTemplate;
22 public void save(String key, String value, ZonedDateTime issued)
24 MapSqlParameterSource parameters = new MapSqlParameterSource();
25 parameters.addValue("key", key);
26 parameters.addValue("value", value);
27 parameters.addValue("issued", Timestamp.from(issued.toInstant()));
28 jdbcTemplate.update(SQL_UPDATE, parameters);