Class ECpdsBase

java.lang.Object

ecmwf.common.database.DataGet

ecmwf.common.database.DataBase

ecmwf.common.database.ECpdsBase

All Implemented Interfaces:

MBeanService, Closeable, AutoCloseable

public final class ECpdsBase
extends DataBase

The Class ECpdsBase.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ECpdsBase.DataTransferCache	Allow getting a value cached by the caller.

Nested classes/interfaces inherited from class ecmwf.common.database.DataBase

DataBase.ScriptFileImpl

Field Summary

Fields inherited from class ecmwf.common.database.DataBase

MODE_EXTERNAL, MODE_INTERNAL, MODE_SERVER

Constructor Summary

Constructors

Constructor	Description
ECpdsBase()

Method Summary

Modifier and Type	Method	Description
void	clearIncomingUserCache(String userId)	Allow clearing the cache for an IncomingUser.
void	clearTransferServerCache(String groupName)	Allow clearing the cache for an TransferGroup.
Iterator<DataTransfer>	getAcquisitionDataTransfersToDownloadIterator(int limit)	Gets the acquisition data transfers to download iterator.
Alias[]	getAliases(String name, String mode)	Gets the aliases.
Collection<ECUser>	getAllowedEcUsersByHostName(String hostName)	Gets the allowed ec users by host name.
List<String>	getAuthorisedDestinations(String user)	Gets the authorised destinations.
List<String>	getAuthorisedHosts(String user)	Gets the authorised hosts.
Collection<DataTransfer>	getBadDataTransfersByDestination(ECpdsBase.DataTransferCache cache, String destinationName)	Gets the bad data transfers by destination.
int	getBadDataTransfersByDestinationCount(String destinationName)	Gets the bad data transfers by destination count.
Map<String,Integer>	getBadDataTransfersCount()	Gets the bad data transfers count.
Collection<Category>	getCategoriesPerResourceId(String id)	Gets the categories per resource id.
Collection<Category>	getCategoriesPerUserId(String userId)	Gets the categories per user id.
List<ChangeLog>	getChangeLogByKey(String keyName, String keyValue)	Gets the change log by key.
Map<String,List<Long>>	getDataFilesByGroupBy()	Gets the data files by group by.
long	getDataFilesByGroupByCount(String groupBy)	Gets the data files by group by count.
Collection<DataFile>	getDataFilesByMetaData(String name, String value, Date from, Date to, DataBaseCursor cursor)	Gets the data files by meta data.
Iterator<DataFile>	getDataFilesToFilterIterator(int limit)	Gets the data files to filter iterator.
String	getDataFromUserPolicies(IncomingUser user)	Gets the incoming user object with the data field populated with the data from the associated data policies.
int	getDataTransferCountNotDoneByProductAndTimeOnDate(String destination, String product, String time, Date from, Date to)	Gets the data transfer count not done by product and time on date.
Collection<DataTransfer>	getDataTransferNotDoneOnDate()	Gets the data transfer not done on date.
List<DataTransfer>	getDataTransfersByDataFileId(ECpdsBase.DataTransferCache cache, long dataFileId)	Gets the data transfers by data file id.
List<DataTransfer>	getDataTransfersByDataFileId(ECpdsBase.DataTransferCache cache, long dataFileId, boolean includeDeleted)	Gets the data transfers by data file id.
Iterator<DataTransfer>	getDataTransfersByDestination(String destinationName)	Gets the data transfers by destination.
Collection<DataTransfer>	getDataTransfersByDestinationAndIdentity(ECpdsBase.DataTransferCache cache, String destination, String identity)	Gets the data transfers by destination and identity.
Map<Long,DataTransfer>	getDataTransfersByDestinationAndMetaData(Date from, Date to, String destinationName, String metaStream, String metaTime)	Gets the data transfers by destination and meta data.
Iterator<DataTransfer>	getDataTransfersByDestinationAndTargetIterator(String destinationName, String target, boolean runnable)	Gets the data transfers by destination and target iterator.
Iterator<DataTransfer>	getDataTransfersByDestinationAndTargetIterator2(String destinationName, String target, boolean runnable, int sort, int order)	Gets the data transfers by destination and target iterator (v2).
Iterator<DataTransfer>	getDataTransfersByDestinationAndTargetOnDateIterator(String destinationName, String target, Date fromIsoDate, Date toIsoDate)	Gets the data transfers by destination on date iterator.
Iterator<DataTransfer>	getDataTransfersByDestinationAndTargetOnDateIterator2(String destinationName, String target, Date fromIsoDate, Date toIsoDate, int sort, int order)	Gets the data transfers by destination on date iterator (v2).
Collection<DataTransfer>	getDataTransfersByDestinationOnDate(ECpdsBase.DataTransferCache cache, String destinationName, Date fromIsoDate, Date toIsoDate)	Gets the data transfers by destination on date.
Collection<DataTransfer>	getDataTransfersByDestinationOnTransmissionDate(ECpdsBase.DataTransferCache cache, String destinationName, Date fromIsoDate, Date toIsoDate)	Gets the data transfers by destination on transmission date.
Collection<DataTransfer>	getDataTransfersByDestinationProductAndTimeOnDate(ECpdsBase.DataTransferCache cache, String destinationName, String product, String time, Date fromIsoDate, Date toIsoDate)	Gets the data transfers by destination product and time on date.
Collection<DataTransfer>	getDataTransfersByFilter(ECpdsBase.DataTransferCache cache, String destination, String target, String stream, String time, String status, String privilegedUser, Date scheduledBefore, String fileName, Date from, Date to)	Gets the data transfers by filter.
Collection<DataTransfer>	getDataTransfersByFilter(ECpdsBase.DataTransferCache cache, String destination, String target, String stream, String time, String status, String privilegedUser, Date scheduledBefore, String fileName, Date from, Date to, DataBaseCursor cursor)	Gets the sorted data transfers by filter.
Collection<DataTransfer>	getDataTransfersByHostName(ECpdsBase.DataTransferCache cache, String hostName, Date from, Date to)	Gets the data transfers by host name.
Iterator<DataTransfer>	getDataTransfersByTransferServer(TransferServer server)	Gets the data transfers by transfer server.
Collection<DataTransfer>	getDataTransfersByTransferServerName(ECpdsBase.DataTransferCache cache, String name, Date from, Date to)	Gets the data transfers by transfer server name.
Iterator<DataTransfer>	getDataTransfersToBackupIterator(int limit)	Gets the data transfers to backup iterator.
Iterator<DataTransfer>	getDataTransfersToProxyIterator(int limit)	Gets the data transfers to proxy iterator.
Iterator<DataTransfer>	getDataTransfersToReplicateIterator(int limit)	Gets the data transfers to replicate iterator.
Long[]	getDatesByDestinationAndTargetOnDate(String destinationName, int order)	Gets the dates by destination and target on date.
Destination[]	getDestinationAliases(String name, String mode)	Gets the destination aliases.
Destination[]	getDestinationArray(boolean monitored)	Gets the destinations.
ECUser[]	getDestinationEcuser(String destinationName)	Gets the destination ecuser.
DestinationExt[]	getDestinationExts()	Gets the destination exts.
Host[]	getDestinationHost(Destination dest, String type)	Gets the destination host.
Host[]	getDestinationHost(String dest, String type)	Gets the destination host.
IncomingPolicy[]	getDestinationIncomingPolicy(String destinationName)	Gets the destination incoming policies.
Set<Map.Entry<String,String>>	getDestinationNamesAndComments()	Gets the sorted destination names and comments.
Destination[]	getDestinations(String name)	Gets the destinations.
Map<String,List<Host>>	getDestinationsAndHostsForType(String type, int paramLimit)	Gets the destinations and hosts for type.
Destination[]	getDestinationsByCountryISO(String isoCode)	Gets the destinations by country iso.
Destination[]	getDestinationsByHostName(String hostName)	Gets the destinations by host name.
List<Destination>	getDestinationsByUser(String uid, SQLParameterParser options, String fromToAliases, boolean asc, String status, String type, String filter)	Gets the destinations by user.
Destination[]	getDestinationsByUserPolicies(String userId)	Gets the destinations by user policies.
Destination[]	getDestinationsForIncomingPolicy(String policyId)	Gets the destinations for an incoming policy.
Destination[]	getDestinationsForIncomingUser(String userId)	Gets the destinations for incoming user.
Iterator<DataTransfer>	getDisseminationDataTransfersToDownloadIterator(int limit)	Gets the dissemination data transfers to download iterator.
int	getECUserCount()	Gets the EC user count.
Collection<Event>	getECuserEvents(String userName, Date onIsoDate, String search, DataBaseCursor cursor)	Gets the ecuser events.
Iterator<ExistingStorageDirectory>	getExistingStorageDirectories()	Gets the existing storage directories.
Iterator<ExistingStorageDirectory>	getExistingStorageDirectoriesPerProxyHost()	Gets the existing storage directories per proxy host.
Iterator<DataFile>	getExpiredDataFilesIterator(int limit)	Gets the expired data files iterator.
Collection<Host>	getFilteredHosts(String label, String filter, String network, String type, String search, DataBaseCursor cursor)	Gets the hosts with the provided criteria.
Collection<Host>	getHostsByDestinationId(String destId)	Gets the hosts by destination id.
Collection<Host>	getHostsByTransferMethodId(String transferMethodId)	Gets the hosts by transfer method id.
Host[]	getHostsToCheck()	Gets the hosts to check.
Collection<IncomingHistory>	getIncomingHistory(String incomingUserName, Date onIsoDate, String search, DataBaseCursor cursor)	Gets the incoming history list.
List<IncomingPermission>	getIncomingPermissionsForIncomingUser(String userId)	Gets the incoming permissions for incoming user.
IncomingPolicy[]	getIncomingPoliciesForIncomingUser(String userId)	Gets the incoming policies for an incoming user.
IncomingUser[]	getIncomingUsersForIncomingPolicy(String policyId)	Gets the incoming users for an incoming policy.
Collection<DataTransfer>	getInitialDataTransferEvents(Date from, Date to)	Gets the initial data transfer events.
Iterator<DataTransfer>	getInitialDataTransferEventsIterator(Date from, Date to)	Gets the initial data transfer events.
ProductStatus[]	getInitialProductStatusEvents()	Gets the initial product status events.
Iterator<ProductStatus>	getInitialProductStatusEventsIterator()	Gets the initial product status events.
DataTransfer[]	getInterruptedTransfers()	Gets the interrupted transfers.
DataTransfer[]	getInterruptedTransfersPerDestination(Destination destination)	Gets the interrupted transfers per destination.
Collection<MetadataValue>	getMetaDataByAttributeName(String id)	Gets the meta data by attribute name.
Collection<MetadataValue>	getMetaDataByDataFileId(long dataFileId)	Gets the meta data by data file id.
Operation[]	getOperationsForIncomingUser(String userId)	Gets the operations for an incoming user.
List<DataTransfer>	getPendingDataTransfers(Destination destination, int limit)	Gets the pending data transfers.
List<PolicyUser>	getPolicyUserList(String userId)	Gets the user policies per user id.
ProductStatus[]	getProductStatus(String stream, String time, String type, long step, int limit)	Gets the product status.
Iterator<Publication>	getPublicationIterator(int limit)	Gets the publications to process iterator.
Rates[]	getRates(Date fromDate, Date toDate, String caller, String sourceHost)	Gets the rates.
Rates[]	getRatesPerFileSystem(Date fromDate, Date toDate, String transferServerName, String caller, String sourceHost)	Gets the rates per file system.
Rates[]	getRatesPerTransferServer(Date fromDate, Date toDate, String caller, String sourceHost)	Gets the rates per transfer server.
DataTransfer[]	getScheduledDataTransfer(String uniqueKey, String destinationName)	Gets the scheduled data transfer.
Collection<DataTransfer>	getSortedDataTransfersByStatusCodeAndDate(ECpdsBase.DataTransferCache cache, String status, Date from, Date to, String fileName, String type, DataBaseCursor cursor)	Gets the sorted data transfers by status code and date.
TransferHistory[]	getSortedTransferHistory(long dataTransferId, boolean afterScheduleTime, DataBaseCursor cursor)	Gets the sorted transfer history.
Collection<TransferHistory>	getSortedTransferHistoryByDestinationOnHistoryDate(String destinationName, Date fromIsoDate, Date toIsoDate, DataBaseCursor cursor)	Gets the sorted transfer history by destination on history date.
Collection<TransferHistory>	getSortedTransferHistoryByDestinationOnProductDate(String destinationName, Date fromIsoDate, Date toIsoDate, DataBaseCursor cursor)	Gets the sorted transfer history by destination on product date.
Statistics[]	getStatistics(Date fromDate, Date toDate, String groupName, String status, String type)	Gets the statistics.
List<Traffic>	getTrafficByDestinationName(String destinationName)	Gets the traffic by destination name.
Collection<List<String>>	getTransferCountAndMetaDataByFilter(String countBy, String destination, String target, String stream, String time, String status, String fileName, Date from, Date to, String privilegedUser, Date scheduledBefore)	Gets the transfer count and meta data by filter.
Collection<List<String>>	getTransferCountWithDestinationAndMetadataValueByMetadataName(String metadataName)	Gets the transfer count with destination and metadata value by metadata name.
TransferHistory[]	getTransferHistoryByDataTransferId(long dataTransferId)	Gets the transfer history.
Collection<TransferMethod>	getTransferMethodsByEcTransModuleName(String ecTransModuleName)	Gets the transfer methods by ec trans module name.
TransferServer[]	getTransferServers(String groupName)	Gets the transfer servers.
TransferServer[]	getTransferServersByDataFileId(long dataFileId)	Gets the transfer servers by data file id.
Collection<Url>	getUrlsPerCategoryId(String id)	Gets the urls per category id.
Collection<WebUser>	getUsersPerCategoryId(String categoryId)	Gets the users per category id.
int	purgeDataBase(long milliseconds)	Purge data base.
int	purgeDataFile(long dataFileId)	Purge data files.
long	purgeExpiredDataTransfers(int maxIdentityCount, int maxTransferLife)	Purge expired data transfers.
int	removeCategory(Category category)	Removes the category.
int	removeDestination(String destinationName, boolean remove)	Removes the destination.
int	removeHost(Host host)	Removes the host.
int	removeIncomingPolicy(IncomingPolicy policy)	Removes the IncomingPolicy.
int	removeIncomingUser(IncomingUser user)	Removes the IncomingUser.
int	removeUrl(Url url)	Removes the url.
int	removeWebUser(WebUser user)	Removes the web user.
int	resetDataTransferSchedulesByGroup(String groupBy)	Reschedule all data transfers belonging to a specific group to the current time.
int	resetProductStatus(String metaStream, String metaTime, long timeStep)	Reset product status.
int	resetRequeuedTransfersPerDestination(Destination destination)	Reset the re-queued transfers per destination.

