All Superinterfaces:

CustomBean

All Known Implementing Classes:

BaseNativeQueryHandlerImpl, PostgresqlQueryHandlerImpl
```
public interface NativeQueryHandler
extends CustomBean
```
Single place which contains the native queries

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`long`	`closeAccountBalances()`	Closes the account balances, returning the number of balances closed
`long`	`copyLargeObject(long sourceOid)`	Makes a copy of the large object with the specified oid and returns the oid of the copy.
`void`	`deleteLargeObject(long oid)`	Deletes the large object with the specified oid.
`List<InconsistentBalance>`	`fixInconsistentAccountBalances(List<Long> previousIds)`	Fixes any wrong account balances, returning the account ids that were wrong
`NativeAccountStatus`	`getAccountStatus(Account account, Date date)`	Returns the native account status at a given date
`com.querydsl.jpa.JPQLTemplates`	`getJpaQueryTemplates()`	Returns the templates used for jpa queries
`Long`	`getNextTransactionNumber()`	Returns the number used to generate the next transaction number
`Long`	`getObjectId(long id)`	Returns the oid associated to the specified stored file id.
`SearchHandler`	`getSearchHandler()`	Returns a handler to search on the database
`long`	`insertAccountsPendingToCharge(AccountFeeLog log)`	Inserts the references for the accounts pending to charge the given account fee log
`long`	`insertArchiveAccountFees()`	Inserts the `BackgroundTaskExecution`s for each account fee log older than `CyclosProperties.getArchiveAccountFeesDays()`
`void`	`insertBackgroundTaskExecution(String className, String context)`	Tries to insert a new execution of the task with the given context, in case of conflicts (the same execution already exists) then do nothing.
`long`	`insertMailings(MailingList mailingList)`	Inserts mailings for all users for a given mailing list message
`void`	`insertReindexBackgroundTasks(Class<? extends SimpleEntity> entityClass, String indexName, int batchSize)`	Inserts n executions of `IndexEntitiesBackgroundTask` for a given entity
`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(Long bulkActionId, UserQuery query)`	Inserts a record of `BulkActionUser` for each returned user of the given query
`com.mysema.commons.lang.CloseableIterator<Record>`	`iterateRecords(RecordQuery params)`	Iterates record entities according to the given query parameters
`com.mysema.commons.lang.CloseableIterator<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
`List<Long>`	`nextAccountIdsToClose(int maxCount, Date limit)`	Returns up to the maximum count of account ids to close balance.
`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<Set<String>,Set<Long>>`	`purgeRemovedBuiltinLanguages()`	Removes all languages that were pointing to `BuiltinLanguage`s that no longer exist, returning both the language templates that no longer exist and the ids of languages that were removed
`long`	`rebuildClosedAccountBalances()`	Rebuilds all closed account balances from the beginning
`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
`boolean`	`tryLock(LockKey key)`	Attempt to acquire an exclusive lock with a given key.
`boolean`	`tryLock(JdbcTemplate jdbc, LockKey key)`	Attempt to acquire an exclusive lock with a given key using the given `JdbcTemplate`.
`List<AccountStatusUpdateResult>`	`updateAccountStatuses(Collection<AccountStatusUpdateParams> updates)`	Updates a set of account statuses.
`long`	`writeLargeObject(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.

- Method Detail
  - closeAccountBalances
```
long closeAccountBalances()
```
    Closes the account balances, returning the number of balances closed
  - copyLargeObject
```
long copyLargeObject(long sourceOid)
              throws IOException
```
    Makes a copy of the large object with the specified oid and returns the oid of the copy.
    
    Throws:
    
    IOException
  - deleteLargeObject
```
void deleteLargeObject(long oid)
```
    Deletes the large object with the specified oid.
  - fixInconsistentAccountBalances
```
List<InconsistentBalance> fixInconsistentAccountBalances(List<Long> previousIds)
```
    Fixes any wrong account balances, returning the account ids that were wrong
  - getAccountStatus
```
NativeAccountStatus getAccountStatus(Account account,
                                     Date date)
```
    Returns the native account status at a given date
  - getJpaQueryTemplates
```
com.querydsl.jpa.JPQLTemplates getJpaQueryTemplates()
```
    Returns the templates used for jpa queries
  - getNextTransactionNumber
```
Long getNextTransactionNumber()
```
    Returns the number used to generate the next transaction number
  - getObjectId
```
Long getObjectId(long id)
```
    Returns the oid associated to the specified stored file id. Returns null if the stored file doesn't have any associated content.
  - getSearchHandler
```
SearchHandler getSearchHandler()
```
    Returns a handler to search on the database
  - insertAccountsPendingToCharge
```
long insertAccountsPendingToCharge(AccountFeeLog log)
```
    Inserts the references for the accounts pending to charge the given account fee log
  - insertArchiveAccountFees
```
long insertArchiveAccountFees()
```
    Inserts the BackgroundTaskExecutions for each account fee log older than CyclosProperties.getArchiveAccountFeesDays()
  - insertBackgroundTaskExecution
```
void insertBackgroundTaskExecution(String className,
                                   String context)
