Package org.opencastproject.assetmanager.impl.persistence

Class Database

java.lang.Object
org.opencastproject.assetmanager.impl.persistence.Database
@ParametersAreNonnullByDefault public class Database extends Object
Data access object.

  • Constructor Details

  • Method Details

    • setHttpAssetProvider

      public void setHttpAssetProvider(HttpAssetProvider httpAssetProvider)

    • saveProperty

      public boolean saveProperty(Property property)
      Save a property to the database. This is either an insert or an update operation.

    • claimVersion

      public VersionImpl claimVersion(String mpId)
      Claim a new version for media package mpId.

    • saveSnapshot

      public SnapshotDto saveSnapshot(String orgId, PartialMediaPackage pmp, Date archivalDate, VersionImpl version, Availability availability, String storageId, String owner)
      Save a snapshot and all of its assets.

    • setStorageLocation

      public void setStorageLocation(Snapshot snapshot, String storageId)

    • setStorageLocation

      public void setStorageLocation(VersionImpl version, String mpId, String storageId)

    • setAssetStorageLocation

      public void setAssetStorageLocation(VersionImpl version, String mpId, String mpeId, String storageId)

    • setAvailability

      public int setAvailability(VersionImpl version, String mpId, Availability availability)

    • getAsset

      public Optional<AssetDtos.Medium> getAsset(VersionImpl version, String mpId, String mpeId)
      Get an asset. If no version is specified return the latest version.
      Returns:
      the asset or none, if no asset can be found

    • getSnapshot

      public Optional<SnapshotDtos.Medium> getSnapshot(VersionImpl version, String mpId)

    • deleteProperties

      public int deleteProperties(String mediaPackageId)
      Delete all properties for a given media package identifier
      Parameters:
      mediaPackageId - Media package identifier
      Returns:
      Number of deleted rows

    • deleteProperties

      public int deleteProperties(String mediaPackageId, String namespace)
      Delete all properties for a given media package identifier and namespace.
      Parameters:
      mediaPackageId - Media package identifier
      namespace - A namespace prefix to use for deletion
      Returns:
      Number of deleted rows

    • snapshotExists

      public boolean snapshotExists(String mediaPackageId)
      Check if any snapshot with the given media package identifier exists.
      Parameters:
      mediaPackageId - The media package identifier to check for
      Returns:
      If a snapshot exists for the given media package

    • snapshotExists

      public boolean snapshotExists(String mediaPackageId, String organization)
      Check if any snapshot with the given media package identifier exists.
      Parameters:
      mediaPackageId - The media package identifier to check for
      organization - The organization to filter for
      Returns:
      If a snapshot exists for the given media package

    • selectProperties

      public List<Property> selectProperties(String mediaPackageId, String namespace)
      Select all properties for a specific media package.
      Parameters:
      mediaPackageId - Media package identifier to check for
      namespace - Namespace to limit the search to
      Returns:
      List of properties

    • countEvents

      public long countEvents(String organization)
      Count events with snapshots in the asset manager
      Parameters:
      organization - An organization to count in
      Returns:
      Number of events

    • countSnapshots

      public long countSnapshots(String organization)
      Count events with snapshots in the asset manager
      Parameters:
      organization - An organization to count in
      Returns:
      Number of events

    • countAssets

      public long countAssets()

    • countProperties

      public long countProperties()

    • findAssetByChecksumAndStoreAndOrg

      public Optional<AssetDtos.Full> findAssetByChecksumAndStoreAndOrg(String checksum, String storeId, String orgId)

    • getLatestSnapshot

      public Optional<Snapshot> getLatestSnapshot(String mediaPackageId)

    • getLatestSnapshot

      public Optional<Snapshot> getLatestSnapshot(String mediaPackageId, String orgId)

    • getMediaPackage

      public Optional<MediaPackage> getMediaPackage(String mediaPackageId)

    • getMediaPackage

      public Optional<MediaPackage> getMediaPackage(String mediaPackageId, String orgId)

    • getSnapshots

      public List<Snapshot> getSnapshots(String mediaPackageId)

    • getSnapshots

      public List<Snapshot> getSnapshots(String mediaPackageId, String orgId)

    • getSnapshots

      public List<Snapshot> getSnapshots(String mediaPackageId, String orgId, String orderByVersion)

    • deleteSnapshots

      public int deleteSnapshots(String mediaPackageId, String orgId)

    • deleteAllButLatestSnapshot

      public int deleteAllButLatestSnapshot(String mediaPackageId, String orgId)

    • getSnapshotsByMpIdAndVersion

      public List<Snapshot> getSnapshotsByMpIdAndVersion(String mediaPackageId, Long version, String orgId)

    • getSnapshotsByDateOrderByMpId

      public List<Snapshot> getSnapshotsByDateOrderByMpId(Date start, Date end, String orgId)

    • getSnapshotsByMpdIdAndDate

      public List<Snapshot> getSnapshotsByMpdIdAndDate(String mediaPackageId, Date start, Date end, String orgId)

    • getSnapshotsByMpdIdAndDate

      public List<Snapshot> getSnapshotsByMpdIdAndDate(String mediaPackageId, Date start, Date end, String orgId, String orderByVersion)

    • getSnapshotsByNotStorageAndDate

      public List<Snapshot> getSnapshotsByNotStorageAndDate(String storageId, Date start, Date end, String orgId)

    • getSnapshotsBySeries

      public List<Snapshot> getSnapshotsBySeries(String seriesId, String orgId)

    • getLatestSnapshotsByMediaPackageIds

      public List<Snapshot> getLatestSnapshotsByMediaPackageIds(Collection mediaPackageIds, String orgId)

    • getSnapshot

      public Optional<Snapshot> getSnapshot(String mediaPackageId, String orgId, Long version)

    • getSnapshotsForIndexRebuild

      public List<Snapshot> getSnapshotsForIndexRebuild(int offset, int limit)

    • getVersionsByMediaPackage

      public List<Long> getVersionsByMediaPackage(String mediaPackageId, String orgId)

    • insidePersistenceContextCheck

      public static <A> A insidePersistenceContextCheck(A a)