Methods inherited from class ecmwf.common.database.DataBase

clearCache, clearCache, clearCache, close, escapeSql, executeCountAsInt, executeCountAsInt, executeCountAsLong, executeCountAsLong, executeQuery, executeQuery, executeSelect, executeSelect, executeSelect, executeUpdate, executeUpdate, formatDate, formatTime, get, getAll, getAttribute, getMBeanInfo, getMode, getPrimaryKeyValues, getScriptFileImpl, getTime, getTime, initialize, insert, insert, invoke, logSqlRequest, logSqlRequest, newActivity, newEvent, reloadRepository, remove, remove, select, setAttribute, store, tryInsert, tryUpdate, update, update

Methods inherited from class ecmwf.common.database.DataGet

getActivity, getActivity, getActivityObject, getAlias, getAliasArray, getAliasObject, getAssociation, getAssociationArray, getAssociationObject, getAuthorizedECUser, getAuthorizedECUserObject, getCategory, getCategoryArray, getCategoryObject, getCatUrl, getCatUrlArray, getCatUrlObject, getCountry, getCountryArray, getCountryObject, getDataFile, getDataFile, getDataFileObject, getDataTransfer, getDataTransferObject, getDestination, getDestinationArray, getDestinationECUser, getDestinationECUserArray, getDestinationECUserObject, getDestinationObject, getECSession, getECSession, getECSessionObject, getECtransAccounting, getECtransAccounting, getECtransAccountingObject, getECtransDestination, getECtransDestinationArray, getECtransDestinationObject, getECtransModule, getECtransModuleArray, getECtransModuleObject, getECUser, getECUserArray, getECUserObject, getEvent, getEvent, getEventObject, getHost, getHostArray, getHostArray, getHostECUser, getHostECUserObject, getHostLocation, getHostLocationObject, getHostObject, getHostOutput, getHostOutputObject, getHostStats, getHostStatsObject, getHostWithOutput, getIncomingAssociationArray, getIncomingPolicy, getIncomingPolicyArray, getIncomingPolicyObject, getIncomingUser, getIncomingUserArray, getIncomingUserObject, getMetadataAttribute, getMetadataAttributeArray, getMetadataAttributeObject, getMonitoringValue, getMonitoringValue, getMonitoringValueObject, getNotification, getNotification, getNotificationObject, getOperation, getOperationArray, getOperationObject, getPermission, getPermissionObject, getPolicyAssociation, getPrivileged, getPrivilegedObject, getProductStatus, getProductStatus, getProductStatusArray, getProductStatusObject, getPublication, getPublication, getPublicationIterator, getPublicationObject, getReception, getReception, getReceptionObject, getSchedulerValue, getSchedulerValue, getSchedulerValueObject, getSpool, getSpool, getSpoolObject, getTransferECUser, getTransferECUserObject, getTransferGroup, getTransferGroupArray, getTransferGroupObject, getTransferHistory, getTransferHistory, getTransferHistoryObject, getTransferMethod, getTransferMethodArray, getTransferMethodObject, getTransferModule, getTransferModuleArray, getTransferModuleObject, getTransferServer, getTransferServerArray, getTransferServerObject, getUrl, getUrlArray, getUrlObject, getWebUser, getWebUserArray, getWebUserObject, getWeuCat, getWeuCatArray, getWeuCatObject

