org.finra.herd.dao.impl

Class BusinessObjectDataDaoImpl

java.lang.Object

org.finra.herd.dao.impl.BaseJpaDaoImpl

org.finra.herd.dao.impl.AbstractHerdDao

org.finra.herd.dao.impl.BusinessObjectDataDaoImpl

All Implemented Interfaces:

BaseJpaDao, BusinessObjectDataDao

@Repository
public class BusinessObjectDataDaoImpl
extends AbstractHerdDao
implements BusinessObjectDataDao

Nested Class Summary

Nested classes/interfaces inherited from class org.finra.herd.dao.impl.AbstractHerdDao

AbstractHerdDao.AggregateFunction

Field Summary

Fields inherited from class org.finra.herd.dao.impl.AbstractHerdDao

BUSINESS_OBJECT_DATA_PARTITIONS, BUSINESS_OBJECT_DATA_SUBPARTITIONS, configurationHelper, DEFAULT_SINGLE_DAY_DATE_MASK, MAX_PARTITION_FILTERS_PER_REQUEST

Fields inherited from class org.finra.herd.dao.impl.BaseJpaDaoImpl

entityManager

Constructor Summary

Constructors

Constructor and Description
BusinessObjectDataDaoImpl()

Method Summary

Modifier and Type	Method and Description
BusinessObjectDataEntity	getBusinessObjectDataByAltKey(BusinessObjectDataKey businessObjectDataKey) Retrieves business object data by it's key.
BusinessObjectDataEntity	getBusinessObjectDataByAltKeyAndStatus(BusinessObjectDataKey businessObjectDataKey, String businessObjectDataStatus) Retrieves business object data by it's key.
Long	getBusinessObjectDataCount(BusinessObjectFormatKey businessObjectFormatKey) Returns a number of business object data instances registered with this business object format.
List<BusinessObjectDataEntity>	getBusinessObjectDataEntities(BusinessObjectDataKey businessObjectDataKey) Retrieves business object data versions that match the specified business object data key with potentially missing business object format and/or data version values.
List<BusinessObjectDataEntity>	getBusinessObjectDataEntities(BusinessObjectFormatKey businessObjectFormatKey, List<List<String>> partitionFilters, Integer businessObjectDataVersion, String businessObjectDataStatus, String storageName) Retrieves a list of business object data entities per specified parameters.
List<BusinessObjectDataEntity>	getBusinessObjectDataEntitiesByPartitionValue(String partitionValue) Retrieves a list of business object data by their partition value.
Map<BusinessObjectDataEntity,StoragePolicyEntity>	getBusinessObjectDataEntitiesMatchingStoragePolicies(StoragePolicyPriorityLevel storagePolicyPriorityLevel, List<String> supportedBusinessObjectDataStatuses, int startPosition, int maxResult) Retrieves a map of business object data entities to their corresponding storage policy entities, where the business object data status is supported by the storage policy feature and the business object data alternate key values match storage policy's filter and transition (not taking into account storage policy rules).
List<BusinessObjectDataEntity>	getBusinessObjectDataFromStorageOlderThan(String storageName, int thresholdMinutes, List<String> businessObjectDataStatusesToIgnore) Selects business object data having storage files associated with the specified storage and with status not listed as ignored.
String	getBusinessObjectDataMaxPartitionValue(int partitionColumnPosition, BusinessObjectFormatKey businessObjectFormatKey, Integer businessObjectDataVersion, String businessObjectDataStatus, List<String> storageNames, String storagePlatformType, String excludedStoragePlatformType, String upperBoundPartitionValue, String lowerBoundPartitionValue) Retrieves a maximum available partition value per specified parameters.
Integer	getBusinessObjectDataMaxVersion(BusinessObjectDataKey businessObjectDataKey) Gets a maximum available version of the specified business object data.
String	getBusinessObjectDataMinPartitionValue(int partitionColumnPosition, BusinessObjectFormatKey businessObjectFormatKey, Integer businessObjectDataVersion, String businessObjectDataStatus, List<String> storageNames, String storagePlatformType, String excludedStoragePlatformType) Retrieves a minimum available partition value per specified parameters.
List<BusinessObjectData>	searchBusinessObjectData(List<BusinessObjectDataSearchFilter> filters) Retrieves a list of business object data by list of filters

