Package tigase.archive.db

Class JDBCMessageArchiveRepository<Q extends QueryCriteria>

java.lang.Object

tigase.archive.db.AbstractMessageArchiveRepository<Q,tigase.db.DataRepository>

tigase.archive.db.JDBCMessageArchiveRepository<Q>

All Implemented Interfaces:

MessageArchiveRepository<Q,tigase.db.DataRepository>, tigase.db.DataSourceAware<tigase.db.DataRepository>, tigase.db.util.RepositoryVersionAware, tigase.xmpp.mam.MAMRepository<Q,tigase.xmpp.mam.MAMRepository.Item>

public class JDBCMessageArchiveRepository<Q extends QueryCriteria>
extends AbstractMessageArchiveRepository<Q,tigase.db.DataRepository>
implements tigase.db.util.RepositoryVersionAware

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JDBCMessageArchiveRepository.Item<Q extends QueryCriteria>

Nested classes/interfaces inherited from interface tigase.xmpp.mam.MAMRepository

tigase.xmpp.mam.MAMRepository.ItemHandler<Q extends tigase.xmpp.mam.Query,I extends tigase.xmpp.mam.MAMRepository.Item>

Nested classes/interfaces inherited from interface tigase.archive.db.MessageArchiveRepository

MessageArchiveRepository.CollectionHandler<Q extends tigase.xmpp.mam.Query>, MessageArchiveRepository.Direction

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

tigase.db.util.RepositoryVersionAware.SchemaVersion

Field Summary

Fields

Modifier and Type	Field	Description
protected String	ADD_MESSAGE_QUERY
protected String	ADD_TAG_TO_MESSAGE_QUERY
protected tigase.db.DataRepository	data_repo
protected String	DELETE_EXPIRED_MESSAGES_QUERY
protected String	GET_COLLECTIONS_COUNT_QUERY
protected String	GET_COLLECTIONS_QUERY
protected String	GET_MESSAGE_POSITION_QUERY
protected String	GET_MESSAGES_COUNT_QUERY
protected String	GET_MESSAGES_QUERY
protected String	GET_TAGS_FOR_USER_COUNT_QUERY
protected String	GET_TAGS_FOR_USER_QUERY
protected String	REMOVE_MESSAGES_QUERY

Fields inherited from class tigase.archive.db.AbstractMessageArchiveRepository

MSG_BODY_PATH, MSG_SUBJECT_PATH

Constructor Summary

Constructors

Constructor	Description
JDBCMessageArchiveRepository()

Method Summary

Modifier and Type	Method	Description
protected int	addMessageAdditionalInfo(PreparedStatement stmt, int i, Map<String,Object> additionalData)
void	archiveMessage(tigase.xmpp.jid.BareJID owner, tigase.xmpp.jid.JID buddy, MessageArchiveRepository.Direction direction, Date timestamp, tigase.xml.Element msg, Set<String> tags)
protected Long	archiveMessage(tigase.xmpp.jid.BareJID owner, tigase.xmpp.jid.JID buddy, MessageArchiveRepository.Direction direction, Date timestamp, tigase.xml.Element msg, Set<String> tags, Map<String,Object> additionalData)
protected Timestamp	convertToTimestamp(Date date)
void	deleteExpiredMessages(tigase.xmpp.jid.BareJID owner, LocalDateTime before)
List<String>	getTags(tigase.xmpp.jid.BareJID owner, String startsWith, Q crit)
protected void	initPreparedStatements(tigase.db.DataRepository data_repo)
protected JDBCMessageArchiveRepository.Item	newItemInstance()
Q	newQuery()
void	queryCollections(Q crit, MessageArchiveRepository.CollectionHandler<Q> collectionHandler)
void	queryItems(Q crit, tigase.xmpp.mam.MAMRepository.ItemHandler<Q,tigase.xmpp.mam.MAMRepository.Item> itemHandler)
void	removeItems(tigase.xmpp.jid.BareJID owner, String withJid, Date start, Date end)
protected int	setCountQueryParams(PreparedStatement stmt, String ownerJid, Q crit, Boolean groupByType)
void	setDataSource(tigase.db.DataRepository data_repo)
void	setItemsQueryParams(PreparedStatement stmt, String ownerJid, Q crit, Boolean groupByType)
protected int	setQueryParams(PreparedStatement stmt, Q crit, Boolean groupByType, int i)

Methods inherited from class tigase.archive.db.AbstractMessageArchiveRepository

calculateOffsetAndPosition, generateHashOfMessage

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface tigase.archive.db.MessageArchiveRepository

destroy

Methods inherited from interface tigase.db.util.RepositoryVersionAware

getVersion, updateSchema

Field Detail

ADD_MESSAGE_QUERY

@ConfigField(desc="Query to add message to store",
             alias="add-message-query")
protected String ADD_MESSAGE_QUERY

ADD_TAG_TO_MESSAGE_QUERY

@ConfigField(desc="Query to add tag to message in store",
             alias="add-tag-to-message-query")
protected String ADD_TAG_TO_MESSAGE_QUERY

DELETE_EXPIRED_MESSAGES_QUERY

@ConfigField(desc="Query to delete expired messages",
             alias="delete-expired-messages-query")
protected String DELETE_EXPIRED_MESSAGES_QUERY

GET_COLLECTIONS_COUNT_QUERY

@ConfigField(desc="Query to retrieve number of collections",
             alias="get-collections-count-query")
protected String GET_COLLECTIONS_COUNT_QUERY

GET_COLLECTIONS_QUERY

@ConfigField(desc="Query to retrieve list of collections",
             alias="get-collections-query")