Methods inherited from class java.lang.Object

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

Constructor Details

ECpdsBase

public ECpdsBase()

Method Details

clearIncomingUserCache

public void clearIncomingUserCache(String userId)

Allow clearing the cache for an IncomingUser.

Parameters:

userId - user identifier

clearTransferServerCache

public void clearTransferServerCache(String groupName)

Allow clearing the cache for an TransferGroup.

Parameters:

groupName - the group name

getTransferServers

public TransferServer[] getTransferServers(String groupName)

Gets the transfer servers.

Parameters:

groupName - the group name

Returns:

the transfer servers

getAuthorisedDestinations

public List<String> getAuthorisedDestinations(String user)
                                       throws DataBaseException

Gets the authorised destinations.

Parameters:

user - the user

Returns:

the authorised destinations

Throws:

DataBaseException - the data base exception

getAuthorisedHosts

public List<String> getAuthorisedHosts(String user)
                                throws DataBaseException

Gets the authorised hosts.

Parameters:

user - the user

Returns:

the authorised hosts

Throws:

DataBaseException - the data base exception

getStatistics

public Statistics[] getStatistics(Date fromDate,
 Date toDate,
 String groupName,
 String status,
 String type)
                           throws DataBaseException

Gets the statistics.

Parameters:

fromDate - the from date

toDate - the to date

groupName - the group name

status - the status

type - the type

Returns:

the statistics

Throws:

DataBaseException - the data base exception

getRates

public Rates[] getRates(Date fromDate,
 Date toDate,
 String caller,
 String sourceHost)
                 throws DataBaseException

Gets the rates.

Parameters:

fromDate - the from date

toDate - the to date

caller - the caller

sourceHost - the source host

Returns:

the rates

Throws:

DataBaseException - the data base exception

getRatesPerTransferServer

public Rates[] getRatesPerTransferServer(Date fromDate,
 Date toDate,
 String caller,
 String sourceHost)
                                  throws DataBaseException

Gets the rates per transfer server.

Parameters:

fromDate - the from date

toDate - the to date

caller - the caller

sourceHost - the source host

Returns:

the rates per transfer server

Throws:

DataBaseException - the data base exception

getRatesPerFileSystem

public Rates[] getRatesPerFileSystem(Date fromDate,
 Date toDate,
 String transferServerName,
 String caller,
 String sourceHost)
                              throws DataBaseException

Gets the rates per file system.

Parameters:

fromDate - the from date

toDate - the to date

transferServerName - the transfer server name

caller - the caller

sourceHost - the source host

Returns:

the rates per file system

Throws:

DataBaseException - the data base exception

getTransferServersByDataFileId

