com.atlassian.confluence.pages.persistence.dao.hibernate

Class AbstractHibernateAttachmentDao

java.lang.Object

org.springframework.dao.support.DaoSupport

com.atlassian.confluence.core.persistence.hibernate.HibernateObjectDao

com.atlassian.confluence.core.persistence.hibernate.VersionedHibernateObjectDao<Attachment>

com.atlassian.confluence.pages.persistence.dao.hibernate.AbstractHibernateAttachmentDao

All Implemented Interfaces:

ObjectDao, VersionedObjectDao, AttachmentDao, FlushableCachingDao, org.springframework.beans.factory.InitializingBean

Direct Known Subclasses:

NonTransactionalHibernateAttachmentDao, TransactionalHibernateAttachmentDao

public abstract class AbstractHibernateAttachmentDao
extends VersionedHibernateObjectDao<Attachment>
implements AttachmentDao, FlushableCachingDao

Abstract class that defines the basic methods necessary for saving Attachments to a database.

The location of the storage of attachment data is dependent on the AttachmentDataDao set for this class. In some cases, since the removal of attachments is destructive, different implementations may wish to perform the removal of data in a different order. Subclasses will have to implement the #removeDataForAttachment(Attachment attachment) method.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	AbstractHibernateAttachmentDao.IntraHibernateAttachmentCopier This attachment copier will copy attachment streams from the current instance of AbstractHibernateAttachmentDao to another.
class	AbstractHibernateAttachmentDao.IntraHibernateAttachmentMigrator This attachment migrator will migrate attachment streams from the current instance of AbstractHibernateAttachmentDao to another.

Nested classes/interfaces inherited from class com.atlassian.confluence.core.persistence.hibernate.HibernateObjectDao

HibernateObjectDao.Cacheability

Nested classes/interfaces inherited from interface com.atlassian.confluence.pages.persistence.dao.AttachmentDao

AttachmentDao.AttachmentCopier, AttachmentDao.AttachmentMigrator

Field Summary

Fields

Modifier and Type	Field and Description
protected AttachmentDataDao	dataDao

Fields inherited from class com.atlassian.confluence.core.persistence.hibernate.VersionedHibernateObjectDao

cacheFactory, confluenceUserDao

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

logger

Fields inherited from interface bucket.core.persistence.ObjectDao

NON_CACHEABLE

Constructor Summary

Constructors

Constructor and Description
AbstractHibernateAttachmentDao()

Method Summary