```
    Tries to insert a new execution of the task with the given context, in case of conflicts (the same execution already exists) then do nothing.
  - insertMailings
```
long insertMailings(MailingList mailingList)
```
    Inserts mailings for all users for a given mailing list message
    
    Returns:
    
    the quantity of users that the mailing list is sending
  - insertReindexBackgroundTasks
```
void insertReindexBackgroundTasks(Class<? extends SimpleEntity> entityClass,
                                  String indexName,
                                  int batchSize)
```
    Inserts n executions of IndexEntitiesBackgroundTask for a given entity
  - insertTransferInitialStatus
```
void insertTransferInitialStatus(TransferType transferType,
                                 TransferStatus status)
```
    Inserts the relation for current status and a log for each transfer of the given type
  - insertUserIncomingMessages
```
void insertUserIncomingMessages(SendMessageDTO sendMessage,
                                MessageOwner messageOwner,
                                User sendingUser,
                                OutgoingMessage outgoing)
```
    Inserts incoming messages for users for a given outgoing message
  - insertUsersForBulkAction
```
long insertUsersForBulkAction(Long bulkActionId,
                              UserQuery query)
```
    Inserts a record of BulkActionUser for each returned user of the given query
  - iterateRecords
```
com.mysema.commons.lang.CloseableIterator<Record> iterateRecords(RecordQuery params)
```
    Iterates record entities according to the given query parameters
  - iterateUserIds
```
com.mysema.commons.lang.CloseableIterator<Long> iterateUserIds(UserQuery query)
```
    Iterates user ids according to the given query parameters
  - iterateUsers
```
com.mysema.commons.lang.CloseableIterator<UserWithFieldsVO> iterateUsers(UserQuery query)
```
    Iterates user entities according to the given query parameters
  - nextAccountIdsToClose
```
List<Long> nextAccountIdsToClose(int maxCount,
                                 Date limit)
```
    Returns up to the maximum count of account ids to close balance. Accounts that are returned:
    
    Accounts that have never been closed yet
    
    Accounts whose last closing was before the given limit and the current account balance's date is newer than the last closing
  - openLargeObject
```
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).
  - purgeRemovedBuiltinLanguages
```
Pair<Set<String>,Set<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
  - rebuildClosedAccountBalances
```
long rebuildClosedAccountBalances()
```
    Rebuilds all closed account balances from the beginning
  - setObjectId
```
void setObjectId(long storedFileId,
                 long oid)
```
    Sets the oid to the specified stored file id.
  - supportsBlobsInReadOnlyTransactions
```
boolean supportsBlobsInReadOnlyTransactions()
```
    Returns whether the underlying database supports accessing BLOBs from pure read-only transactions
  - tryLock
```
boolean tryLock(JdbcTemplate jdbc,
                LockKey key)
```
    Attempt to acquire an exclusive lock with a given key using the given JdbcTemplate.
  - tryLock
```
boolean tryLock(LockKey key)
```
    Attempt to acquire an exclusive lock with a given key. The lock will be bound to the current transaction, and will be automatically unlocked when the transaction ends.
  - updateAccountStatuses
```
List<AccountStatusUpdateResult> updateAccountStatuses(Collection<AccountStatusUpdateParams> updates)
```
    Updates a set of account statuses. Must be called only after acquiring the lock on the affected accounts.
  - writeLargeObject
```
long writeLargeObject(InputStream in)
               throws IOException
```
    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.
    
    Throws:
    
    IOException

Interface NativeQueryHandler

Method Summary

Method Detail

closeAccountBalances

copyLargeObject

deleteLargeObject

fixInconsistentAccountBalances

getAccountStatus

getJpaQueryTemplates

getNextTransactionNumber

getObjectId

getSearchHandler

insertAccountsPendingToCharge

insertArchiveAccountFees

insertBackgroundTaskExecution

insertMailings

insertReindexBackgroundTasks

insertTransferInitialStatus

insertUserIncomingMessages

insertUsersForBulkAction

iterateRecords

iterateUserIds

iterateUsers

nextAccountIdsToClose

openLargeObject

purgeRemovedBuiltinLanguages

rebuildClosedAccountBalances

setObjectId

supportsBlobsInReadOnlyTransactions

tryLock

tryLock

updateAccountStatuses

writeLargeObject