Package tigase.push.repositories
Class JDBCPushRepository
- java.lang.Object
-
- tigase.push.repositories.AbstractPushRepository<tigase.db.DataRepository>
-
- tigase.push.repositories.JDBCPushRepository
-
- All Implemented Interfaces:
tigase.db.DataSourceAware<tigase.db.DataRepository>
,tigase.db.util.RepositoryVersionAware
,IPushRepository<tigase.db.DataRepository>
public class JDBCPushRepository extends AbstractPushRepository<tigase.db.DataRepository> implements tigase.db.util.RepositoryVersionAware
Created by andrzej on 05.01.2017.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class tigase.push.repositories.AbstractPushRepository
AbstractPushRepository.StatisticsImpl
-
Nested classes/interfaces inherited from interface tigase.push.api.IPushRepository
IPushRepository.ElseHandler, IPushRepository.Statistics
-
-
Field Summary
Fields Modifier and Type Field Description protected tigase.db.DataRepository
repo
-
Constructor Summary
Constructors Constructor Description JDBCPushRepository()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.stream.Stream<IPushSettings>
getNodeSettings(java.lang.String provider, java.lang.String deviceId)
IPushSettings
getNodeSettings(tigase.xmpp.jid.BareJID serviceJid, java.lang.String node)
java.util.Map<java.lang.String,IPushRepository.Statistics>
getStatistics()
protected void
initRepo(tigase.db.DataRepository repo)
protected IPushSettings.IDevice
readDevice(java.sql.ResultSet rs, int i)
IPushSettings
registerDevice(tigase.xmpp.jid.BareJID serviceJid, tigase.xmpp.jid.BareJID userJid, java.lang.String provider, java.lang.String deviceId, java.lang.String deviceSecondId)
void
setDataSource(tigase.db.DataRepository dataSource)
IPushSettings
unregisterDevice(tigase.xmpp.jid.BareJID serviceJid, tigase.xmpp.jid.BareJID userJid, java.lang.String provider, java.lang.String deviceId)
IPushSettings
unregisterDeviceOld(tigase.xmpp.jid.BareJID serviceJid, tigase.xmpp.jid.BareJID userJid, java.lang.String provider, java.lang.String deviceId)
-
Methods inherited from class tigase.push.repositories.AbstractPushRepository
calculateNode, calculateNode, getNodeSettings, toHex
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface tigase.push.api.IPushRepository
getNodeSettings
-
-
-
-
Method Detail
-
registerDevice
public IPushSettings registerDevice(tigase.xmpp.jid.BareJID serviceJid, tigase.xmpp.jid.BareJID userJid, java.lang.String provider, java.lang.String deviceId, java.lang.String deviceSecondId) throws tigase.component.exceptions.RepositoryException
- Specified by:
registerDevice
in interfaceIPushRepository<tigase.db.DataRepository>
- Throws:
tigase.component.exceptions.RepositoryException
-
unregisterDevice
public IPushSettings unregisterDevice(tigase.xmpp.jid.BareJID serviceJid, tigase.xmpp.jid.BareJID userJid, java.lang.String provider, java.lang.String deviceId) throws tigase.component.exceptions.RepositoryException, tigase.component.exceptions.ComponentException
- Specified by:
unregisterDevice
in interfaceIPushRepository<tigase.db.DataRepository>
- Throws:
tigase.component.exceptions.RepositoryException
tigase.component.exceptions.ComponentException
-
unregisterDeviceOld
public IPushSettings unregisterDeviceOld(tigase.xmpp.jid.BareJID serviceJid, tigase.xmpp.jid.BareJID userJid, java.lang.String provider, java.lang.String deviceId) throws tigase.component.exceptions.RepositoryException, tigase.component.exceptions.ComponentException
- Throws:
tigase.component.exceptions.RepositoryException
tigase.component.exceptions.ComponentException
-
getNodeSettings
public IPushSettings getNodeSettings(tigase.xmpp.jid.BareJID serviceJid, java.lang.String node) throws tigase.component.exceptions.RepositoryException
- Specified by:
getNodeSettings
in interfaceIPushRepository<tigase.db.DataRepository>
- Throws:
tigase.component.exceptions.RepositoryException
-
getNodeSettings
public java.util.stream.Stream<IPushSettings> getNodeSettings(java.lang.String provider, java.lang.String deviceId) throws tigase.component.exceptions.RepositoryException
- Specified by:
getNodeSettings
in interfaceIPushRepository<tigase.db.DataRepository>
- Throws:
tigase.component.exceptions.RepositoryException
-
getStatistics
public java.util.Map<java.lang.String,IPushRepository.Statistics> getStatistics() throws tigase.component.exceptions.RepositoryException
- Specified by:
getStatistics
in interfaceIPushRepository<tigase.db.DataRepository>
- Throws:
tigase.component.exceptions.RepositoryException
-
setDataSource
public void setDataSource(tigase.db.DataRepository dataSource)
- Specified by:
setDataSource
in interfacetigase.db.DataSourceAware<tigase.db.DataRepository>
-
readDevice
protected IPushSettings.IDevice readDevice(java.sql.ResultSet rs, int i) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
initRepo
protected void initRepo(tigase.db.DataRepository repo) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
-