org.jminor.framework.db

Class EntityConnections

java.lang.Object

org.jminor.framework.db.EntityConnections

public final class EntityConnections
extends java.lang.Object

A static helper class for mass data manipulation.

Method Summary

Modifier and Type	Method and Description
static void	batchInsert(EntityConnection connection, java.util.List<Entity> entities, java.util.List<Entity.Key> committed, int batchSize, EventDataListener<java.lang.Integer> progressReporter) Inserts the given entities, performing a commit after each batchSize number of inserts.
static void	copyEntities(EntityConnection source, EntityConnection destination, int batchSize, boolean includePrimaryKeys, java.lang.String... entityIds) Copies the given entities from source to destination

Methods inherited from class java.lang.Object

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

Method Detail

copyEntities

public static void copyEntities(EntityConnection source,
                                EntityConnection destination,
                                int batchSize,
                                boolean includePrimaryKeys,
                                java.lang.String... entityIds)
                         throws DatabaseException

Copies the given entities from source to destination

Parameters:

source - the source db

destination - the destination db

batchSize - the number of records to copy between commits

includePrimaryKeys - if true primary key values are included, if false then they are assumed to be auto-generated

entityIds - the IDs of the entity types to copy

Throws:

DatabaseException - in case of a db exception

java.lang.IllegalArgumentException - if batchSize is not a positive integer

batchInsert

public static void batchInsert(EntityConnection connection,
                               java.util.List<Entity> entities,
                               java.util.List<Entity.Key> committed,
                               int batchSize,
                               EventDataListener<java.lang.Integer> progressReporter)
                        throws DatabaseException

Inserts the given entities, performing a commit after each batchSize number of inserts.

Parameters:

connection - the entity connection to use when inserting

entities - the entities to insert

committed - after the call this list will contain the primary keys of successfully inserted entities

batchSize - the commit batch size

progressReporter - if specified this will be used to report batch progress

Throws:

DatabaseException - in case of an exception

java.lang.IllegalArgumentException - if batchSize is not a positive integer