Methods inherited from class org.finra.herd.dao.impl.AbstractHerdDao

getMaximumBusinessObjectDataVersionSubQuery, getQueryRestriction, getQueryRestriction, getQueryRestrictionOnBusinessObjectDataVersionAndStatus, getQueryRestrictionOnPartitionValues, getQueryRestrictionOnPartitionValues, getQueryRestrictionOnPartitionValues, getQueryRestrictionOnPartitionValues, getQueryRestrictionOnStorage, save

Methods inherited from class org.finra.herd.dao.impl.BaseJpaDaoImpl

delete, detach, executeSingleResultQuery, findAll, findById, findByNamedProperties, findUniqueByNamedProperties, getCurrentTimestamp, getEntityManager, getPredicateForInClause, query, queryByNamedParams, saveAndRefresh

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.finra.herd.dao.BaseJpaDao

delete, detach, findAll, findById, findByNamedProperties, findUniqueByNamedProperties, getCurrentTimestamp, getEntityManager, query, queryByNamedParams, save, saveAndRefresh

Constructor Detail

BusinessObjectDataDaoImpl

public BusinessObjectDataDaoImpl()

Method Detail

getBusinessObjectDataByAltKey

public BusinessObjectDataEntity getBusinessObjectDataByAltKey(BusinessObjectDataKey businessObjectDataKey)

Description copied from interface: BusinessObjectDataDao

Retrieves business object data by it's key. If a format version isn't specified, the latest available format version (for this partition value) will be used. If a business object data version isn't specified, the latest data version is returned regardless of the business object data status.

Specified by:

getBusinessObjectDataByAltKey in interface BusinessObjectDataDao

Parameters:

businessObjectDataKey - the business object data key

Returns:

the business object data

getBusinessObjectDataByAltKeyAndStatus

public BusinessObjectDataEntity getBusinessObjectDataByAltKeyAndStatus(BusinessObjectDataKey businessObjectDataKey,
                                                                       String businessObjectDataStatus)

Description copied from interface: BusinessObjectDataDao

Retrieves business object data by it's key. If a format version isn't specified, the latest available format version (for this partition value) will be used. If a business object data version isn't specified, the latest data version based on the specified business object data status is returned. When both business object data version and business object data status both are not specified, the latest data version for each set of partition values will be used regardless of the status.

Specified by:

getBusinessObjectDataByAltKeyAndStatus in interface BusinessObjectDataDao

Parameters:

businessObjectDataKey - the business object data key

businessObjectDataStatus - the business object data status. This parameter is ignored when the business object data version is specified.

Returns:

the business object data

getBusinessObjectDataMaxVersion

public Integer getBusinessObjectDataMaxVersion(BusinessObjectDataKey businessObjectDataKey)

Description copied from interface: BusinessObjectDataDao

Gets a maximum available version of the specified business object data.

Specified by:

getBusinessObjectDataMaxVersion in interface BusinessObjectDataDao

Parameters:

businessObjectDataKey - the business object data key

Returns:

the maximum available version of the specified business object data

getBusinessObjectDataMaxPartitionValue

public String getBusinessObjectDataMaxPartitionValue(int partitionColumnPosition,
                                                     BusinessObjectFormatKey businessObjectFormatKey,
                                                     Integer businessObjectDataVersion,
                                                     String businessObjectDataStatus,
                                                     List<String> storageNames,
                                                     String storagePlatformType,
                                                     String excludedStoragePlatformType,
                                                     String upperBoundPartitionValue,
                                                     String lowerBoundPartitionValue)