protected String GET_COLLECTIONS_QUERY

GET_MESSAGES_COUNT_QUERY

@ConfigField(desc="Query to retrieve number of messages",
             alias="get-messages-count-query")
protected String GET_MESSAGES_COUNT_QUERY

GET_MESSAGES_QUERY

@ConfigField(desc="Query to retrieve list of messages",
             alias="get-messages-query")
protected String GET_MESSAGES_QUERY

GET_MESSAGE_POSITION_QUERY

@ConfigField(desc="Query to retrieve message possition",
             alias="get-message-position-query")
protected String GET_MESSAGE_POSITION_QUERY

GET_TAGS_FOR_USER_COUNT_QUERY

@ConfigField(desc="Query to retrieve number of tags used by user",
             alias="get-tags-for-user-count-query")
protected String GET_TAGS_FOR_USER_COUNT_QUERY

GET_TAGS_FOR_USER_QUERY

@ConfigField(desc="Query to retrieve tags used by user",
             alias="get-tags-for-user-query")
protected String GET_TAGS_FOR_USER_QUERY

REMOVE_MESSAGES_QUERY

@ConfigField(desc="Query to remove messages",
             alias="remove-messages-query")
protected String REMOVE_MESSAGES_QUERY

data_repo

protected tigase.db.DataRepository data_repo

Constructor Detail

JDBCMessageArchiveRepository

public JDBCMessageArchiveRepository()

Method Detail

setDataSource

public void setDataSource(tigase.db.DataRepository data_repo)

Specified by:

setDataSource in interface tigase.db.DataSourceAware<Q extends QueryCriteria>

archiveMessage

public void archiveMessage(tigase.xmpp.jid.BareJID owner,
                           tigase.xmpp.jid.JID buddy,
                           MessageArchiveRepository.Direction direction,
                           Date timestamp,
                           tigase.xml.Element msg,
                           Set<String> tags)

Specified by:

archiveMessage in interface MessageArchiveRepository<Q extends QueryCriteria,tigase.db.DataRepository>

deleteExpiredMessages

public void deleteExpiredMessages(tigase.xmpp.jid.BareJID owner,
                                  LocalDateTime before)
                           throws tigase.db.TigaseDBException

Specified by:

deleteExpiredMessages in interface MessageArchiveRepository<Q extends QueryCriteria,tigase.db.DataRepository>

Throws:

tigase.db.TigaseDBException

queryCollections

public void queryCollections(Q crit,
                             MessageArchiveRepository.CollectionHandler<Q> collectionHandler)
                      throws tigase.db.TigaseDBException

Specified by:

queryCollections in interface MessageArchiveRepository<Q extends QueryCriteria,tigase.db.DataRepository>

Throws:

tigase.db.TigaseDBException

queryItems

public void queryItems(Q crit,
                       tigase.xmpp.mam.MAMRepository.ItemHandler<Q,tigase.xmpp.mam.MAMRepository.Item> itemHandler)
                throws tigase.db.TigaseDBException,
                       tigase.component.exceptions.ComponentException

Specified by:

queryItems in interface tigase.xmpp.mam.MAMRepository<Q extends QueryCriteria,tigase.xmpp.mam.MAMRepository.Item>

Throws:

tigase.db.TigaseDBException

tigase.component.exceptions.ComponentException

removeItems

public void removeItems(tigase.xmpp.jid.BareJID owner,
                        String withJid,
                        Date start,
                        Date end)
                 throws tigase.db.TigaseDBException

Specified by:

removeItems in interface MessageArchiveRepository<Q extends QueryCriteria,tigase.db.DataRepository>

Throws:

tigase.db.TigaseDBException

getTags

public List<String> getTags(tigase.xmpp.jid.BareJID owner,
                            String startsWith,
                            Q crit)
                     throws tigase.db.TigaseDBException

Specified by:

getTags in interface MessageArchiveRepository<Q extends QueryCriteria,tigase.db.DataRepository>

Throws:

tigase.db.TigaseDBException

setItemsQueryParams

public void setItemsQueryParams(PreparedStatement stmt,
                                String ownerJid,
                                Q crit,
                                Boolean groupByType)
                         throws SQLException

Throws:

SQLException

newQuery

public Q newQuery()

Specified by:

newQuery in interface tigase.xmpp.mam.MAMRepository<Q extends QueryCriteria,tigase.xmpp.mam.MAMRepository.Item>

initPreparedStatements

protected void initPreparedStatements(tigase.db.DataRepository data_repo)
                               throws SQLException

Throws:

SQLException

archiveMessage

protected Long archiveMessage(tigase.xmpp.jid.BareJID owner,
                              tigase.xmpp.jid.JID buddy,
                              MessageArchiveRepository.Direction direction,
                              Date timestamp,
                              tigase.xml.Element msg,
                              Set<String> tags,
                              Map<String,Object> additionalData)

addMessageAdditionalInfo

protected int addMessageAdditionalInfo(PreparedStatement stmt,
                                       int i,
                                       Map<String,Object> additionalData)
                                throws SQLException

Throws:

SQLException

convertToTimestamp

protected Timestamp convertToTimestamp(Date date)

setCountQueryParams

protected int setCountQueryParams(PreparedStatement stmt,
                                  String ownerJid,
                                  Q crit,
                                  Boolean groupByType)
                           throws SQLException

Throws:

SQLException

setQueryParams

protected int setQueryParams(PreparedStatement stmt,
                             Q crit,
                             Boolean groupByType,
                             int i)
                      throws SQLException

Throws:

SQLException

newItemInstance

protected JDBCMessageArchiveRepository.Item newItemInstance()