public TransferServer[] getTransferServersByDataFileId(long dataFileId)
                                                throws DataBaseException

Gets the transfer servers by data file id.

Parameters:

dataFileId - the data file id

Returns:

the transfer servers by data file id

Throws:

DataBaseException - the data base exception

getECUserCount

public int getECUserCount()

Gets the EC user count.

Returns:

the EC user count

getDestinationsAndHostsForType

public Map<String,List<Host>> getDestinationsAndHostsForType(String type,
 int paramLimit)
                                                      throws DataBaseException

Gets the destinations and hosts for type.

Parameters:

type - the type

paramLimit - the param limit

Returns:

the destinations and hosts for type

Throws:

DataBaseException - the data base exception

getDestinationHost

public Host[] getDestinationHost(Destination dest,
 String type)

Gets the destination host.

Parameters:

dest - the dest

type - the type

Returns:

the destination host

getDestinationHost

public Host[] getDestinationHost(String dest,
 String type)

Gets the destination host.

Parameters:

dest - the dest

type - the type

Returns:

the destination host

getDestinationEcuser

public ECUser[] getDestinationEcuser(String destinationName)
                              throws DataBaseException

Gets the destination ecuser.

Parameters:

destinationName - the destination name

Returns:

the destination ecuser

Throws:

DataBaseException - the data base exception

getDestinationIncomingPolicy

public IncomingPolicy[] getDestinationIncomingPolicy(String destinationName)
                                              throws DataBaseException

Gets the destination incoming policies.

Parameters:

destinationName - the destination name

Returns:

the destination incoming policies

Throws:

DataBaseException - the data base exception

getIncomingUsersForIncomingPolicy

public IncomingUser[] getIncomingUsersForIncomingPolicy(String policyId)
                                                 throws DataBaseException

Gets the incoming users for an incoming policy.

Parameters:

policyId - the policy id

Returns:

the incoming users

Throws:

DataBaseException - the data base exception

getIncomingPoliciesForIncomingUser

public IncomingPolicy[] getIncomingPoliciesForIncomingUser(String userId)
                                                    throws DataBaseException

Gets the incoming policies for an incoming user.

Parameters:

userId - the user id

Returns:

the incoming policies

Throws:

DataBaseException - the data base exception

getOperationsForIncomingUser

public Operation[] getOperationsForIncomingUser(String userId)

Gets the operations for an incoming user.

Parameters:

userId - the user id

Returns:

the operations

getDestinationsForIncomingPolicy

public Destination[] getDestinationsForIncomingPolicy(String policyId)
                                               throws DataBaseException

Gets the destinations for an incoming policy.

Parameters:

policyId - the policy id

Returns:

the destinations

Throws:

DataBaseException - the data base exception

getDestinations

public Destination[] getDestinations(String name)
                              throws DataBaseException

Gets the destinations.

Parameters:

name - the name

Returns:

the destinations

Throws:

DataBaseException - the data base exception

getDestinationArray

public Destination[] getDestinationArray(boolean monitored)
                                  throws DataBaseException

Gets the destinations.

Parameters:

monitored - only monitored destinations?

Returns:

the destinations

Throws:

DataBaseException - the data base exception

getDestinationsForIncomingUser

public Destination[] getDestinationsForIncomingUser(String userId)

Gets the destinations for incoming user.

Parameters:

userId - the uid

Returns:

the destinations for incoming user

getDestinationsByUserPolicies

public Destination[] getDestinationsByUserPolicies(String userId)

Gets the destinations by user policies.

Parameters:

userId - the user id

Returns:

the destinations by user policies

getIncomingPermissionsForIncomingUser

public List<IncomingPermission> getIncomingPermissionsForIncomingUser(String userId)

Gets the incoming permissions for incoming user.

Parameters:

userId - the user id

Returns:

the incoming permissions for incoming user

getDestinationAliases

public Destination[] getDestinationAliases(String name,
 String mode)
                                    throws DataBaseException

Gets the destination aliases.

Parameters:

name - the name

mode - the mode

Returns:

the destination aliases

Throws:

DataBaseException - the data base exception

getAliases

public Alias[] getAliases(String name,
 String mode)
                   throws DataBaseException

Gets the aliases.

Parameters:

name - the name

mode - the mode

Returns:

the aliases

Throws:

DataBaseException - the data base exception

purgeDataBase

public int purgeDataBase(long milliseconds)

Purge data base.

Parameters:

milliseconds - the milliseconds

Returns:

the int

resetDataTransferSchedulesByGroup

public int resetDataTransferSchedulesByGroup(String groupBy)

Reschedule all data transfers belonging to a specific group to the current time.

Parameters:

groupBy - the group by

Returns:

the int

purgeDataFile

public int purgeDataFile(long dataFileId)

Purge data files.

Parameters:

dataFileId - the data file id

Returns:

the int

getBadDataTransfersCount

public Map<String,Integer> getBadDataTransfersCount()
                                             throws DataBaseException

Gets the bad data transfers count.

Returns:

the bad data transfers count

Throws:

DataBaseException - the data base exception

getDataTransfersByHostName

public Collection<DataTransfer> getDataTransfersByHostName(ECpdsBase.DataTransferCache cache,
 String hostName,
 Date from,
 Date to)
                                                    throws DataBaseException

Gets the data transfers by host name.

Parameters:

cache - the data transfer cache

hostName - the host name

from - the from

to - the to

Returns:

the data transfers by host name

Throws:

DataBaseException - the data base exception

getDataTransfersByDestinationAndMetaData

public Map<Long,DataTransfer> getDataTransfersByDestinationAndMetaData(Date from,
 Date to,
 String destinationName,
 String metaStream,
 String metaTime)
                                                                throws DataBaseException

Gets the data transfers by destination and meta data.

Parameters:

from - the from

to - the to

destinationName - the destination name

metaStream - the meta stream

metaTime - the meta time

Returns:

the data transfers by destination and meta data

Throws:

DataBaseException - the data base exception

getDataTransferNotDoneOnDate

public Collection<DataTransfer> getDataTransferNotDoneOnDate()
                                                      throws DataBaseException

Gets the data transfer not done on date.

Returns:

the data transfer not done on date

Throws:

DataBaseException - the data base exception

getDataTransfersByTransferServerName

public Collection<DataTransfer> getDataTransfersByTransferServerName(ECpdsBase.DataTransferCache cache,
 String name,
 Date from,
 Date to)
                                                              throws DataBaseException

Gets the data transfers by transfer server name.

Parameters:

cache - the data transfer cache

name - the name

from - the from

to - the to

Returns:

the data transfers by transfer server name

Throws:

DataBaseException - the data base exception

getInitialDataTransferEventsIterator

public Iterator<DataTransfer> getInitialDataTransferEventsIterator(Date from,
 Date to)
                                                            throws DataBaseException,
SQLException,
IOException

Gets the initial data transfer events.

Parameters:

from - the from

to - the to

Returns:

the initial data transfer events

Throws:

DataBaseException - the data base exception

SQLException - the SQL exception

