com.atlassian.confluence.pages.persistence.dao.filesystem.strategy

Class DualAttachmentDataFileSystemPrimaryLocal

java.lang.Object

com.atlassian.confluence.pages.persistence.dao.filesystem.strategy.DualAttachmentDataFileSystemPrimaryLocal

All Implemented Interfaces:

AttachmentDataFileSystem

public class DualAttachmentDataFileSystemPrimaryLocal
extends Object
implements AttachmentDataFileSystem

An implementation of AttachmentDataFileSystem which stores the attachment data in both local file system using HierarchicalMultiStreamAttachmentDataFileSystem and remote FileStore using FileStoreAttachmentDataFileSystem.

This strategy ensures local file system is the primary storage: a WRITE operation is only successful if WRITE to local file system is successful.

Operations that require a READ/WRITE/DELETE to FileStore will be run in a background thread with a new hibernate transaction. Other transactions that don't request to FileStore will be run in the same transactional thread.

Since:

5.9

Constructor Summary

Constructors

Constructor and Description
DualAttachmentDataFileSystemPrimaryLocal(AttachmentDataFileSystem localAttachmentDataFileSystem, AttachmentDataFileSystem cloudAttachmentDataFileSystem, org.springframework.transaction.PlatformTransactionManager transactionManager, SynchronizationManager synchronizationManager, com.atlassian.spring.container.LazyComponentReference<AttachmentManager> attachmentManager)

Method Summary

Modifier and Type	Method and Description
boolean	dataExistsForAttachment(Attachment attachment) Indicates whether the filesystem contains data for the given attachment
void	deleteAllAttachmentVersions(Attachment attachment, ContentEntityObject contentEntity) Delete all data corresponding to all versions of the given attachment
void	deleteSingleAttachmentVersion(Attachment attachment, ContentEntityObject contentEntity) Delete the data corresponding to a single attachment version
void	deleteSingleAttachmentVersion(Attachment attachment, ContentEntityObject contentEntity, AttachmentDataStreamType dataStreamType) Delete the data of the specified stream type corresponding to a single attachment version
AttachmentDataStream	getAttachmentData(Attachment attachment, AttachmentDataStreamType dataStreamType) Fetches the data for a given attachment version and data stream type
AttachmentDataStream	getAttachmentData(Attachment attachment, AttachmentDataStreamType dataStreamType, Optional<RangeRequest> range) Fetches the specified range of data for a given attachment version and data stream type
void	moveAttachment(Attachment oldAttachment, Attachment newAttachment, ContentEntityObject newContentEntity) Move all data relating to one attachment to a new directory corresponding to the given new attachment and content entity.
void	moveAttachments(ContentEntityObject contentEntity, Space oldSpace, Space newSpace) Move all data for all versions of all attachments corresponding to the given content entity in the given space, to the same entity in a different space.
void	moveDataForAttachmentVersion(Attachment sourceAttachmentVersion, Attachment targetAttachmentVersion) Move the data associated with one attachment version, to being associated with a different attachment version
void	prepareForMigrationTo() Prepare the data store for a migration from another type of data store.
boolean	saveAttachmentData(Attachment attachment, AttachmentDataStream dataStream, boolean overwrite) Save new data corresponding to the given attachment.

Methods inherited from class java.lang.Object

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

Constructor Detail

DualAttachmentDataFileSystemPrimaryLocal

public DualAttachmentDataFileSystemPrimaryLocal(AttachmentDataFileSystem localAttachmentDataFileSystem,
                                                AttachmentDataFileSystem cloudAttachmentDataFileSystem,
                                                org.springframework.transaction.PlatformTransactionManager transactionManager,
                                                SynchronizationManager synchronizationManager,
                                                com.atlassian.spring.container.LazyComponentReference<AttachmentManager> attachmentManager)

Method Detail

saveAttachmentData

public boolean saveAttachmentData(Attachment attachment,
                                  AttachmentDataStream dataStream,
                                  boolean overwrite)

Description copied from interface: AttachmentDataFileSystem

Save new data corresponding to the given attachment.

Specified by:

saveAttachmentData in interface AttachmentDataFileSystem

Parameters:

attachment - The attachment to which the data should be associated

dataStream - The new data

overwrite - If true, any existing data will be overwritten. If false, does nothing if data already exists.

Returns:

true if the data was written, false otherwise (e.g. no overwrite)

getAttachmentData