Modifier and Type	Method and Description
void	afterMigrationFrom() This implementation removes all Attachments and passes the migration tasks onto the AttachmentDataDao
int	countLatestVersionsOfAttachments(ContentEntityObject content)
int	countLatestVersionsOfAttachmentsWithAnyStatus(ContentEntityObject content)
List<Attachment>	findAllVersions(Attachment attachment)
List<Attachment>	findAllVersions(Long id)
List<Long>	findLatestVersionIds()
List<Long>	findLatestVersionIds(List<Space> spacesToInclude) Same as findLatestVersionIdsIterator() but only gets the ids matching the list of spaces requested.
Iterator<Long>	findLatestVersionIdsIterator()
Iterator<Long>	findLatestVersionIdsIterator(List<Space> spacesToInclude) Same as findLatestVersionIdsIterator() but only gets the ids matching the list of spaces requested.
void	flush() This implementation flushes the Hibernate session.
Attachment	getAttachment(ContentEntityObject content, String fileName, int version) Return the attachment on the specified content with the given filename and version.
InputStream	getAttachmentData(Attachment attachment) Retrieves the InputStream representing the data for attachment
InputStream	getAttachmentData(Attachment attachment, Optional<RangeRequest> range) Retrieves the InputStream representing the specified range of data for attachment
AttachmentDataStorageType	getBackingStorageType() Returns the backing storage type.
Attachment	getById(long id) Returns the attachment with the given persistent ID.
List<Attachment>	getByIds(List<Long> ids) Returns a list of attachments matching the given list of IDs.
AttachmentDao.AttachmentCopier	getCopier(AttachmentDao destinationDao) Get a copier object to copy attachments between data stores
AttachmentDataDao	getDataDao()
static AttachmentDao	getInstance(AttachmentDataDao attachmentDataDao) Returns the correct instance of AttachmentDao for the AttachmentDataDao that is given.
List<Attachment>	getLastAddedVersionsOf(Attachment attachment) Retrieves all the last added versions for each user who has added a version of the attachment That is, if a user has added multiple versions, only the latest added version will be added to the list returned.
Attachment	getLatestAttachment(ContentEntityObject content, String fileName) Return the latest version of the attachment on the specified content with the given filename.
List<Attachment>	getLatestVersionsOfAttachments(ContentEntityObject content) Retrieves the latest versions of all attachments to ceo
PageResponse<Attachment>	getLatestVersionsOfAttachments(ContentEntityObject ceo, LimitedRequest request, com.google.common.base.Predicate<? super Attachment> predicate) Retrieves a paginated list of the latest version of attachments to the ceo filtered by the predicate
List<Attachment>	getLatestVersionsOfAttachmentsForMultipleCeos(Iterable<? extends ContentEntityObject> contentEntityObjects) Retrieves the latest versions of all attachments for all CEOs provided
List<Attachment>	getLatestVersionsOfAttachmentsWithAnyStatus(ContentEntityObject content) Retrieves the latest versions of all attachments to ceo (including trashed)
AttachmentDao.AttachmentMigrator	getMigrator(AttachmentDao destinationDao) Get a migrator object to migrate attachments between attachment datastores.
Class	getPersistentClass()
Map<Long,Long>	getRemappedAttachmentIds() Gets a list of remapped attachment IDs.
boolean	isAttachmentPresent(Attachment attachment) Check that an attachment exists
void	moveAttachment(Attachment latestVersion, Attachment oldAttachment, ContentEntityObject newContent) Moves an Attachment to a new file name or content object
protected void	overwriteMetaData(Attachment sourceAttachment, Attachment targetAttachment) Overwrites attachment meta data.
void	prepareForMigrationTo() This implementation removes the contents of the table and passes the migration tasks onto the AttachmentDataDao
protected void	removeAllAttachmentVersions(Attachment latestVersion, ContentEntityObject content)
protected void	removeAttachment(Attachment attachment, ContentEntityObject content) Severs the connection between attachment and content, and removes the attachment from the database
void	removeAttachmentVersionFromServer(Attachment attachmentVersionToBeRemoved) Removes an attachment version
protected abstract void	removeAttachmentVersionFromServer(Attachment attachmentVersionToBeRemoved, Attachment previousAttachmentVersion)
protected void	removeMetaData(Attachment attachment) Removes attachment meta data.
void	replaceAttachmentData(Attachment attachment, InputStream attachmentData) Sets the attachment data for attachment
void	saveNewAttachment(Attachment attachment, InputStream attachmentData) Saves a new attachment
void	saveNewAttachmentVersion(Attachment attachment, Attachment previousVersion, InputStream attachmentData) This implementation saves the Attachment and its previous version to the VersionedHibernateObjectDao.
void	updateAttachment(Attachment attachment) Update an existing attachment without creating a new version

Methods inherited from class com.atlassian.confluence.core.persistence.hibernate.VersionedHibernateObjectDao

findAllSorted, findLatestVersionsCount, findLatestVersionsCount, findLatestVersionsIterator, findLatestVersionsIterator, findNamedQueryStringParams, findNamedQueryStringParams, save, setCacheFactory, setConfluenceUserDao, updateModificationData

Methods inherited from class com.atlassian.confluence.core.persistence.hibernate.HibernateObjectDao