IOException - Signals that an I/O exception has occurred.

getInitialDataTransferEvents

public Collection<DataTransfer> getInitialDataTransferEvents(Date from,
 Date to)
                                                      throws DataBaseException

Gets the initial data transfer events.

Parameters:

from - the from

to - the to

Returns:

the initial data transfer events

Throws:

DataBaseException - the data base exception

getSortedDataTransfersByStatusCodeAndDate

public Collection<DataTransfer> getSortedDataTransfersByStatusCodeAndDate(ECpdsBase.DataTransferCache cache,
 String status,
 Date from,
 Date to,
 String fileName,
 String type,
 DataBaseCursor cursor)
                                                                   throws DataBaseException

Gets the sorted data transfers by status code and date. This is used on the transfer page!

Parameters:

cache - the data transfer cache

status - the status

from - the from

to - the to

fileName - the search

type - the type

cursor - the cursor

Returns:

the sorted data transfers by status code and date

Throws:

DataBaseException - the data base exception

getDestinationNamesAndComments

public Set<Map.Entry<String,String>> getDestinationNamesAndComments()
                                                             throws DataBaseException

Gets the sorted destination names and comments.

Returns:

the sorted destination names and comments

Throws:

DataBaseException - the data base exception

getDestinationExts

public DestinationExt[] getDestinationExts()

Gets the destination exts.

Returns:

the destination exts

getPendingDataTransfers

public List<DataTransfer> getPendingDataTransfers(Destination destination,
 int limit)

Gets the pending data transfers.

Parameters:

destination - the destination

limit - the limit

Returns:

the pending data transfers

getDataFilesByGroupBy

public Map<String,List<Long>> getDataFilesByGroupBy()

Gets the data files by group by.

Returns:

the data files by group by

getDataFilesByGroupByCount

public long getDataFilesByGroupByCount(String groupBy)

Gets the data files by group by count.

Parameters:

groupBy - the group by

Returns:

the data files by group by count

getDataTransfersByDataFileId

public List<DataTransfer> getDataTransfersByDataFileId(ECpdsBase.DataTransferCache cache,
 long dataFileId)
                                                throws DataBaseException

Gets the data transfers by data file id.

Parameters:

cache - the data transfer cache

dataFileId - the dataFile id

Returns:

the data transfers by data file id

Throws:

DataBaseException - the data base exception

getDataTransfersByDataFileId

public List<DataTransfer> getDataTransfersByDataFileId(ECpdsBase.DataTransferCache cache,
 long dataFileId,
 boolean includeDeleted)
                                                throws DataBaseException

Gets the data transfers by data file id.

Parameters:

cache - the data transfer cache

dataFileId - the id

includeDeleted - the include deleted

Returns:

the data transfers by data file id

Throws:

DataBaseException - the data base exception

getDestinationsByCountryISO

public Destination[] getDestinationsByCountryISO(String isoCode)

Gets the destinations by country iso.

Parameters:

isoCode - the iso code

Returns:

the destinations by country iso

getDestinationsByUser

public List<Destination> getDestinationsByUser(String uid,
 SQLParameterParser options,
 String fromToAliases,
 boolean asc,
 String status,
 String type,
 String filter)

Gets the destinations by user.

Parameters:

uid - the uid

options - the options

fromToAliases - the from to aliases

asc - the asc

status - the status

type - the type

filter - the filter

Returns:

the destinations by user

getDestinationsByHostName

public Destination[] getDestinationsByHostName(String hostName)
                                        throws DataBaseException

Gets the destinations by host name.

Parameters:

hostName - the host name

Returns:

the destinations by host name

Throws:

DataBaseException - the data base exception

getTransferHistoryByDataTransferId

public TransferHistory[] getTransferHistoryByDataTransferId(long dataTransferId)
                                                     throws DataBaseException

Gets the transfer history.

Parameters:

dataTransferId - the data transfer id

Returns:

the transfer history

Throws:

DataBaseException - the data base exception

getSortedTransferHistory

public TransferHistory[] getSortedTransferHistory(long dataTransferId,
 boolean afterScheduleTime,
 DataBaseCursor cursor)
                                           throws DataBaseException

Gets the sorted transfer history.

Parameters:

dataTransferId - the data transfer id

afterScheduleTime - the after schedule time

cursor - the cursor

Returns:

the sorted transfer history

Throws:

DataBaseException - the data base exception

getScheduledDataTransfer

public DataTransfer[] getScheduledDataTransfer(String uniqueKey,
 String destinationName)

Gets the scheduled data transfer.

Parameters:

uniqueKey - the unique key

destinationName - the destination name

Returns:

the scheduled data transfer

getExistingStorageDirectories

public Iterator<ExistingStorageDirectory> getExistingStorageDirectories()
                                                                 throws IOException,
SQLException

Gets the existing storage directories.

Returns:

the existing storage directories

Throws:

IOException - Signals that an I/O exception has occurred.

SQLException - the SQL exception

getExistingStorageDirectoriesPerProxyHost

public Iterator<ExistingStorageDirectory> getExistingStorageDirectoriesPerProxyHost()
                                                                             throws IOException,
SQLException

Gets the existing storage directories per proxy host.

Returns:

the existing storage directories per proxy host

Throws:

IOException - Signals that an I/O exception has occurred.

SQLException - the SQL exception

getExpiredDataFilesIterator

public Iterator<DataFile> getExpiredDataFilesIterator(int limit)
                                               throws IOException,
SQLException

Gets the expired data files iterator. Avoid getting a large array of DataFiles!

Parameters:

limit - the limit

Returns:

the expired data files iterator

Throws:

IOException - Signals that an I/O exception has occurred.

SQLException - the SQL exception

getDataFilesToFilterIterator

public Iterator<DataFile> getDataFilesToFilterIterator(int limit)
                                                throws IOException,
SQLException

Gets the data files to filter iterator. Avoid getting a large array of DataFiles!

Parameters:

limit - the limit

Returns:

the data files to filter iterator

Throws:

IOException - Signals that an I/O exception has occurred.

SQLException - the SQL exception

getPublicationIterator

public Iterator<Publication> getPublicationIterator(int limit)
                                             throws IOException,
SQLException

Gets the publications to process iterator. Avoid getting a large array of Publications!

Parameters:

limit - the limit

Returns:

the publications to process iterator

Throws:

IOException - Signals that an I/O exception has occurred.

SQLException - the SQL exception

getDataTransfersToReplicateIterator

public Iterator<DataTransfer> getDataTransfersToReplicateIterator(int limit)
                                                           throws IOException,
SQLException

Gets the data transfers to replicate iterator. Get an iterator to avoid having a large array of DataTransfers!

Parameters:

limit - the limit

Returns:

the data transfers to replicate iterator

Throws:

IOException - Signals that an I/O exception has occurred.

SQLException - the SQL exception

getDataTransfersToBackupIterator

public Iterator<DataTransfer> getDataTransfersToBackupIterator(int limit)
                                                        throws IOException,
SQLException

