Package org.ikasan.connector.basefiletransfer.outbound.persistence

Class HibernateBaseFileTransferDaoImpl

java.lang.Object

org.springframework.dao.support.DaoSupport

org.springframework.orm.hibernate5.support.HibernateDaoSupport

org.ikasan.connector.basefiletransfer.outbound.persistence.HibernateBaseFileTransferDaoImpl

All Implemented Interfaces:

BaseFileTransferDao, org.springframework.beans.factory.InitializingBean

public class HibernateBaseFileTransferDaoImpl
extends org.springframework.orm.hibernate5.support.HibernateDaoSupport
implements BaseFileTransferDao

Implementation for Hibernate interactions involving File Transfer connectors

Author:

Ikasan Development Team

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	COUNT_FILE_FILTER_FROM
static java.lang.String	FILE_FILTER_CLIENT_EQUALS_PREDICATE
static java.lang.String	FILE_FILTER_CLIENT_LIKE_PREDICATE
static java.lang.String	FILE_FILTER_CRITERIA_EQUALS_PREDICATE
static java.lang.String	FILE_FILTER_CRITERIA_LIKE_PREDICATE
static java.lang.String	FILE_FILTER_FROM
static java.lang.String	FILE_FILTER_LAST_MODIFIED_EQUALS_PREDICATE
static java.lang.String	FILE_FILTER_SIZE_EQUALS_PREDICATE
static java.lang.String	FILE_FILTER_TO_SELECT_ONE_QUERY
static java.lang.String	HOUSEKEEP_FILE_FILTER_FROM

Constructor Summary

Constructors

Constructor	Description
HibernateBaseFileTransferDaoImpl()

Method Summary

Modifier and Type	Method	Description
void	delete(FileFilter fileFilter)	Deletes given FileFilter.
org.ikasan.spec.search.PagedSearchResult<FileFilter>	find(int pageNo, int pageSize, java.lang.String criteria, java.lang.String clientId)	Find a Paged List ofFileFilter by its id: clientId or and clientId
FileFilter	findById(int id)	Finds FileFilter by given id.
void	housekeep(java.lang.String clientId, int ageOfFiles, int maxRows)	Delete entries from the FileFilter table based on their age of creation and their clientId
boolean	isDuplicate(ClientListEntry entry, boolean filterOnFilename, boolean filterOnLastModifiedDate)	Method that checks if an ClientListEntry is already included in the filter table.
void	persistClientListEntry(ClientListEntry entry)	Derives an FileFilter from the provided ClientListEntry and persists it to the filtering table.
FileFilter	save(FileFilter fileFilter)	Saves given FileFilter.

Methods inherited from class org.springframework.orm.hibernate5.support.HibernateDaoSupport

checkDaoConfig, createHibernateTemplate, currentSession, getHibernateTemplate, getSessionFactory, setHibernateTemplate, setSessionFactory

Methods inherited from class org.springframework.dao.support.DaoSupport

afterPropertiesSet, initDao

Methods inherited from class java.lang.Object

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

Field Detail

FILE_FILTER_TO_SELECT_ONE_QUERY

public static final java.lang.String FILE_FILTER_TO_SELECT_ONE_QUERY

See Also:

Constant Field Values

HOUSEKEEP_FILE_FILTER_FROM

public static final java.lang.String HOUSEKEEP_FILE_FILTER_FROM

See Also:

Constant Field Values

COUNT_FILE_FILTER_FROM

public static final java.lang.String COUNT_FILE_FILTER_FROM

See Also:

Constant Field Values

FILE_FILTER_FROM

public static final java.lang.String FILE_FILTER_FROM

See Also:

Constant Field Values

FILE_FILTER_CLIENT_EQUALS_PREDICATE

public static final java.lang.String FILE_FILTER_CLIENT_EQUALS_PREDICATE

See Also:

Constant Field Values

FILE_FILTER_CRITERIA_EQUALS_PREDICATE

public static final java.lang.String FILE_FILTER_CRITERIA_EQUALS_PREDICATE