applyTransactionTimeout, applyTransactionTimeout, checkDaoConfig, createHibernateTemplate, findAll, findAllSorted, findByClassIds, findNamedQuery, findNamedQuery, findNamedQuery, findNamedQuery, findNamedQuery, findNamedQueryStringParam, findNamedQueryStringParam, findNamedQueryStringParam, findNamedQueryStringParam, findNamedQueryStringParam, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findSingleObject, getByClassId, getCountResult, getHibernateTemplate, getSession, getSessionFactory, index, refresh, reIndex, remove, replicate, save, saveRaw, setHibernateTemplate, setIndexer, setSessionFactory, unIndex, uniqueResult

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

afterPropertiesSet, initDao

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.atlassian.confluence.pages.persistence.dao.AttachmentDao

findAll, findLatestVersionsIterator, removeAttachmentFromServer

Methods inherited from interface bucket.core.persistence.ObjectDao

findAll, findAllSorted, findByClassIds, refresh, remove, replicate, save, saveRaw

Field Detail

dataDao

protected AttachmentDataDao dataDao

Constructor Detail

AbstractHibernateAttachmentDao

public AbstractHibernateAttachmentDao()

Method Detail

getDataDao

public AttachmentDataDao getDataDao()

Specified by:

getDataDao in interface AttachmentDao

getInstance

public static AttachmentDao getInstance(AttachmentDataDao attachmentDataDao)

Returns the correct instance of AttachmentDao for the AttachmentDataDao that is given.

Parameters:

attachmentDataDao - the AttachmentDataDao that should be used

Returns:

a matching AttachmentDao instance

Throws:

IllegalArgumentException - if dataDao is not supported

getPersistentClass

public Class getPersistentClass()

Specified by:

getPersistentClass in interface ObjectDao

getLatestVersionsOfAttachments

public List<Attachment> getLatestVersionsOfAttachments(ContentEntityObject content)

Description copied from interface: AttachmentDao

Retrieves the latest versions of all attachments to ceo

Specified by:

getLatestVersionsOfAttachments in interface AttachmentDao

Parameters:

content - the content to look up attachments

Returns:

a List of Attachment objects

See Also:

AttachmentDao.countLatestVersionsOfAttachments(com.atlassian.confluence.core.ContentEntityObject)

getLatestVersionsOfAttachmentsForMultipleCeos

public List<Attachment> getLatestVersionsOfAttachmentsForMultipleCeos(Iterable<? extends ContentEntityObject> contentEntityObjects)

Description copied from interface: AttachmentDao

Retrieves the latest versions of all attachments for all CEOs provided

Specified by:

getLatestVersionsOfAttachmentsForMultipleCeos in interface AttachmentDao

Parameters:

contentEntityObjects - CEOs to retrieve attachements for

Returns:

a List of Attachment objects

getLatestVersionsOfAttachmentsWithAnyStatus

public List<Attachment> getLatestVersionsOfAttachmentsWithAnyStatus(ContentEntityObject content)

Description copied from interface: AttachmentDao

Retrieves the latest versions of all attachments to ceo (including trashed)

Specified by:

getLatestVersionsOfAttachmentsWithAnyStatus in interface AttachmentDao

Parameters:

content - the content to look up attachments

Returns:

a List of Attachment objects

See Also:

AttachmentDao.countLatestVersionsOfAttachments(com.atlassian.confluence.core.ContentEntityObject)

getLatestVersionsOfAttachments

public PageResponse<Attachment> getLatestVersionsOfAttachments(ContentEntityObject ceo,
                                                               LimitedRequest request,
                                                               com.google.common.base.Predicate<? super Attachment> predicate)

Description copied from interface: AttachmentDao

Retrieves a paginated list of the latest version of attachments to the ceo filtered by the predicate

Specified by:

getLatestVersionsOfAttachments in interface AttachmentDao

Parameters:

ceo - the content to find attachments on

request - the pagination request

predicate - a predicate to filter the results by

Returns:

a paginated list of attachments

countLatestVersionsOfAttachments

public int countLatestVersionsOfAttachments(ContentEntityObject content)

Specified by:

countLatestVersionsOfAttachments in interface AttachmentDao

Parameters:

content - the content object

Returns:

the number of current attachments on a content object

See Also:

AttachmentDao.getLatestVersionsOfAttachments(com.atlassian.confluence.core.ContentEntityObject)

countLatestVersionsOfAttachmentsWithAnyStatus

public int countLatestVersionsOfAttachmentsWithAnyStatus(ContentEntityObject content)

Specified by:

countLatestVersionsOfAttachmentsWithAnyStatus in interface AttachmentDao

Parameters:

content - the content object

Returns:

the number of current attachments on a content object (including trashed)

See Also:

AttachmentDao.getLatestVersionsOfAttachmentsWithAnyStatus(com.atlassian.confluence.core.ContentEntityObject)

getById

public Attachment getById(long id)

Description copied from interface: AttachmentDao

Returns the attachment with the given persistent ID. Returns null if no such attachment exists.

Specified by:

getById in interface AttachmentDao

Parameters:

id - the persistent ID of the attachment to retrieve

Returns:

the attachment with the given ID, or null if no attachment exists with the provided ID.

getByIds

public List<Attachment> getByIds(List<Long> ids)

Description copied from interface: AttachmentDao

Returns a list of attachments matching the given list of IDs. Returns an empty list if no such attachments exist. In the case where some IDs exist and some don't, only the existing Attachments will be returned.

Specified by:

getByIds in interface AttachmentDao

Parameters:

ids - list of IDs to retrieve

Returns:

the attachments with the given IDs, or an empty list if no attachments exist with the provided IDs.

getAttachment

public Attachment getAttachment(ContentEntityObject content,
                                String fileName,
                                int version)

Description copied from interface: AttachmentDao

Return the attachment on the specified content with the given filename and version. Returns null if no such attachment exists.

Note: unlike AttachmentManager.getAttachment(ContentEntityObject, String, int), this method does not accept zero as a special flag to indicate the latest version of an attachment. To retrieve the latest version of an attachment, use AttachmentDao.getLatestAttachment(ContentEntityObject, String).

Specified by:

getAttachment in interface AttachmentDao

Parameters:

content - the content to find the attachment on

fileName - the file name of the attachment, treated case-insensitively

version - the version of the attachment

Returns:

the attachment with the given name and version attached to that content, or null if the attachment does not exist.

getLatestAttachment

public Attachment getLatestAttachment(ContentEntityObject content,
                                      String fileName)

Description copied from interface: AttachmentDao

Return the latest version of the attachment on the specified content with the given filename. Returns null if no attachment with that name on the content exists.

Specified by:

getLatestAttachment in interface AttachmentDao

Parameters:

content - the content to find the attachment on

fileName - the file name of the attachment

Returns:

the latest version of attachment with the given name attached to that content, or null if the attachment does not exist.

getLastAddedVersionsOf

public List<Attachment> getLastAddedVersionsOf(Attachment attachment)

Description copied from interface: AttachmentDao

Retrieves all the last added versions for each user who has added a version of the attachment That is, if a user has added multiple versions, only the latest added version will be added to the list returned. Result will be sorted with the earliest version coming first.

Specified by:

getLastAddedVersionsOf in interface AttachmentDao

Parameters:

attachment - attachment (must be the latest version)

Returns:

the last added versions for each user who has added a version of the attachment

findAllVersions

public List<Attachment> findAllVersions(Attachment attachment)

Specified by:

findAllVersions in interface AttachmentDao

findAllVersions

public List<Attachment> findAllVersions(Long id)

getAttachmentData

public InputStream getAttachmentData(Attachment attachment)
                              throws AttachmentDataNotFoundException

Description copied from interface: AttachmentDao

Retrieves the InputStream representing the data for attachment

Specified by:

getAttachmentData in interface AttachmentDao

Parameters:

attachment - the attachment whose data will be returned

Returns:

InputStream of the data

Throws:

AttachmentDataNotFoundException - if the data could not be found

getAttachmentData

public InputStream getAttachmentData(Attachment attachment,
                                     Optional<RangeRequest> range)
                              throws AttachmentDataNotFoundException

Description copied from interface: AttachmentDao

