net.bluemind.backend.mail.replica.persistence

Class MailboxRecordStore

java.lang.Object

net.bluemind.core.jdbc.JdbcAbstractStore

net.bluemind.core.container.persistence.AbstractItemValueStore<MailboxRecord>

net.bluemind.backend.mail.replica.persistence.MailboxRecordStore

All Implemented Interfaces:

IItemValueStore<MailboxRecord>

public class MailboxRecordStore
extends AbstractItemValueStore<MailboxRecord>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MailboxRecordStore.MailboxRecordItemV

Nested classes/interfaces inherited from class net.bluemind.core.container.persistence.AbstractItemValueStore

AbstractItemValueStore.ItemV<T>

Nested classes/interfaces inherited from class net.bluemind.core.jdbc.JdbcAbstractStore

JdbcAbstractStore.Creator<T>, JdbcAbstractStore.DataType, JdbcAbstractStore.EntityPopulator<T>, JdbcAbstractStore.SqlOperation<R>, JdbcAbstractStore.StatementValues<T>

Field Summary

Fields inherited from class net.bluemind.core.jdbc.JdbcAbstractStore

datasource

Constructor Summary

Constructors

Constructor and Description
MailboxRecordStore(javax.sql.DataSource pool)
MailboxRecordStore(javax.sql.DataSource pool, Container container)

Method Summary

Modifier and Type	Method and Description
java.util.List<ImapBinding>	bindings(java.util.List<java.lang.Long> itemIds)
Count	count(ItemFlagFilter itemFilter)
void	create(Item item, MailboxRecord value)
void	delete(Item item)
void	deleteAll()
void	deleteVirtualConversations(java.lang.Long folder)
java.util.Optional<Count>	fastpathCount(java.lang.String columnName)
MailboxRecord	get(Item item)
java.util.List<InternalConversation.InternalMessageRef>	getAllItemsByConversation(java.lang.Long conversationId, java.lang.String owner)
java.util.List<MailboxRecordItemUri>	getBodyGuidReferences(java.lang.String guid)
java.lang.Long	getByImapUid(long imapUid)
java.util.List<java.lang.Long>	getConversationIds(ItemFlagFilter filter)
java.util.List<java.lang.Long>	getConversationIds(java.util.Set<java.lang.Long> folderIds)
java.util.List<MailboxRecordStore.MailboxRecordItemV>	getExpiredItems(int days)
java.util.Set<java.lang.String>	getImapUidReferences(long uid, java.lang.String owner)
java.util.List<java.lang.Long>	getItemsByConversations(java.util.List<java.lang.String> conversationUids)
java.util.List<MailboxRecord>	getMultiple(java.util.List<Item> items)
java.util.Set<java.lang.Long>	getRecordConversationIds(java.lang.Long folder)
java.util.List<ImapBinding>	havingBodyVersionLowerThan(int version)
java.util.List<RecordID>	identifiers(long... uidArrays) Retrieve a collection of RecordID from an array of imap uids.
java.util.List<ImapBinding>	recentItems(java.util.Date d)
java.util.List<java.lang.Long>	sortedIds(SortDescriptor sorted)
void	triggerConversationUpdate(java.lang.Long folder, java.lang.Long conversation)
java.util.List<ImapBinding>	unreadItems()
void	update(Item item, MailboxRecord value)

Methods inherited from class net.bluemind.core.container.persistence.AbstractItemValueStore

join

Methods inherited from class net.bluemind.core.jdbc.JdbcAbstractStore

batchInsert, batchInsert, delete, delete, delete, doOrContinue, doOrFail, getConnection, insert, insert, insert, insert, insertAndReturn, insertWithSerial, lastInsertId, select, select, select, unique, unique, unique, unique, unique, update, update, update, update, update

Methods inherited from class java.lang.Object

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

Constructor Detail

MailboxRecordStore

public MailboxRecordStore(javax.sql.DataSource pool,
                          Container container)

MailboxRecordStore

public MailboxRecordStore(javax.sql.DataSource pool)

Method Detail

create

public void create(Item item,
                   MailboxRecord value)
            throws java.sql.SQLException

Throws:

java.sql.SQLException

update

public void update(Item item,
                   MailboxRecord value)
            throws java.sql.SQLException

Throws:

java.sql.SQLException

delete

