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.

  • 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