Package nl.b3p.brmo.bag2.schema

Class BAG2ObjectTableWriter

java.lang.Object

nl.b3p.brmo.schema.ObjectTableWriter

nl.b3p.brmo.bag2.schema.BAG2ObjectTableWriter

public class BAG2ObjectTableWriter
extends ObjectTableWriter

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	BAG2ObjectTableWriter.BAG2Progress

Nested classes/interfaces inherited from class nl.b3p.brmo.schema.ObjectTableWriter

ObjectTableWriter.Progress, ObjectTableWriter.Stage

Constructor Summary

Constructors

Constructor	Description
BAG2ObjectTableWriter(Connection connection, SQLDialect dialect, SchemaSQLMapper schemaSQLMapper)

Method Summary

Modifier and Type	Method	Description
protected void	addObjectToBatch(SchemaObjectInstance object)
void	complete()
void	createIndexes(ObjectType objectType)
void	createKeys(ObjectType objectType)
boolean	getIgnoreDuplicates()
Map<BAG2ObjectType,Set<org.apache.commons.lang3.tuple.Pair<Object,Object>>>	getKeysPerObjectType()
BAG2ObjectTableWriter.BAG2Progress	getProgress()
void	setIgnoreDuplicates(boolean ignoreDuplicates)
void	setKeysPerObjectType(Map<BAG2ObjectType,Set<org.apache.commons.lang3.tuple.Pair<Object,Object>>> keysPerObjectType)
void	start()
void	write(InputStream bagXml)

Methods inherited from class nl.b3p.brmo.schema.ObjectTableWriter

abortWorkerThread, closeBatches, endOfObjects, getArrayAttributeInsertBatch, getBatchSize, getConnection, getDialect, getInsertBatch, getObjectLimit, getProgressUpdater, getSchemaSQLMapper, getTablePrefix, isCreateKeysAndIndexes, isCreateSchema, isDropIfExists, isLinearizeCurves, isMultithreading, isUsePgCopy, prepareDatabaseForObject, setBatchSize, setCreateKeysAndIndexes, setCreateSchema, setDropIfExists, setLinearizeCurves, setMultithreading, setObjectLimit, setProgress, setProgressUpdater, setTablePrefix, setUsePgCopy, start, updateProgress, updateProgress

Methods inherited from class java.lang.Object

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

Constructor Details

BAG2ObjectTableWriter

public BAG2ObjectTableWriter(Connection connection,
 SQLDialect dialect,
 SchemaSQLMapper schemaSQLMapper)

Method Details

setIgnoreDuplicates

public void setIgnoreDuplicates(boolean ignoreDuplicates)

getIgnoreDuplicates

public boolean getIgnoreDuplicates()

getProgress

public BAG2ObjectTableWriter.BAG2Progress getProgress()

Overrides:

getProgress in class ObjectTableWriter

getKeysPerObjectType

public Map<BAG2ObjectType,Set<org.apache.commons.lang3.tuple.Pair<Object,Object>>> getKeysPerObjectType()

setKeysPerObjectType

public void setKeysPerObjectType(Map<BAG2ObjectType,Set<org.apache.commons.lang3.tuple.Pair<Object,Object>>> keysPerObjectType)

start

public void start()
           throws SQLException

Throws:

SQLException

addObjectToBatch

protected void addObjectToBatch(SchemaObjectInstance object)
                         throws Exception

Overrides:

addObjectToBatch in class ObjectTableWriter

Throws:

Exception

write

public void write(InputStream bagXml)
           throws Exception

Throws:

Exception

complete

public void complete()
              throws Exception

Overrides:

complete in class ObjectTableWriter

Throws:

Exception

createKeys

public void createKeys(ObjectType objectType)
                throws Exception

Overrides:

createKeys in class ObjectTableWriter

Throws:

Exception

createIndexes

public void createIndexes(ObjectType objectType)
                   throws Exception

Overrides:

createIndexes in class ObjectTableWriter

Throws:

Exception