Description copied from interface: BusinessObjectDataDao

Retrieves a maximum available partition value per specified parameters.

Specified by:

getBusinessObjectDataMaxPartitionValue in interface BusinessObjectDataDao

Parameters:

partitionColumnPosition - the partition column position (1-based numbering)

businessObjectFormatKey - the business object format key (case-insensitive). If a business object format version isn't specified, the latest available format version for each partition value will be used.

businessObjectDataVersion - the business object data version. If a business object data version isn't specified, the latest data version based on the specified business object data status will be used for each partition value.

businessObjectDataStatus - the business object data status. This parameter is ignored when the business object data version is specified.

storageNames - the optional list of storage names (case-insensitive)

storagePlatformType - the optional storage platform type, e.g. S3 for Hive DDL. It is ignored when the list of storages is not empty

excludedStoragePlatformType - the optional storage platform type to be excluded from search. It is ignored when the list of storages is not empty or the storage platform type is specified

upperBoundPartitionValue - the optional inclusive upper bound for the maximum available partition value

lowerBoundPartitionValue - the optional inclusive lower bound for the maximum available partition value

Returns:

the maximum available partition value

getBusinessObjectDataMinPartitionValue

public String getBusinessObjectDataMinPartitionValue(int partitionColumnPosition,
                                                     BusinessObjectFormatKey businessObjectFormatKey,
                                                     Integer businessObjectDataVersion,
                                                     String businessObjectDataStatus,
                                                     List<String> storageNames,
                                                     String storagePlatformType,
                                                     String excludedStoragePlatformType)

Description copied from interface: BusinessObjectDataDao

Retrieves a minimum available partition value per specified parameters.

Specified by:

getBusinessObjectDataMinPartitionValue in interface BusinessObjectDataDao

Parameters:

partitionColumnPosition - the partition column position (1-based numbering)

businessObjectFormatKey - the business object format key (case-insensitive). If a business object format version isn't specified, the latest available format version for each partition value will be used.

businessObjectDataVersion - the business object data version. If a business object data version isn't specified, the latest data version based on the specified business object data status will be used for each partition value.

businessObjectDataStatus - the business object data status. This parameter is ignored when the business object data version is specified.

storageNames - the optional list of storage names (case-insensitive)

storagePlatformType - the optional storage platform type, e.g. S3 for Hive DDL. It is ignored when the list of storages is not empty

excludedStoragePlatformType - the optional storage platform type to be excluded from search. It is ignored when the list of storages is not empty or the storage platform type is specified

Returns:

the maximum available partition value

getBusinessObjectDataCount

public Long getBusinessObjectDataCount(BusinessObjectFormatKey businessObjectFormatKey)

Description copied from interface: BusinessObjectDataDao

Returns a number of business object data instances registered with this business object format.

Specified by:

getBusinessObjectDataCount in interface BusinessObjectDataDao

Parameters:

businessObjectFormatKey - the business object format key

Returns:

the number of business object data instances registered with this business object format

getBusinessObjectDataEntities

public List<BusinessObjectDataEntity> getBusinessObjectDataEntities(BusinessObjectDataKey businessObjectDataKey)

Description copied from interface: BusinessObjectDataDao

Retrieves business object data versions that match the specified business object data key with potentially missing business object format and/or data version values.

Specified by:

getBusinessObjectDataEntities in interface BusinessObjectDataDao

Parameters:

businessObjectDataKey - the business object data key with potentially missing business object format and/or data version values

Returns:

the business object data

getBusinessObjectDataEntities

public List<BusinessObjectDataEntity> getBusinessObjectDataEntities(BusinessObjectFormatKey businessObjectFormatKey,
                                                                    List<List<String>> partitionFilters,
                                                                    Integer businessObjectDataVersion,
                                                                    String businessObjectDataStatus,
                                                                    String storageName)

