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

Nested classes/interfaces inherited from interface tigase.db.util.RepositoryVersionAware

tigase.db.util.RepositoryVersionAware.SchemaVersion

Field Summary

Fields

Modifier and Type	Field	Description
protected tigase.db.DataRepository	repo

Constructor Summary

Constructors

Constructor	Description
JDBCPushRepository()

Method Summary

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

Methods inherited from interface tigase.db.util.RepositoryVersionAware

getVersion, updateSchema

Field Detail

repo

protected tigase.db.DataRepository repo

Constructor Detail

JDBCPushRepository

public JDBCPushRepository()

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 interface IPushRepository<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 interface IPushRepository<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 interface IPushRepository<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 interface IPushRepository<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 interface IPushRepository<tigase.db.DataRepository>

Throws:

tigase.component.exceptions.RepositoryException

setDataSource

public void setDataSource(tigase.db.DataRepository dataSource)

Specified by:

setDataSource in interface tigase.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