public interface NativeQueryHandler
extends org.cyclos.impl.CustomBean
| Modifier and Type | Method and Description |
|---|---|
long |
copyLargeObject(long sourceOid)
Makes a copy of the large object with the specified oid and returns the oid of the copy.
|
org.cyclos.impl.locks.Lock |
createLock(org.cyclos.impl.locks.LockType type,
java.lang.Long id,
long timeoutMillis)
Creates a database lock for the given type and entity identifier, waiting the maximum time as the given timeout
in millis
|
void |
deleteLargeObject(long oid)
Deletes the large object with the specified oid.
|
java.lang.String |
dictionaryFor(BuiltinLanguage language)
Returns the name of the dictionary used for the given language
|
org.cyclos.impl.banking.NativeAccountStatus |
getAccountStatus(Account account,
java.util.Date date)
Returns the native account status at a given date
|
com.querydsl.jpa.JPQLTemplates |
getJpaQueryTemplates()
Returns the templates used for jpa queries
|
java.lang.Long |
getObjectId(long id)
Returns the oid associated to the specified stored file id.
|
long |
insertAccountsPendingToCharge(AccountFeeLog log)
Inserts the references for the accounts pending to charge the given account fee log
|
long |
insertMailings(MailingList mailingList)
Inserts mailings for all users for a given mailing list message
|
void |
insertTransferInitialStatus(TransferType transferType,
TransferStatus status)
Inserts the relation for current status and a log for each transfer of the given type
|
void |
insertUserIncomingMessages(SendMessageDTO sendMessage,
MessageOwner messageOwner,
User sendingUser,
OutgoingMessage outgoing)
Inserts incoming messages for users for a given outgoing message
|
com.mysema.commons.lang.CloseableIterator<java.lang.Long> |
iterateUserIds(UserQuery query)
Iterates user ids according to the given query parameters
|
com.mysema.commons.lang.CloseableIterator<UserWithFieldsVO> |
iterateUsers(UserQuery query)
Iterates user entities according to the given query parameters
|
java.util.List<DictionaryVO> |
listDictionaries()
Returns a list of existing full text dictionaries
|
java.util.List<java.lang.Long> |
nextAccountIdsToClose(int maxCount,
java.util.Date limit,
int paymentsThreshold)
Returns up to the maximum count of account ids to close balance, limiting to accounts which have been closed at
most at the given date, and
having at minimum the given number of payments pending closing
|
java.io.InputStream |
openLargeObject(long oid)
Opens the large object associated to the specified oid.
NOTE: After read, the input stream must be closed (the large object will be closed in turn). |
void |
reindexNetwork(java.lang.Long networkId)
Reindex all data within the given network (probably because the dictionaries definitions have changed)
|
void |
reindexTranslations()
Reindex translation files, allowing searching for keys which are not customized
|
void |
removeFromContacts(User user)
Removes all rows in the contacts relation where the given user is on either side
|
Page<BasicAdVO> |
searchAds(BasicAdQuery params)
Searches for advertisement according to the given query
|
Page<Record> |
searchRecords(RecordQuery params)
Searches for user records according to the given query parameters
|
Page<TranslationKeyVO> |
searchTranslationKeys(TranslationQuery params)
Searches for translation keys according o the given query parameters
|
Page<UserWithFieldsVO> |
searchUsers(UserQuery query)
Searches for users according to the given query parameters
|
UsersWithBalancesResult |
searchUsersWithBalance(UserWithBalanceQuery params)
Searches for users including the account balance, according to the given query parameters
|
void |
setObjectId(long storedFileId,
long oid)
Sets the oid to the specified stored file id.
|
long |
writeLargeObject(java.io.InputStream in)
Creates a new large object reading the content from the stream and returns its oid.
NOTE: The input stream parameter won't be closed it is responsibility of the client code. |
long copyLargeObject(long sourceOid)
throws java.io.IOException
java.io.IOExceptionorg.cyclos.impl.locks.Lock createLock(org.cyclos.impl.locks.LockType type,
java.lang.Long id,
long timeoutMillis)
throws LockAcquisitionException
LockAcquisitionExceptionvoid deleteLargeObject(long oid)
java.lang.String dictionaryFor(BuiltinLanguage language)
org.cyclos.impl.banking.NativeAccountStatus getAccountStatus(Account account, java.util.Date date)
com.querydsl.jpa.JPQLTemplates getJpaQueryTemplates()
java.lang.Long getObjectId(long id)
long insertAccountsPendingToCharge(AccountFeeLog log)
long insertMailings(MailingList mailingList)
void insertTransferInitialStatus(TransferType transferType, TransferStatus status)
void insertUserIncomingMessages(SendMessageDTO sendMessage, MessageOwner messageOwner, User sendingUser, OutgoingMessage outgoing)
com.mysema.commons.lang.CloseableIterator<java.lang.Long> iterateUserIds(UserQuery query)
com.mysema.commons.lang.CloseableIterator<UserWithFieldsVO> iterateUsers(UserQuery query)
java.util.List<DictionaryVO> listDictionaries()
java.util.List<java.lang.Long> nextAccountIdsToClose(int maxCount,
java.util.Date limit,
int paymentsThreshold)
java.io.InputStream openLargeObject(long oid)
void reindexNetwork(java.lang.Long networkId)
void reindexTranslations()
void removeFromContacts(User user)
Page<BasicAdVO> searchAds(BasicAdQuery params)
Page<Record> searchRecords(RecordQuery params)
Page<TranslationKeyVO> searchTranslationKeys(TranslationQuery params)
Page<UserWithFieldsVO> searchUsers(UserQuery query)
UsersWithBalancesResult searchUsersWithBalance(UserWithBalanceQuery params)
void setObjectId(long storedFileId,
long oid)
long writeLargeObject(java.io.InputStream in)
throws java.io.IOException
java.io.IOException