Package com.atlassian.confluence.impl.backuprestore.dao

Class DefaultBackupRestoreJobDao

java.lang.Object

com.atlassian.confluence.impl.backuprestore.dao.DefaultBackupRestoreJobDao

All Implemented Interfaces:

BackupRestoreJobDao

public class DefaultBackupRestoreJobDao
extends Object
implements BackupRestoreJobDao

Dao for backup/restore jobs.

Since:

9.3

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CANCEL_TIME
static final String	EXISTING_EXPECTED_STATE
static final String	FINISH_PROCESSING_TIME
static final String	ID
static final String	NEW_STATE
static final String	START_PROCESSING_TIME
static final String	STATISTICS
static final String	TERMINATOR

Constructor Summary

Constructors

Constructor	Description
DefaultBackupRestoreJobDao(@NonNull org.hibernate.SessionFactory sessionFactory)

Method Summary

Modifier and Type	Method	Description
boolean	cancelQueuedJobWithOptimisticLock(long jobId, String terminator)	Cancels the job only if it's state was not modified.
boolean	cancelRunningJobWithOptimisticLock(long jobId, String terminator)	Cancels the job only if it's state was not modified.
void	delete(long jobId)	Deletes given job with its settings and statistics
List<BackupRestoreJob>	findJobs(BackupRestoreJobsSearchFilter backupRestoreJobsSearchFilter)
List<BackupRestoreJob>	findJobsWithExpiredZips()	This gets all jobs where the file delete time is expired and the backup zip file still exists
BackupRestoreJob	getById(Long jobId)
BackupRestoreJob	getNextActiveJob()
BackupRestoreJob	getNextJobForProcessing()
BackupRestoreJobSettingsRecord	getSettingsById(long id)
BackupRestoreJobStatisticsRecord	getStatisticsById(long id)
BackupRestoreJob	save(BackupRestoreJob job)
Long	save(BackupRestoreJobSettingsRecord backupRestoreJobSettingsRecord)
void	save(BackupRestoreJobStatisticsRecord statisticsRecord)
BackupRestoreJob	saveAndKeepId(BackupRestoreJob job)	Regular save generates the new id if the object does not exist.
boolean	startProcessingJobWithOptimisticLock(long jobId)	Changes jobs state to PROCESSING only if it's state was not modified.
void	update(BackupRestoreJob job)
void	updateInNewTransaction(BackupRestoreJob job)
int	updateStatistics(long jobId, String statistics)

Methods inherited from class java.lang.Object

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

Field Details

NEW_STATE

public static final String NEW_STATE

See Also:

• Constant Field Values

EXISTING_EXPECTED_STATE

public static final String EXISTING_EXPECTED_STATE

See Also:

• Constant Field Values

CANCEL_TIME

public static final String CANCEL_TIME

See Also:

• Constant Field Values

TERMINATOR

public static final String TERMINATOR

See Also:

• Constant Field Values

ID

public static final String ID

See Also:

• Constant Field Values

FINISH_PROCESSING_TIME

public static final String FINISH_PROCESSING_TIME

See Also:

• Constant Field Values

START_PROCESSING_TIME

public static final String START_PROCESSING_TIME

See Also:

• Constant Field Values

STATISTICS

public static final String STATISTICS

See Also:

• Constant Field Values

Constructor Details

DefaultBackupRestoreJobDao

public DefaultBackupRestoreJobDao(@NonNull org.hibernate.SessionFactory sessionFactory)

Method Details

getById

@Transactional(readOnly=true)
public BackupRestoreJob getById(Long jobId)

Specified by:

getById in interface BackupRestoreJobDao

save

@Transactional
public BackupRestoreJob save(BackupRestoreJob job)

Specified by:

save in interface BackupRestoreJobDao

update

@Transactional
public void update(BackupRestoreJob job)

Specified by:

update in interface BackupRestoreJobDao

updateInNewTransaction

@Transactional(propagation=REQUIRES_NEW)
public void updateInNewTransaction(BackupRestoreJob job)

Specified by:

updateInNewTransaction in interface BackupRestoreJobDao

findJobs

@Transactional(readOnly=true)
public List<BackupRestoreJob> findJobs(BackupRestoreJobsSearchFilter backupRestoreJobsSearchFilter)

Specified by:

findJobs in interface BackupRestoreJobDao

cancelRunningJobWithOptimisticLock

@Transactional
public boolean cancelRunningJobWithOptimisticLock(long jobId,
 String terminator)

Cancels the job only if it's state was not modified.

Specified by:

cancelRunningJobWithOptimisticLock in interface BackupRestoreJobDao

Parameters:

jobId - job id

terminator - user who wants to cancel the job

Returns:

true if job was cancelled

cancelQueuedJobWithOptimisticLock

@Transactional
public boolean cancelQueuedJobWithOptimisticLock(long jobId,
 String terminator)

Cancels the job only if it's state was not modified.

Specified by:

cancelQueuedJobWithOptimisticLock in interface BackupRestoreJobDao

Parameters:

jobId - job id

terminator - user who wants to cancel the job

Returns:

true if job was cancelled

startProcessingJobWithOptimisticLock

@Transactional
public boolean startProcessingJobWithOptimisticLock(long jobId)

Changes jobs state to PROCESSING only if it's state was not modified.

Specified by:

startProcessingJobWithOptimisticLock in interface BackupRestoreJobDao

Parameters:

jobId - job id

Returns:

true if job changed it's state to processing

getNextJobForProcessing

@Transactional(readOnly=true)
public BackupRestoreJob getNextJobForProcessing()

Specified by:

getNextJobForProcessing in interface BackupRestoreJobDao

getNextActiveJob

@Transactional(readOnly=true)
public BackupRestoreJob getNextActiveJob()

Specified by:

getNextActiveJob in interface BackupRestoreJobDao

getSettingsById

@Transactional(readOnly=true)
public BackupRestoreJobSettingsRecord getSettingsById(long id)
                                               throws IllegalStateException

Specified by:

getSettingsById in interface BackupRestoreJobDao

Throws:

IllegalStateException

getStatisticsById

@Transactional(readOnly=true)
public BackupRestoreJobStatisticsRecord getStatisticsById(long id)

Specified by:

getStatisticsById in interface BackupRestoreJobDao

save

@Transactional
public Long save(BackupRestoreJobSettingsRecord backupRestoreJobSettingsRecord)

Specified by:

save in interface BackupRestoreJobDao

save

@Transactional
public void save(BackupRestoreJobStatisticsRecord statisticsRecord)

Specified by:

save in interface BackupRestoreJobDao

updateStatistics

@Transactional
public int updateStatistics(long jobId,
 String statistics)

Specified by:

updateStatistics in interface BackupRestoreJobDao

saveAndKeepId

@Transactional
public BackupRestoreJob saveAndKeepId(BackupRestoreJob job)

Regular save generates the new id if the object does not exist. This method reuses existing id.

Specified by:

saveAndKeepId in interface BackupRestoreJobDao

findJobsWithExpiredZips

@Transactional(readOnly=true)
public List<BackupRestoreJob> findJobsWithExpiredZips()

This gets all jobs where the file delete time is expired and the backup zip file still exists

Specified by:

findJobsWithExpiredZips in interface BackupRestoreJobDao

Returns:

list of jobs to delete

delete

@Transactional
public void delete(long jobId)

Deletes given job with its settings and statistics

Specified by:

delete in interface BackupRestoreJobDao

Parameters:

jobId - - job id of the job to be deleted