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.
|
UsersWithBalancesOverview |
getUsersWithBalancesOverview(UserWithBalanceQuery params)
Returns the overview summaries of users with balances search according to the given parameters
|
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
|
long |
insertUsersForBulkAction(java.lang.Long bulkActionId,
UserQuery query)
Inserts a record of
BulkActionUser for each returned user of the given query |
boolean |
isFullTextQuerySupported()
Returns whether full-text queries are supported
|
boolean |
isPhraseSearchSupported()
Returns whether phrase searches are supported within full-text queries
|
com.mysema.commons.lang.CloseableIterator<Record> |
iterateRecords(RecordQuery params)
Iterates record entities according to the given query parameters
|
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). |
Pair<java.util.Set<java.lang.String>,java.util.Set<java.lang.Long>> |
purgeRemovedBuiltinLanguages()
Removes all languages that were pointing to
BuiltinLanguages that no longer exist, returning both the
language templates that no longer exist and the ids of languages that were removed |
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
|
Page<UserWithBalanceVO> |
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.
|
boolean |
supportsBlobsInReadOnlyTransactions()
Returns whether the underlying database supports accessing BLOBs from pure read-only transactions
|
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)
UsersWithBalancesOverview getUsersWithBalancesOverview(UserWithBalanceQuery params)
long insertAccountsPendingToCharge(AccountFeeLog log)
long insertMailings(MailingList mailingList)
void insertTransferInitialStatus(TransferType transferType, TransferStatus status)
void insertUserIncomingMessages(SendMessageDTO sendMessage, MessageOwner messageOwner, User sendingUser, OutgoingMessage outgoing)
long insertUsersForBulkAction(java.lang.Long bulkActionId,
UserQuery query)
BulkActionUser for each returned user of the given queryboolean isFullTextQuerySupported()
boolean isPhraseSearchSupported()
com.mysema.commons.lang.CloseableIterator<Record> iterateRecords(RecordQuery params)
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)
Pair<java.util.Set<java.lang.String>,java.util.Set<java.lang.Long>> purgeRemovedBuiltinLanguages()
BuiltinLanguages that no longer exist, returning both the
language templates that no longer exist and the ids of languages that were removedvoid 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)
Page<UserWithBalanceVO> searchUsersWithBalance(UserWithBalanceQuery params)
void setObjectId(long storedFileId,
long oid)
boolean supportsBlobsInReadOnlyTransactions()
long writeLargeObject(java.io.InputStream in)
throws java.io.IOException
java.io.IOException