Gets the data transfers to backup iterator. Avoid getting a large array of DataTransfers!

Parameters:

limit - the limit

Returns:

the data transfers to backup iterator

Throws:

IOException - Signals that an I/O exception has occurred.

SQLException - the SQL exception

getDataTransfersToProxyIterator

public Iterator<DataTransfer> getDataTransfersToProxyIterator(int limit)
                                                       throws IOException,
SQLException

Gets the data transfers to proxy iterator. Avoid getting a large array of DataTransfers!

Parameters:

limit - the limit

Returns:

the data transfers to proxy iterator

Throws:

IOException - Signals that an I/O exception has occurred.

SQLException - the SQL exception

getAcquisitionDataTransfersToDownloadIterator

public Iterator<DataTransfer> getAcquisitionDataTransfersToDownloadIterator(int limit)
                                                                     throws SQLException,
IOException

Gets the acquisition data transfers to download iterator. Avoid caching the DataTransfers in an array!

Parameters:

limit - the limit

Returns:

the acquisition data transfers to download iterator

Throws:

SQLException - the SQL exception

IOException - Signals that an I/O exception has occurred.

getDisseminationDataTransfersToDownloadIterator

public Iterator<DataTransfer> getDisseminationDataTransfersToDownloadIterator(int limit)
                                                                       throws SQLException,
IOException

Gets the dissemination data transfers to download iterator. Avoid caching the DataTransfers in an array!

Parameters:

limit - the limit

Returns:

the dissemination data transfers to download iterator

Throws:

SQLException - the SQL exception

IOException - Signals that an I/O exception has occurred.

purgeExpiredDataTransfers

public long purgeExpiredDataTransfers(int maxIdentityCount,
 int maxTransferLife)

Purge expired data transfers.

Parameters:

maxIdentityCount - the max identity count

maxTransferLife - the max transfer life

Returns:

the long

getCategoriesPerUserId

public Collection<Category> getCategoriesPerUserId(String userId)
                                            throws DataBaseException

Gets the categories per user id.

Parameters:

userId - the user id

Returns:

the categories per user id

Throws:

DataBaseException - the data base exception

getDataFromUserPolicies

public String getDataFromUserPolicies(IncomingUser user)

Gets the incoming user object with the data field populated with the data from the associated data policies. Not meant to be saved to the database by the caller!

Parameters:

user - the user

Returns:

the incoming user object

getPolicyUserList

public List<PolicyUser> getPolicyUserList(String userId)

Gets the user policies per user id.

Parameters:

userId - the user id

Returns:

the user policies per user id

getUsersPerCategoryId

public Collection<WebUser> getUsersPerCategoryId(String categoryId)
                                          throws DataBaseException

Gets the users per category id.

Parameters:

categoryId - the category id

Returns:

the users per category id

Throws:

DataBaseException - the data base exception

getUrlsPerCategoryId

public Collection<Url> getUrlsPerCategoryId(String id)
                                     throws DataBaseException

Gets the urls per category id.

Parameters:

id - the id

Returns:

the urls per category id

Throws:

DataBaseException - the data base exception

getCategoriesPerResourceId

public Collection<Category> getCategoriesPerResourceId(String id)
                                                throws DataBaseException

Gets the categories per resource id.

Parameters:

id - the id

Returns:

the categories per resource id

Throws:

DataBaseException - the data base exception

getDataFilesByMetaData

public Collection<DataFile> getDataFilesByMetaData(String name,
 String value,
 Date from,
 Date to,
 DataBaseCursor cursor)
                                            throws DataBaseException

Gets the data files by meta data.

Parameters:

name - the name

value - the value

from - the from

to - the to

cursor - the cursor

Returns:

the data files by meta data

Throws:

DataBaseException - the data base exception

getTransferCountAndMetaDataByFilter

public Collection<List<String>> getTransferCountAndMetaDataByFilter(String countBy,
 String destination,
 String target,
 String stream,
 String time,
 String status,
 String fileName,
 Date from,
 Date to,
 String privilegedUser,
 Date scheduledBefore)
                                                             throws DataBaseException

Gets the transfer count and meta data by filter. This is used on the destination page to show the number of transfers per stream, target of status!

Parameters:

countBy - the count by

destination - the destination

target - the target

stream - the stream

time - the time

status - the status

fileName - the file name

from - the from

to - the to

privilegedUser - the privileged user

scheduledBefore - the scheduled before

Returns:

the transfer count and meta data by filter

Throws:

DataBaseException - the data base exception

getDataTransfersByFilter

public Collection<DataTransfer> getDataTransfersByFilter(ECpdsBase.DataTransferCache cache,
 String destination,
 String target,
 String stream,
 String time,
 String status,
 String privilegedUser,
 Date scheduledBefore,
 String fileName,
 Date from,
 Date to,
 DataBaseCursor cursor)
                                                  throws DataBaseException

Gets the sorted data transfers by filter. This is used on the destination page, to filter the transfers!

Parameters:

cache - the data transfer cache

destination - the destination

target - the target

stream - the stream

time - the time

status - the status

privilegedUser - the privileged user

scheduledBefore - the scheduled before

fileName - the file name

from - the from

to - the to

cursor - the cursor

Returns:

the sorted data transfers by filter

Throws:

DataBaseException - the data base exception

getDataTransfersByFilter

public Collection<DataTransfer> getDataTransfersByFilter(ECpdsBase.DataTransferCache cache,
 String destination,
 String target,
 String stream,
 String time,
 String status,
 String privilegedUser,
 Date scheduledBefore,
 String fileName,
 Date from,
 Date to)
                                                  throws DataBaseException

Gets the data transfers by filter. This is used on the destination page, to filter the transfers!

Parameters:

cache - the data transfer cache

destination - the destination

target - the target

stream - the stream

time - the time

status - the status

privilegedUser - the privileged user

scheduledBefore - the scheduled before

fileName - the file name

from - the from

to - the to

Returns:

the data transfers by filter

Throws:

DataBaseException - the data base exception

getFilteredHosts

public Collection<Host> getFilteredHosts(String label,
 String filter,
 String network,
 String type,
 String search,
 DataBaseCursor cursor)
                                  throws DataBaseException

Gets the hosts with the provided criteria.

Parameters:

label - the label

filter - the filter

network - the network

type - the type

search - the search

cursor - the cursor

Returns:

the hosts

Throws:

DataBaseException - the data base exception

getHostsByDestinationId

public Collection<Host> getHostsByDestinationId(String destId)
                                         throws DataBaseException

Gets the hosts by destination id.

Parameters:

destId - the dest id

Returns:

the hosts by destination id

Throws:

DataBaseException - the data base exception

getHostsByTransferMethodId

public Collection<Host> getHostsByTransferMethodId(String transferMethodId)
                                            throws DataBaseException

Gets the hosts by transfer method id.

Parameters:

transferMethodId - the transfer method id

Returns:

the hosts by transfer method id

Throws:

DataBaseException - the data base exception

getHostsToCheck

public Host[] getHostsToCheck()

Gets the hosts to check.