Description copied from interface: BusinessObjectDataDao

Retrieves a list of business object data entities per specified parameters.

Specified by:

getBusinessObjectDataEntities in interface BusinessObjectDataDao

Parameters:

businessObjectFormatKey - the business object format key (case-insensitive). If a business object format version isn't specified, the latest available format version for each partition value will be used.

partitionFilters - the list of partition filter to be used to select business object data instances. Each partition filter contains a list of primary and sub-partition values in the right order up to the maximum partition levels allowed by business object data registration - with partition values for the relative partitions not to be used for selection passed as nulls.

businessObjectDataVersion - the business object data version. If a business object data version isn't specified, the latest data version based on the specified business object data status is returned.

businessObjectDataStatus - the business object data status. This parameter is ignored when the business object data version is specified. When business object data version and business object data status both are not specified, the latest data version for each set of partition values will be used regardless of the status.

storageName - the name of the storage where the business object data storage unit is located (case-insensitive)

Returns:

the list of business object data entities sorted by partition values

getBusinessObjectDataFromStorageOlderThan

public List<BusinessObjectDataEntity> getBusinessObjectDataFromStorageOlderThan(String storageName,
                                                                                int thresholdMinutes,
                                                                                List<String> businessObjectDataStatusesToIgnore)

Description copied from interface: BusinessObjectDataDao

Selects business object data having storage files associated with the specified storage and with status not listed as ignored. Only tbe business object data records that are older than threshold minutes will be selected.

Specified by:

getBusinessObjectDataFromStorageOlderThan in interface BusinessObjectDataDao

Parameters:

storageName - the storage name

thresholdMinutes - the expiration time in minutes

businessObjectDataStatusesToIgnore - the list of business object data statuses to ignore

Returns:

the list of business object data entities sorted by created on

getBusinessObjectDataEntitiesMatchingStoragePolicies

public Map<BusinessObjectDataEntity,StoragePolicyEntity> getBusinessObjectDataEntitiesMatchingStoragePolicies(StoragePolicyPriorityLevel storagePolicyPriorityLevel,
                                                                                                              List<String> supportedBusinessObjectDataStatuses,
                                                                                                              int startPosition,
                                                                                                              int maxResult)

Description copied from interface: BusinessObjectDataDao

Retrieves a map of business object data entities to their corresponding storage policy entities, where the business object data status is supported by the storage policy feature and the business object data alternate key values match storage policy's filter and transition (not taking into account storage policy rules). The storage policy priority level identifies a particular storage policy priority that will be selected by the query. The returned map is ordered by the business object data "created on" timestamp, starting with the oldest business object data entity.

Specified by:

getBusinessObjectDataEntitiesMatchingStoragePolicies in interface BusinessObjectDataDao

Parameters:

storagePolicyPriorityLevel - the storage policy priority level

supportedBusinessObjectDataStatuses - the list of business object data statuses that storage policies apply to

startPosition - the position of the first result, numbered from 0

maxResult - the maximum number of results to retrieve

Returns:

the map of business object data entities to their corresponding storage policy entities

getBusinessObjectDataEntitiesByPartitionValue

public List<BusinessObjectDataEntity> getBusinessObjectDataEntitiesByPartitionValue(String partitionValue)

Description copied from interface: BusinessObjectDataDao

Retrieves a list of business object data by their partition value.

Specified by:

getBusinessObjectDataEntitiesByPartitionValue in interface BusinessObjectDataDao

Parameters:

partitionValue - The partition value

Returns:

A list of business object data entity

searchBusinessObjectData

public List<BusinessObjectData> searchBusinessObjectData(List<BusinessObjectDataSearchFilter> filters)

Description copied from interface: BusinessObjectDataDao

Retrieves a list of business object data by list of filters

Specified by:

searchBusinessObjectData in interface BusinessObjectDataDao

Parameters:

filters - search filters

Returns:

A list of business object data