Retrieves the InputStream representing the specified range of data for attachment

Specified by:

getAttachmentData in interface AttachmentDao

Parameters:

attachment - the attachment whose data will be returned

range - the range of data to retrieve. See ByteRanges

Returns:

InputStream of the data

Throws:

AttachmentDataNotFoundException - if the data could not be found

saveNewAttachment

public void saveNewAttachment(Attachment attachment,
                              InputStream attachmentData)

Description copied from interface: AttachmentDao

Saves a new attachment

Specified by:

saveNewAttachment in interface AttachmentDao

Parameters:

attachment - the Attachment to be saved

attachmentData - the attachment data to be saved

saveNewAttachmentVersion

public void saveNewAttachmentVersion(Attachment attachment,
                                     Attachment previousVersion,
                                     InputStream attachmentData)

This implementation saves the Attachment and its previous version to the VersionedHibernateObjectDao.

Due to the way Hibernate works, attachment must be the current Hibernate-managed object (without its version or ID having being changed), and previousVersion should be a clone of the unmodified Attachment object.

Specified by:

saveNewAttachmentVersion in interface AttachmentDao

Parameters:

attachment - the attachment to be saved, a clone of the old one

previousVersion - the old attachment, which must be unmodified

attachmentData - the new attachment data

isAttachmentPresent

public boolean isAttachmentPresent(Attachment attachment)

Description copied from interface: AttachmentDao

Check that an attachment exists

Specified by:

isAttachmentPresent in interface AttachmentDao

Parameters:

attachment - the Attachment to be checked

moveAttachment

public void moveAttachment(Attachment latestVersion,
                           Attachment oldAttachment,
                           ContentEntityObject newContent)

Description copied from interface: AttachmentDao

Moves an Attachment to a new file name or content object

This method assumes that the filename and/or content of the attachment (and its previous versions) have already been updated.

Specified by:

moveAttachment in interface AttachmentDao

Parameters:

latestVersion - the Attachment to be moved

oldAttachment - the Attachment before it has been updated

newContent - the new content attachment belongs to

removeAttachment

protected void removeAttachment(Attachment attachment,
                                ContentEntityObject content)

Severs the connection between attachment and content, and removes the attachment from the database

Parameters:

attachment - the attachment to remove

content - the content to remove the attachment from

removeAttachmentVersionFromServer

public final void removeAttachmentVersionFromServer(Attachment attachmentVersionToBeRemoved)

Description copied from interface: AttachmentDao

Removes an attachment version

Specified by:

removeAttachmentVersionFromServer in interface AttachmentDao

Parameters:

attachmentVersionToBeRemoved - the Attachment version to be removed

removeAttachmentVersionFromServer

protected abstract void removeAttachmentVersionFromServer(Attachment attachmentVersionToBeRemoved,
                                                          @Nullable
                                                          Attachment previousAttachmentVersion)

removeMetaData

protected void removeMetaData(Attachment attachment)

Removes attachment meta data.

The steps for removing attachment meta data are

1. the attachment object being de-referenced from its container (e.g. page)
2. the original version (reference to the latest version) to be set to null
3. the row removal to be recorded
4. the un-index to be queued

Parameters:

attachment - the attachment version to be removed

overwriteMetaData

protected void overwriteMetaData(Attachment sourceAttachment,
                                 Attachment targetAttachment)

Overwrites attachment meta data.

The latest version of an attachment inherits the EntityObject.getId() of the first version, that means the identifier which was given to the first version gets replaced by a new one if a second version gets uploaded, and the second version inherits the identifier of the first one. Thus using the identifier of the latest version in the frontend is guaranteed to never become stale.

Thus

1. removing a historical version is "simple", as the only thing that references it is its container (e.g. page)
2. removing the current version is "complex", as this requires the previous version to be "promoted" to the current version

