Package org.cyclos.impl.sql.postgresql

Class PostgresqlQueryHandlerImpl

    • Constructor Detail

      • PostgresqlQueryHandlerImpl

        public PostgresqlQueryHandlerImpl()

    • Method Detail

      • closeAccountBalances

        public long closeAccountBalances()
        Description copied from interface: NativeQueryHandler
        Closes the account balances, returning the number of balances closed

      • copyLargeObject

        public long copyLargeObject​(long sourceOid)
                     throws IOException
        Description copied from interface: NativeQueryHandler
        Makes a copy of the large object with the specified oid and returns the oid of the copy.
        Throws:
        IOException

      • deleteLargeObject

        public void deleteLargeObject​(long oid)
        Description copied from interface: NativeQueryHandler
        Deletes the large object with the specified oid.

      • fixInconsistentAccountBalances

        public List<InconsistentBalance> fixInconsistentAccountBalances​(List<Long> accountIds)
        Description copied from interface: NativeQueryHandler
        Fixes any wrong account balances, returning the account ids that were wrong

      • from

        public com.querydsl.sql.SQLQuery<?> from​(Connection connection,
                                         com.querydsl.sql.RelationalPathBase<?>... from)

      • from

        public com.querydsl.sql.SQLQuery<?> from​(com.querydsl.sql.RelationalPathBase<?>... from)

      • getJpaQueryTemplates

        public com.querydsl.jpa.JPQLTemplates getJpaQueryTemplates()
        Description copied from interface: NativeQueryHandler
        Returns the templates used for jpa queries

      • getNextTransactionNumber

        public Long getNextTransactionNumber()
        Description copied from interface: NativeQueryHandler
        Returns the number used to generate the next transaction number

      • getObjectId

        public Long getObjectId​(long soredFileId)
        Description copied from interface: NativeQueryHandler
        Returns the oid associated to the specified stored file id. Returns null if the stored file doesn't have any associated content.

      • getSearchHandler

        public SearchHandler getSearchHandler()
        Description copied from interface: NativeQueryHandler
        Returns a handler to search on the database

      • insert

        public com.querydsl.sql.dml.SQLInsertClause insert​(Connection connection,
                                                   com.querydsl.sql.RelationalPath<?> alias)

      • insertAccountsPendingToCharge

        public long insertAccountsPendingToCharge​(AccountFeeLog log)
        Description copied from interface: NativeQueryHandler
        Inserts the references for the accounts pending to charge the given account fee log

      • insertBackgroundTaskExecution

        public void insertBackgroundTaskExecution​(String className,
                                          String context)
        Description copied from interface: NativeQueryHandler
        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

        public long insertMailings​(MailingList mailingList)
        Description copied from interface: NativeQueryHandler
        Inserts mailings for all users for a given mailing list message
        Returns:
        the quantity of users that the mailing list is sending

      • insertTransferInitialStatus

        public void insertTransferInitialStatus​(TransferType transferType,
                                        TransferStatus status)
        Description copied from interface: NativeQueryHandler
        Inserts the relation for current status and a log for each transfer of the given type

      • insertUsersForBulkAction

        public long insertUsersForBulkAction​(Long bulkActionId,
                                     UserQuery params)
        Description copied from interface: NativeQueryHandler
        Inserts a record of BulkActionUser for each returned user of the given query

      • iterateRecords

        public com.mysema.commons.lang.CloseableIterator<Record> iterateRecords​(RecordQuery params)
        Description copied from interface: NativeQueryHandler
        Iterates record entities according to the given query parameters

      • iterateUserIds

        public com.mysema.commons.lang.CloseableIterator<Long> iterateUserIds​(UserQuery params)
        Description copied from interface: NativeQueryHandler
        Iterates user ids according to the given query parameters

      • iterateUsers

        public com.mysema.commons.lang.CloseableIterator<UserWithFieldsVO> iterateUsers​(UserQuery params)
        Description copied from interface: NativeQueryHandler
        Iterates user entities according to the given query parameters

      • nextAccountIdsToClose

        public List<Long> nextAccountIdsToClose​(int maxCount,
                                        Date limit)
        Description copied from interface: NativeQueryHandler
        Returns up to the maximum count of account ids to close balance. Accounts that are returned:
        1. Accounts that have never been closed yet
        2. Accounts whose last closing was before the given limit and the current account balance's date is newer than the last closing

      • openLargeObject

        public InputStream openLargeObject​(long oid)
        Description copied from interface: NativeQueryHandler
        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

        public Pair<Set<String>,​Set<Long>> purgeRemovedBuiltinLanguages()
        Description copied from interface: NativeQueryHandler
        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

        public long rebuildClosedAccountBalances()
        Description copied from interface: NativeQueryHandler
        Rebuilds all closed account balances from the beginning

      • setObjectId

        public void setObjectId​(long storedFileId,
                        long oid)
        Description copied from interface: NativeQueryHandler
        Sets the oid to the specified stored file id.

      • supportsBlobsInReadOnlyTransactions

        public boolean supportsBlobsInReadOnlyTransactions()
        Description copied from interface: NativeQueryHandler
        Returns whether the underlying database supports accessing BLOBs from pure read-only transactions

      • tryLock

        public boolean tryLock​(LockKey key)
        Description copied from interface: NativeQueryHandler
        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.

      • update

        public com.querydsl.sql.dml.SQLUpdateClause update​(Connection connection,
                                                   com.querydsl.sql.RelationalPath<?> alias)

      • writeLargeObject

        public long writeLargeObject​(InputStream in)
                      throws IOException
        Description copied from interface: NativeQueryHandler
        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