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

Class DatabasePersister

java.lang.Object

com.atlassian.confluence.impl.backuprestore.restore.dao.DatabasePersister

public class DatabasePersister
extends Object

Stores prepared imported objects to the database.

Since:

7.20.0

Constructor Summary

Constructors

Constructor	Description
DatabasePersister(ParallelTasksExecutor parallelTasksExecutor, RestoreDao restoreDao, IdMapper idMapper, EntityInfoSqlHelper entityInfoSqlHelper)
DatabasePersister(ParallelTasksExecutor parallelTasksExecutor, RestoreDao restoreDao, IdMapper idMapper, EntityInfoSqlHelper entityInfoSqlHelper, int batchSize)	Provides an ability to change batch size for tests.

Method Summary

Modifier and Type	Method	Description
Collection<Future<?>>	persistAsynchronously(Collection<ImportedObjectV2> objectsToPersist, Object fakeObjectForIdGeneration)	Run object persisting asynchronously.
void	waitUntilAllJobsFinish(Collection<Future<?>> futures)

Methods inherited from class java.lang.Object

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

Constructor Detail

DatabasePersister

public DatabasePersister(ParallelTasksExecutor parallelTasksExecutor,
                         RestoreDao restoreDao,
                         IdMapper idMapper,
                         EntityInfoSqlHelper entityInfoSqlHelper)

DatabasePersister

public DatabasePersister(ParallelTasksExecutor parallelTasksExecutor,
                         RestoreDao restoreDao,
                         IdMapper idMapper,
                         EntityInfoSqlHelper entityInfoSqlHelper,
                         int batchSize)

Provides an ability to change batch size for tests.

Method Detail

persistAsynchronously

public Collection<Future<?>> persistAsynchronously(Collection<ImportedObjectV2> objectsToPersist,
                                                   Object fakeObjectForIdGeneration)

Run object persisting asynchronously. Returns the collections of the tasks futures.

waitUntilAllJobsFinish

public void waitUntilAllJobsFinish(Collection<Future<?>> futures)
                            throws BackupRestoreException

Throws:

BackupRestoreException