Package ch.tocco.nice2.dms.impl.dbrefactoring

Class DocumentFolderSqlCreator

java.lang.Object

ch.tocco.nice2.dms.impl.dbrefactoring.DocumentFolderSqlCreator

public class DocumentFolderSqlCreator
extends Object

Creates "entity folders".

Given an entity and its parent folder, creates a new folder by inserting a row into the table `nice_folder`. It does so in parallel if `nthreads` is greater than 1. Also the inserts are committed in batches of `txsize`.

The `submit` method submits workers in a thread pool that insert the rows in `nice_folder` according to the given entity. The method finish() must be called at last to shut down the pool (this object is not usable anymore after this).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	DocumentFolderSqlCreator.EntityValueId
static class	DocumentFolderSqlCreator.FolderCreate
static interface	DocumentFolderSqlCreator.SqlFunction<R>

Constructor Summary

Constructors

Constructor	Description
DocumentFolderSqlCreator(DataSource dataSource, org.slf4j.Logger log)
DocumentFolderSqlCreator(org.slf4j.Logger log, int nthreads, DataSource dataSource)

Method Summary

Modifier and Type	Method	Description
void	finish()
String	makeStatusMessage()
com.google.common.util.concurrent.ListenableFuture<Void>	submit(EntityId eid, Entity parent)	Creates a "documents-folder" for the given entity and its given parent node.

Methods inherited from class java.lang.Object

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

Constructor Details

DocumentFolderSqlCreator

public DocumentFolderSqlCreator(org.slf4j.Logger log,
 int nthreads,
 DataSource dataSource)
                         throws SQLException,
InterruptedException

Throws:

SQLException

InterruptedException

DocumentFolderSqlCreator

public DocumentFolderSqlCreator(DataSource dataSource,
 org.slf4j.Logger log)
                         throws SQLException,
InterruptedException

Throws:

SQLException

InterruptedException

Method Details

submit

public com.google.common.util.concurrent.ListenableFuture<Void> submit(EntityId eid,
 Entity parent)

Creates a "documents-folder" for the given entity and its given parent node. The creation is done on a separate thread and this method returns immediately.

makeStatusMessage

public String makeStatusMessage()

finish

public void finish()
            throws SQLException,
InterruptedException

Throws:

SQLException

InterruptedException