public void delete(Item item)
            throws java.sql.SQLException

Throws:

java.sql.SQLException

get

public MailboxRecord get(Item item)
                  throws java.sql.SQLException

Throws:

java.sql.SQLException

getMultiple

public java.util.List<MailboxRecord> getMultiple(java.util.List<Item> items)
                                          throws java.sql.SQLException

Specified by:

getMultiple in interface IItemValueStore<MailboxRecord>

Overrides:

getMultiple in class AbstractItemValueStore<MailboxRecord>

Throws:

java.sql.SQLException

getExpiredItems

public java.util.List<MailboxRecordStore.MailboxRecordItemV> getExpiredItems(int days)
                                                                      throws java.sql.SQLException

Throws:

java.sql.SQLException

deleteAll

public void deleteAll()
               throws java.sql.SQLException

Throws:

java.sql.SQLException

identifiers

public java.util.List<RecordID> identifiers(long... uidArrays)
                                     throws java.sql.SQLException

Retrieve a collection of RecordID from an array of imap uids.

Parameters:

uidArrays -

Returns:

Throws:

java.sql.SQLException

bindings

public java.util.List<ImapBinding> bindings(java.util.List<java.lang.Long> itemIds)
                                     throws java.sql.SQLException

Throws:

java.sql.SQLException

sortedIds

public java.util.List<java.lang.Long> sortedIds(SortDescriptor sorted)
                                         throws java.sql.SQLException

Throws:

java.sql.SQLException

havingBodyVersionLowerThan

public java.util.List<ImapBinding> havingBodyVersionLowerThan(int version)
                                                       throws java.sql.SQLException

Returns:

the list of ImapBinding for which the corresponding MessageBody has a MessageBody.bodyVersion lower than version

Throws:

java.sql.SQLException

recentItems

public java.util.List<ImapBinding> recentItems(java.util.Date d)
                                        throws java.sql.SQLException

Throws:

java.sql.SQLException

unreadItems

public java.util.List<ImapBinding> unreadItems()
                                        throws java.sql.SQLException

Throws:

java.sql.SQLException

count

public Count count(ItemFlagFilter itemFilter)
            throws java.sql.SQLException

Throws:

java.sql.SQLException

fastpathCount

public java.util.Optional<Count> fastpathCount(java.lang.String columnName)

getBodyGuidReferences

public java.util.List<MailboxRecordItemUri> getBodyGuidReferences(java.lang.String guid)
                                                           throws java.sql.SQLException

Throws:

java.sql.SQLException

getImapUidReferences

public java.util.Set<java.lang.String> getImapUidReferences(long uid,
                                                            java.lang.String owner)
                                                     throws java.sql.SQLException

Throws:

java.sql.SQLException

getConversationIds

public java.util.List<java.lang.Long> getConversationIds(ItemFlagFilter filter)
                                                  throws java.sql.SQLException

Throws:

java.sql.SQLException

getConversationIds

public java.util.List<java.lang.Long> getConversationIds(java.util.Set<java.lang.Long> folderIds)
                                                  throws java.sql.SQLException

Throws:

java.sql.SQLException

getItemsByConversations

public java.util.List<java.lang.Long> getItemsByConversations(java.util.List<java.lang.String> conversationUids)
                                                       throws java.sql.SQLException

Throws:

java.sql.SQLException

getAllItemsByConversation

public java.util.List<InternalConversation.InternalMessageRef> getAllItemsByConversation(java.lang.Long conversationId,
                                                                                         java.lang.String owner)
                                                                                  throws java.sql.SQLException

Throws:

java.sql.SQLException

deleteVirtualConversations

public void deleteVirtualConversations(java.lang.Long folder)
                                throws java.sql.SQLException

Throws:

java.sql.SQLException

getRecordConversationIds

public java.util.Set<java.lang.Long> getRecordConversationIds(java.lang.Long folder)
                                                       throws java.sql.SQLException

Throws:

java.sql.SQLException

triggerConversationUpdate

public void triggerConversationUpdate(java.lang.Long folder,
                                      java.lang.Long conversation)
                               throws java.sql.SQLException

Throws:

java.sql.SQLException

getByImapUid

public java.lang.Long getByImapUid(long imapUid)
                            throws java.sql.SQLException

Throws:

java.sql.SQLException