See Also:

Constant Field Values

FILE_FILTER_SIZE_EQUALS_PREDICATE

public static final java.lang.String FILE_FILTER_SIZE_EQUALS_PREDICATE

See Also:

Constant Field Values

FILE_FILTER_LAST_MODIFIED_EQUALS_PREDICATE

public static final java.lang.String FILE_FILTER_LAST_MODIFIED_EQUALS_PREDICATE

See Also:

Constant Field Values

FILE_FILTER_CLIENT_LIKE_PREDICATE

public static final java.lang.String FILE_FILTER_CLIENT_LIKE_PREDICATE

See Also:

Constant Field Values

FILE_FILTER_CRITERIA_LIKE_PREDICATE

public static final java.lang.String FILE_FILTER_CRITERIA_LIKE_PREDICATE

See Also:

Constant Field Values

Constructor Detail

HibernateBaseFileTransferDaoImpl

public HibernateBaseFileTransferDaoImpl()

Method Detail

isDuplicate

public boolean isDuplicate(ClientListEntry entry,
                           boolean filterOnFilename,
                           boolean filterOnLastModifiedDate)
                    throws org.hibernate.HibernateException

Description copied from interface: BaseFileTransferDao

Method that checks if an ClientListEntry is already included in the filter table.

Specified by:

isDuplicate in interface BaseFileTransferDao

Parameters:

entry - The ClientListEntry to filter

Returns:

true if the entry is a duplicate, false otherwise.

Throws:

org.hibernate.HibernateException

See Also:

BaseFileTransferDao.isDuplicate(ClientListEntry, boolean, boolean)

persistClientListEntry

public void persistClientListEntry(ClientListEntry entry)
                            throws org.hibernate.HibernateException

Description copied from interface: BaseFileTransferDao

Derives an FileFilter from the provided ClientListEntry and persists it to the filtering table.

Specified by:

persistClientListEntry in interface BaseFileTransferDao

Parameters:

entry - the ClientListEntry to save.

Throws:

org.hibernate.HibernateException

See Also:

BaseFileTransferDao.persistClientListEntry(org.ikasan.connector.basefiletransfer.net.ClientListEntry)

housekeep

public void housekeep(java.lang.String clientId,
                      int ageOfFiles,
                      int maxRows)
               throws org.hibernate.HibernateException

Delete entries from the FileFilter table based on their age of creation and their clientId

TODO This is _not_ a platform independent solution as we are using a Sybase specific functions (dateadd() & getdate())

Specified by:

housekeep in interface BaseFileTransferDao

Parameters:

clientId -

ageOfFiles -

maxRows -

Throws:

org.hibernate.HibernateException

findById

public FileFilter findById(int id)

Description copied from interface: BaseFileTransferDao

Finds FileFilter by given id.

Specified by:

findById in interface BaseFileTransferDao

Parameters:

id - of a FileFilter entry

Returns:

FileFilter entry for given id

delete

public void delete(FileFilter fileFilter)

Description copied from interface: BaseFileTransferDao

Deletes given FileFilter.

Specified by:

delete in interface BaseFileTransferDao

Parameters:

fileFilter - to be deleted

save

public FileFilter save(FileFilter fileFilter)

Description copied from interface: BaseFileTransferDao

Saves given FileFilter.

Specified by:

save in interface BaseFileTransferDao

Parameters:

fileFilter - to be deleted

find

public org.ikasan.spec.search.PagedSearchResult<FileFilter> find(int pageNo,
                                                                 int pageSize,
                                                                 java.lang.String criteria,
                                                                 java.lang.String clientId)

Description copied from interface: BaseFileTransferDao

Find a Paged List ofFileFilter by its id: clientId or and clientId

Specified by:

find in interface BaseFileTransferDao

Parameters:

pageNo - page number

pageSize - page Size to be returned

criteria - of FileFilters to be found

clientId - of FileFilters to be found

Returns:

The found Paged Search result of FileFilter or empty if nothing found in persistence.