From f1278ae7119fcb77326c6d520915ecaa1527d39c Mon Sep 17 00:00:00 2001 From: Vitaly Takmazov Date: Sun, 7 Apr 2019 03:49:09 +0300 Subject: Edit telegram messages --- src/main/java/com/juick/service/MessagesService.java | 1 + src/main/java/com/juick/service/MessagesServiceImpl.java | 12 ++++++++++++ 2 files changed, 13 insertions(+) (limited to 'src/main/java/com/juick/service') diff --git a/src/main/java/com/juick/service/MessagesService.java b/src/main/java/com/juick/service/MessagesService.java index 8f8c3e62..e98b2b1d 100644 --- a/src/main/java/com/juick/service/MessagesService.java +++ b/src/main/java/com/juick/service/MessagesService.java @@ -144,4 +144,5 @@ public interface MessagesService { String getMessageProperty(Integer mid, Integer rid, String key); void setMessageProperty(Integer mid, Integer rid, String key, String value); + Optional> findMessageByProperty(String key, String value); } diff --git a/src/main/java/com/juick/service/MessagesServiceImpl.java b/src/main/java/com/juick/service/MessagesServiceImpl.java index 798502b3..0cf321b6 100644 --- a/src/main/java/com/juick/service/MessagesServiceImpl.java +++ b/src/main/java/com/juick/service/MessagesServiceImpl.java @@ -1217,4 +1217,16 @@ public class MessagesServiceImpl extends BaseJdbcService implements MessagesServ "WHERE message_id=:mid AND reply_id=:rid AND property_key=:key", parameterSource); } } + + @Transactional(readOnly = true) + @Override + public Optional> findMessageByProperty(String key, String value) { + List> results = jdbcTemplate.query("SELECT message_id, reply_id FROM messages_properties " + + "WHERE property_key=? AND property_value=?", + (rs, rowNum) -> Pair.of(rs.getInt(1), rs.getInt(2)), key, value); + if (results.size() > 0) { + return Optional.of(results.get(0)); + } + return Optional.empty(); + } } -- cgit v1.2.3