Returns:

the hosts to check

getTransferMethodsByEcTransModuleName

public Collection<TransferMethod> getTransferMethodsByEcTransModuleName(String ecTransModuleName)
                                                                 throws DataBaseException

Gets the transfer methods by ec trans module name.

Parameters:

ecTransModuleName - the ec trans module name

Returns:

the transfer methods by ec trans module name

Throws:

DataBaseException - the data base exception

getMetaDataByDataFileId

public Collection<MetadataValue> getMetaDataByDataFileId(long dataFileId)
                                                  throws DataBaseException

Gets the meta data by data file id.

Parameters:

dataFileId - the dataFile id

Returns:

the meta data by data file id

Throws:

DataBaseException - the data base exception

getMetaDataByAttributeName

public Collection<MetadataValue> getMetaDataByAttributeName(String id)
                                                     throws DataBaseException

Gets the meta data by attribute name.

Parameters:

id - the id

Returns:

the meta data by attribute name

Throws:

DataBaseException - the data base exception

getDataTransfersByDestination

public Iterator<DataTransfer> getDataTransfersByDestination(String destinationName)
                                                     throws DataBaseException

Gets the data transfers by destination.

Parameters:

destinationName - the Destination name

Returns:

the data transfers by destination

Throws:

DataBaseException - the data base exception

resetRequeuedTransfersPerDestination

public int resetRequeuedTransfersPerDestination(Destination destination)
                                         throws DataBaseException

Reset the re-queued transfers per destination.

Parameters:

destination - the destination

Returns:

the int

Throws:

DataBaseException - the data base exception

getDataTransfersByTransferServer

public Iterator<DataTransfer> getDataTransfersByTransferServer(TransferServer server)
                                                        throws DataBaseException

Gets the data transfers by transfer server.

Parameters:

server - the server

Returns:

the data transfers by transfer server

Throws:

DataBaseException - the data base exception

getDataTransfersByDestinationAndIdentity

public Collection<DataTransfer> getDataTransfersByDestinationAndIdentity(ECpdsBase.DataTransferCache cache,
 String destination,
 String identity)
                                                                  throws DataBaseException

Gets the data transfers by destination and identity.

Parameters:

cache - the data transfer cache

destination - the destination

identity - the identity

Returns:

the data transfers by destination and identity

Throws:

DataBaseException - the data base exception

getTransferCountWithDestinationAndMetadataValueByMetadataName

public Collection<List<String>> getTransferCountWithDestinationAndMetadataValueByMetadataName(String metadataName)
                                                                                       throws DataBaseException

Gets the transfer count with destination and metadata value by metadata name.

Parameters:

metadataName - the metadata name

Returns:

the transfer count with destination and metadata value by metadata name

Throws:

DataBaseException - the data base exception

getDataTransfersByDestinationProductAndTimeOnDate

public Collection<DataTransfer> getDataTransfersByDestinationProductAndTimeOnDate(ECpdsBase.DataTransferCache cache,
 String destinationName,
 String product,
 String time,
 Date fromIsoDate,
 Date toIsoDate)
                                                                           throws DataBaseException

Gets the data transfers by destination product and time on date.

Parameters:

cache - the data transfer cache

destinationName - the destination name

product - the product

time - the time

fromIsoDate - the from iso date

toIsoDate - the to iso date

Returns:

the data transfers by destination product and time on date

Throws:

DataBaseException - the data base exception

getDataTransfersByDestinationOnDate

public Collection<DataTransfer> getDataTransfersByDestinationOnDate(ECpdsBase.DataTransferCache cache,
 String destinationName,
 Date fromIsoDate,
 Date toIsoDate)
                                                             throws DataBaseException

Gets the data transfers by destination on date.

Parameters:

cache - the data transfer cache

destinationName - the destination name

fromIsoDate - the from iso date

toIsoDate - the to iso date

Returns:

the data transfers by destination on date

Throws:

DataBaseException - the data base exception

getDataTransfersByDestinationAndTargetOnDateIterator

public Iterator<DataTransfer> getDataTransfersByDestinationAndTargetOnDateIterator(String destinationName,
 String target,
 Date fromIsoDate,
 Date toIsoDate)
                                                                            throws DataBaseException

Gets the data transfers by destination on date iterator.

Parameters:

destinationName - the destination name

target - the target

fromIsoDate - the from iso date

toIsoDate - the to iso date

Returns:

the data transfers by destination on date iterator

Throws:

DataBaseException - the data base exception

getDataTransfersByDestinationAndTargetOnDateIterator2

public Iterator<DataTransfer> getDataTransfersByDestinationAndTargetOnDateIterator2(String destinationName,
 String target,
 Date fromIsoDate,
 Date toIsoDate,
 int sort,
 int order)
                                                                             throws IOException,
SQLException

Gets the data transfers by destination on date iterator (v2).

Parameters:

destinationName - the destination name

target - the target

fromIsoDate - the from iso date

toIsoDate - the to iso date

sort - the sort

order - the order

Returns:

the data transfers by destination on date iterator

Throws:

IOException - Signals that an I/O exception has occurred.

SQLException - the SQL exception

getDataTransfersByDestinationOnTransmissionDate

public Collection<DataTransfer> getDataTransfersByDestinationOnTransmissionDate(ECpdsBase.DataTransferCache cache,
 String destinationName,
 Date fromIsoDate,
 Date toIsoDate)
                                                                         throws DataBaseException

Gets the data transfers by destination on transmission date.

Parameters:

cache - the data transfer cache

destinationName - the destination name

fromIsoDate - the from iso date

toIsoDate - the to iso date

Returns:

the data transfers by destination on transmission date

Throws:

DataBaseException - the data base exception

getDatesByDestinationAndTargetOnDate

public Long[] getDatesByDestinationAndTargetOnDate(String destinationName,
 int order)
                                            throws DataBaseException

Gets the dates by destination and target on date.

Parameters:

destinationName - the destination name

order - the order

Returns:

the dates by destination and target on date

Throws:

DataBaseException - the data base exception

getDataTransfersByDestinationAndTargetIterator

public Iterator<DataTransfer> getDataTransfersByDestinationAndTargetIterator(String destinationName,
 String target,
 boolean runnable)
                                                                      throws DataBaseException

Gets the data transfers by destination and target iterator.

Parameters:

destinationName - the destination name

target - the target

runnable - the runnable

Returns:

the data transfers by destination and target iterator

Throws:

DataBaseException - the data base exception

getDataTransfersByDestinationAndTargetIterator2

public Iterator<DataTransfer> getDataTransfersByDestinationAndTargetIterator2(String destinationName,
 String target,
 boolean runnable,
 int sort,
 int order)
                                                                       throws IOException,
SQLException

Gets the data transfers by destination and target iterator (v2).

Parameters:

destinationName - the destination name

target - the target

runnable - the runnable

sort - the sort

order - the order

Returns:

the data transfers by destination and target iterator

Throws:

IOException - Signals that an I/O exception has occurred.

SQLException - the SQL exception

