package com.juick.service; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Repository; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.StringUtils; import javax.inject.Inject; import java.util.List; /** * Created by aalexeev on 11/13/16. */ @Repository @Transactional(readOnly = true) public class PushQueriesServiceImpl extends BaseJdbcService implements PushQueriesService { @Inject public PushQueriesServiceImpl(JdbcTemplate jdbcTemplate) { super(jdbcTemplate, null); } @Override public List getAndroidRegID(final int uid) { return getJdbcTemplate().queryForList( "SELECT regid FROM android WHERE user_id=?", String.class, uid); } @Override public List getAndroidTokens(final List uids) { return getJdbcTemplate().queryForList( "SELECT regid FROM android INNER JOIN users " + "ON (users.id=android.user_id) WHERE users.id IN (" + StringUtils.collectionToCommaDelimitedString(uids) + ")", String.class); } @Override public List getWinPhoneURL(final int uid) { return getJdbcTemplate().queryForList( "SELECT url FROM winphone WHERE user_id=?", String.class, uid); } @Override public List getWindowsTokens(final List uids) { return getJdbcTemplate().queryForList( "SELECT url FROM winphone INNER JOIN users " + "ON (users.id=winphone.user_id) WHERE users.id IN (" + StringUtils.collectionToCommaDelimitedString(uids) + ")", String.class); } @Override public List getAPNSToken(final int uid) { return getJdbcTemplate().queryForList( "SELECT token from ios WHERE user_id=?", String.class, uid); } @Override public boolean deleteAPNSToken(String token) { return getJdbcTemplate().update("DELETE FROM ios WHERE token=?", token) > 0; } @Override public List getAPNSTokens(final List uids) { return getJdbcTemplate().queryForList( "SELECT token FROM ios INNER JOIN users " + "ON (users.id=ios.user_id) WHERE users.id IN (" + StringUtils.collectionToCommaDelimitedString(uids) + ")", String.class); } }