The corresponding row of sourceAttachment in the ATTACHMENTS table will be removed, and its data will be used to overwrite the corresponding row of targetAttachment. Calling this method assumes that you removed all tuples having a referential constraint on the sourceAttachment's row ahead, since the state of the Hibernate session will be synchronised with the database several times as part of this execution. The sourceAttachment object will become untracked by Hibernate as a result of this call, and it will have the id of the targetAttachment, thus anything relying on the old state should have cached it ahead (e.g. shallow Attachment.clone()).

Parameters:

sourceAttachment - the attachment version to be moved

targetAttachment - the attachment version to be overwritten

getBackingStorageType

public AttachmentDataStorageType getBackingStorageType()

Description copied from interface: AttachmentDao

Returns the backing storage type.

Specified by:

getBackingStorageType in interface AttachmentDao

Returns:

the backing storage type

See Also:

AttachmentDataDao.getStorageType()

removeAllAttachmentVersions

protected void removeAllAttachmentVersions(Attachment latestVersion,
                                           ContentEntityObject content)

getMigrator

public AttachmentDao.AttachmentMigrator getMigrator(AttachmentDao destinationDao)

Description copied from interface: AttachmentDao

Get a migrator object to migrate attachments between attachment datastores.

To be used when switching datastore implementations

Specified by:

getMigrator in interface AttachmentDao

Parameters:

destinationDao - dao to move attachments to

Returns:

A migrator

getCopier

public AttachmentDao.AttachmentCopier getCopier(AttachmentDao destinationDao)

Description copied from interface: AttachmentDao

Get a copier object to copy attachments between data stores

The source data store will remain untouched

Specified by:

getCopier in interface AttachmentDao

Parameters:

destinationDao - dao to copy attachments to

Returns:

A copier

updateAttachment

public void updateAttachment(Attachment attachment)

Description copied from interface: AttachmentDao

Update an existing attachment without creating a new version

Specified by:

updateAttachment in interface AttachmentDao

prepareForMigrationTo

public void prepareForMigrationTo()

This implementation removes the contents of the table and passes the migration tasks onto the AttachmentDataDao

Specified by:

prepareForMigrationTo in interface AttachmentDao

afterMigrationFrom

public void afterMigrationFrom()

This implementation removes all Attachments and passes the migration tasks onto the AttachmentDataDao

Specified by:

afterMigrationFrom in interface AttachmentDao

getRemappedAttachmentIds

public Map<Long,Long> getRemappedAttachmentIds()

Description copied from interface: AttachmentDao

Gets a list of remapped attachment IDs. The key is the old ID and the value is the new ID.

Specified by:

getRemappedAttachmentIds in interface AttachmentDao

Returns:

A map where the key is the original ID and the value is the new ID.

replaceAttachmentData

public void replaceAttachmentData(Attachment attachment,
                                  InputStream attachmentData)

Description copied from interface: AttachmentDao

Sets the attachment data for attachment

This method will overwrite any existing data for the attachment version.

Specified by:

replaceAttachmentData in interface AttachmentDao

Parameters:

attachment - Attachment the data belongs to

attachmentData - the data to save

flush

public void flush()

This implementation flushes the Hibernate session.

Specified by:

flush in interface FlushableCachingDao

findLatestVersionIdsIterator

public Iterator<Long> findLatestVersionIdsIterator()

findLatestVersionIdsIterator

public Iterator<Long> findLatestVersionIdsIterator(List<Space> spacesToInclude)

Same as findLatestVersionIdsIterator() but only gets the ids matching the list of spaces requested.

Parameters:

spacesToInclude - list of spaces to include. The length of this list should not exceed the allowed maximum value of an "in" clause.

Returns:

a list of the latest versions of attachments in the requested spaces

findLatestVersionIds

public List<Long> findLatestVersionIds()

findLatestVersionIds

public List<Long> findLatestVersionIds(List<Space> spacesToInclude)

Same as findLatestVersionIdsIterator() but only gets the ids matching the list of spaces requested.

Parameters:

spacesToInclude - list of spaces to include. The length of this list should not exceed the allowed maximum value of an "in" clause.

Returns:

a list of the ids of the latest versions of attachments in the requested spaces