getBadDataTransfersByDestination

public Collection<DataTransfer> getBadDataTransfersByDestination(ECpdsBase.DataTransferCache cache,
 String destinationName)
                                                          throws DataBaseException

Gets the bad data transfers by destination.

Parameters:

cache - the data transfer cache

destinationName - the destination name

Returns:

the bad data transfers by destination

Throws:

DataBaseException - the data base exception

getBadDataTransfersByDestinationCount

public int getBadDataTransfersByDestinationCount(String destinationName)

Gets the bad data transfers by destination count.

Parameters:

destinationName - the destination name

Returns:

the bad data transfers by destination count

getDataTransferCountNotDoneByProductAndTimeOnDate

public int getDataTransferCountNotDoneByProductAndTimeOnDate(String destination,
 String product,
 String time,
 Date from,
 Date to)
                                                      throws DataBaseException

Gets the data transfer count not done by product and time on date.

Parameters:

destination - the destination

product - the product

time - the time

from - the from

to - the to

Returns:

the data transfer count not done by product and time on date

Throws:

DataBaseException - the data base exception

getSortedTransferHistoryByDestinationOnProductDate

public Collection<TransferHistory> getSortedTransferHistoryByDestinationOnProductDate(String destinationName,
 Date fromIsoDate,
 Date toIsoDate,
 DataBaseCursor cursor)
                                                                               throws DataBaseException

Gets the sorted transfer history by destination on product date.

Parameters:

destinationName - the destination name

fromIsoDate - the from iso date

toIsoDate - the to iso date

cursor - the cursor

Returns:

the sorted transfer history by destination on product date

Throws:

DataBaseException - the data base exception

getSortedTransferHistoryByDestinationOnHistoryDate

public Collection<TransferHistory> getSortedTransferHistoryByDestinationOnHistoryDate(String destinationName,
 Date fromIsoDate,
 Date toIsoDate,
 DataBaseCursor cursor)
                                                                               throws DataBaseException

Gets the sorted transfer history by destination on history date.

Parameters:

destinationName - the destination name

fromIsoDate - the from iso date

toIsoDate - the to iso date

cursor - the cursor

Returns:

the sorted transfer history by destination on history date

Throws:

DataBaseException - the data base exception

getECuserEvents

public Collection<Event> getECuserEvents(String userName,
 Date onIsoDate,
 String search,
 DataBaseCursor cursor)
                                  throws DataBaseException

Gets the ecuser events.

Parameters:

userName - the user name

onIsoDate - the on iso date

search - the search

cursor - the cursor

Returns:

the ecuser events

Throws:

DataBaseException - the data base exception

getIncomingHistory

public Collection<IncomingHistory> getIncomingHistory(String incomingUserName,
 Date onIsoDate,
 String search,
 DataBaseCursor cursor)
                                               throws DataBaseException

Gets the incoming history list.

Parameters:

incomingUserName - the incoming user name

onIsoDate - the on iso date

search - the search

cursor - the cursor

Returns:

the incoming history list

Throws:

DataBaseException - the data base exception

getAllowedEcUsersByHostName

public Collection<ECUser> getAllowedEcUsersByHostName(String hostName)
                                               throws DataBaseException

Gets the allowed ec users by host name.

Parameters:

hostName - the host name

Returns:

the allowed ec users by host name

Throws:

DataBaseException - the data base exception

getTrafficByDestinationName

public List<Traffic> getTrafficByDestinationName(String destinationName)
                                          throws DataBaseException

Gets the traffic by destination name.

Parameters:

destinationName - the destination name

Returns:

the traffic

Throws:

DataBaseException - the data base exception

getChangeLogByKey

public List<ChangeLog> getChangeLogByKey(String keyName,
 String keyValue)
                                  throws DataBaseException

Gets the change log by key.

Parameters:

keyName - the key name

keyValue - the key value

Returns:

the change log

Throws:

DataBaseException - the data base exception

getProductStatus

public ProductStatus[] getProductStatus(String stream,
 String time,
 String type,
 long step,
 int limit)
                                 throws DataBaseException

Gets the product status.

Parameters:

stream - the stream

time - the time

type - the type

step - the step

limit - the limit

Returns:

the product status

Throws:

DataBaseException - the data base exception

getInitialProductStatusEventsIterator

public Iterator<ProductStatus> getInitialProductStatusEventsIterator()
                                                              throws DataBaseException,
SQLException,
IOException

Gets the initial product status events.

Returns:

the initial product status events iterator

Throws:

DataBaseException - the data base exception

SQLException - the SQL exception

IOException - Signals that an I/O exception has occurred.

getInitialProductStatusEvents

public ProductStatus[] getInitialProductStatusEvents()
                                              throws DataBaseException

Gets the initial product status events.

Returns:

the initial product status events

Throws:

DataBaseException - the data base exception

getInterruptedTransfers

public DataTransfer[] getInterruptedTransfers()
                                       throws DataBaseException

Gets the interrupted transfers.

Returns:

the interrupted transfers

Throws:

DataBaseException - the data base exception

getInterruptedTransfersPerDestination

public DataTransfer[] getInterruptedTransfersPerDestination(Destination destination)

Gets the interrupted transfers per destination.

Parameters:

destination - the destination

Returns:

the interrupted transfers per destination

resetProductStatus

public int resetProductStatus(String metaStream,
 String metaTime,
 long timeStep)
                       throws DataBaseException

Reset product status.

Parameters:

metaStream - the meta stream

metaTime - the meta time

timeStep - the time step

Returns:

the int

Throws:

DataBaseException - the data base exception

removeDestination

public int removeDestination(String destinationName,
 boolean remove)
                      throws DataBaseException

Removes the destination.

Parameters:

destinationName - the Destination name

remove - the remove

Returns:

the int

Throws:

DataBaseException - the data base exception

removeHost

public int removeHost(Host host)
               throws DataBaseException

Removes the host.

Parameters:

host - the host

Returns:

the int

Throws:

DataBaseException - the data base exception

removeWebUser

public int removeWebUser(WebUser user)
                  throws DataBaseException

Removes the web user.

Parameters:

user - the web user

Returns:

the int

Throws:

DataBaseException - the data base exception

removeCategory

public int removeCategory(Category category)
                   throws DataBaseException

Removes the category.

Parameters:

category - the category

Returns:

the int

Throws:

DataBaseException - the data base exception

removeUrl

public int removeUrl(Url url)
              throws DataBaseException

Removes the url.

Parameters:

url - the url

Returns:

the int

Throws:

DataBaseException - the data base exception

removeIncomingUser

public int removeIncomingUser(IncomingUser user)
                       throws DataBaseException

Removes the IncomingUser.

Parameters:

user - the incoming user

Returns:

the int

Throws:

DataBaseException - the data base exception

removeIncomingPolicy

public int removeIncomingPolicy(IncomingPolicy policy)
                         throws DataBaseException

Removes the IncomingPolicy.

Parameters:

policy - the incoming policy

Returns:

the int

Throws:

DataBaseException - the data base exception