import java.sql.Timestamp;
import java.time.ZonedDateTime;
import java.util.List;
+import java.util.Set;
@Repository
private static final String SQL_UPDATE =
"INSERT INTO outbox (key, value, issued) VALUES (:key, :value, :issued)";
private static final String SQL_DELETE =
- "DELETE FROM outbox WHERE id <= :id";
+ "DELETE FROM outbox WHERE id IN (:ids)";
private final NamedParameterJdbcTemplate jdbcTemplate;
jdbcTemplate.update(SQL_UPDATE, parameters);
}
- public int delete(Long id)
+ public int delete(Set<Long> ids)
{
+ if (ids == null || ids.isEmpty())
+ return 0;
MapSqlParameterSource parameters = new MapSqlParameterSource();
- parameters.addValue("id", id);
+ parameters.addValue("ids", ids);
return jdbcTemplate.update(SQL_DELETE, parameters);
}