public AttachmentDataStream getAttachmentData(Attachment attachment,
                                              AttachmentDataStreamType dataStreamType)

Description copied from interface: AttachmentDataFileSystem

Fetches the data for a given attachment version and data stream type

Specified by:

getAttachmentData in interface AttachmentDataFileSystem

Parameters:

attachment - The attachment version for which the data is to be fetched

dataStreamType - The type of the data stream to be fetched

Returns:

The AttachmentDataStream containing the result

getAttachmentData

public AttachmentDataStream getAttachmentData(Attachment attachment,
                                              AttachmentDataStreamType dataStreamType,
                                              Optional<RangeRequest> range)

Description copied from interface: AttachmentDataFileSystem

Fetches the specified range of data for a given attachment version and data stream type

Specified by:

getAttachmentData in interface AttachmentDataFileSystem

Parameters:

attachment - The attachment version for which the data is to be fetched

dataStreamType - The type of the data stream to be fetched

range - The range of the data stream to be fetched

Returns:

The AttachmentDataStream containing the result

dataExistsForAttachment

public boolean dataExistsForAttachment(Attachment attachment)

Description copied from interface: AttachmentDataFileSystem

Indicates whether the filesystem contains data for the given attachment

Specified by:

dataExistsForAttachment in interface AttachmentDataFileSystem

deleteSingleAttachmentVersion

public void deleteSingleAttachmentVersion(Attachment attachment,
                                          ContentEntityObject contentEntity)

Description copied from interface: AttachmentDataFileSystem

Delete the data corresponding to a single attachment version

Specified by:

deleteSingleAttachmentVersion in interface AttachmentDataFileSystem

Parameters:

attachment - The attachment whose data should be deleted

contentEntity - The content entity associated with the attachment

deleteSingleAttachmentVersion

public void deleteSingleAttachmentVersion(Attachment attachment,
                                          ContentEntityObject contentEntity,
                                          AttachmentDataStreamType dataStreamType)

Description copied from interface: AttachmentDataFileSystem

Delete the data of the specified stream type corresponding to a single attachment version

Specified by:

deleteSingleAttachmentVersion in interface AttachmentDataFileSystem

Parameters:

attachment - The attachment whose data should be deleted

contentEntity - The content entity associated with the attachment

dataStreamType - The attachment stream type

deleteAllAttachmentVersions

public void deleteAllAttachmentVersions(Attachment attachment,
                                        ContentEntityObject contentEntity)

Description copied from interface: AttachmentDataFileSystem

Delete all data corresponding to all versions of the given attachment

Specified by:

deleteAllAttachmentVersions in interface AttachmentDataFileSystem

Parameters:

attachment - the attachment whose data is to be deleted

contentEntity - The content entity associated with the attachment

moveAttachment

public void moveAttachment(Attachment oldAttachment,
                           Attachment newAttachment,
                           ContentEntityObject newContentEntity)

Description copied from interface: AttachmentDataFileSystem

Move all data relating to one attachment to a new directory corresponding to the given new attachment and content entity.

Specified by:

moveAttachment in interface AttachmentDataFileSystem

Parameters:

oldAttachment - The attachment whose data is to be moved

newAttachment - The attachment to which the data should be moved to

newContentEntity - The content entity corresponding to the new attachment

moveDataForAttachmentVersion

public void moveDataForAttachmentVersion(Attachment sourceAttachmentVersion,
                                         Attachment targetAttachmentVersion)

Description copied from interface: AttachmentDataFileSystem

Move the data associated with one attachment version, to being associated with a different attachment version

Specified by:

moveDataForAttachmentVersion in interface AttachmentDataFileSystem

Parameters:

sourceAttachmentVersion - The attachment version containing the data

targetAttachmentVersion - The attachment version to which the data should be moved

moveAttachments

public void moveAttachments(ContentEntityObject contentEntity,
                            Space oldSpace,
                            Space newSpace)

Description copied from interface: AttachmentDataFileSystem

Move all data for all versions of all attachments corresponding to the given content entity in the given space, to the same entity in a different space.

Specified by:

moveAttachments in interface AttachmentDataFileSystem

Parameters:

contentEntity - The content entity whose attachment data is to be moved

oldSpace - The original space of the content entity

newSpace - The new space of the content entity

prepareForMigrationTo

public void prepareForMigrationTo()

Description copied from interface: AttachmentDataFileSystem

Prepare the data store for a migration from another type of data store.

Specified by:

prepareForMigrationTo in interface AttachmentDataFileSystem