Package one.microstream.persistence.types

Class PersistenceManager.Default<M>

java.lang.Object

one.microstream.persistence.types.PersistenceManager.Default<M>

All Implemented Interfaces:

PersistenceManager<M>, PersistenceObjectIdHolder, PersistenceObjectIdLookup, PersistenceObjectLookup, PersistenceObjectManager, PersistenceObjectRetriever, PersistenceRetrieving, PersistenceSourceSupplier<M>, PersistenceStoring, PersistenceSwizzlingLookup, Unpersistable, Cloneable<PersistenceObjectManager>

Enclosing interface:

PersistenceManager<M>

public static final class PersistenceManager.Default<M>
extends Object
implements PersistenceManager<M>, Unpersistable

Nested Class Summary

Nested classes/interfaces inherited from interface one.microstream.persistence.types.PersistenceManager

PersistenceManager.Default<M>

Constructor Summary

Constructors

Constructor	Description
Default()

Method Summary

Modifier and Type	Method	Description
void	close()	Closes all ties to outside resources, if applicable.
<C extends Consumer<Object>> C	collect(C collector, long... objectIds)
void	consolidate()
PersistenceStorer<M>	createEagerStorer()
PersistenceStorer<M>	createLazyStorer()
PersistenceLoader<M>	createLoader()
PersistenceRegisterer	createRegisterer()
PersistenceStorer<M>	createStorer()
PersistenceStorer<M>	createStorer(PersistenceStorer.Creator<M> storerCreator)
long	currentObjectId()
long	ensureObjectId(Object object)
long	ensureObjectId(Object object, PersistenceAcceptor newObjectIdCallback)
Object	get()
Object	getObject(long objectId)
Object	lookupObject(long objectId)
long	lookupObjectId(Object object)
PersistenceObjectRegistry	objectRegistry()
PersistenceSource<M>	source()
long	store(Object object)	Stores the passed instance in any case and all referenced instances of persistable references recursively, but stores referenced instances only if they are newly encountered (e.g.
void	storeAll(Iterable<?> instances)	Convenience method to PersistenceStoring.store(Object) all instances of an Iterable type, usually a collection. The passed instance itself is NOT stored. Note that this method does not return an array of objectIds, since the amount of instances supplied by the passed Iterable cannot be known until after all instances have been stored and the memory and performance overhead to collect them dynamically would not be worth it in most cases since the returned array is hardly ever needed.
long[]	storeAll(Object... instances)	Convenience method to PersistenceStoring.store(Object) multiple instances.
PersistenceTarget<M>	target()
PersistenceTypeDictionary	typeDictionary()
PersistenceManager.Default<M>	updateCurrentObjectId(long currentObjectId)
void	updateMetadata(PersistenceTypeDictionary typeDictionary, long highestTypeId, long highestObjectId)

Methods inherited from class java.lang.Object

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

Methods inherited from interface one.microstream.persistence.types.PersistenceManager

storeSelfStoring, updateMetadata

Methods inherited from interface one.microstream.persistence.types.PersistenceObjectManager

Clone

Constructor Detail

Default

public Default()

Method Detail

objectRegistry

public final PersistenceObjectRegistry objectRegistry()

Specified by:

objectRegistry in interface PersistenceManager<M>

typeDictionary

public final PersistenceTypeDictionary typeDictionary()

Specified by:

typeDictionary in interface PersistenceManager<M>

consolidate

public final void consolidate()

Specified by:

consolidate in interface PersistenceObjectManager

createLazyStorer

public final PersistenceStorer<M> createLazyStorer()

Specified by:

createLazyStorer in interface PersistenceManager<M>

createStorer

public final PersistenceStorer<M> createStorer()

Specified by:

createStorer in interface PersistenceManager<M>

createEagerStorer

public final PersistenceStorer<M> createEagerStorer()

Specified by:

createEagerStorer in interface PersistenceManager<M>

createStorer

public final PersistenceStorer<M> createStorer(PersistenceStorer.Creator<M> storerCreator)

Specified by:

createStorer in interface PersistenceManager<M>

createRegisterer

public final PersistenceRegisterer createRegisterer()

Specified by:

createRegisterer in interface PersistenceManager<M>

store

public final long store(Object object)

Description copied from interface: PersistenceStoring

Stores the passed instance in any case and all referenced instances of persistable references recursively, but stores referenced instances only if they are newly encountered (e.g. don't have an id associated with them in the object registry, yet and are therefore required to be handled). This is useful for the common case of just storing an updated instance and potentially newly created instances along with it while skipping all existing (and normally unchanged) referenced instances.

Specified by:

store in interface PersistenceStoring

Parameters:

object - the root instance of the subgraph of required instances to be stored.

Returns:

the object id representing the passed instance.

storeAll

public final long[] storeAll(Object... instances)

Description copied from interface: PersistenceStoring

Convenience method to PersistenceStoring.store(Object) multiple instances. The passed array (maybe implicitely created by the compiler) itself is NOT stored.

Specified by:

storeAll in interface PersistenceStoring

Parameters:

instances - multiple root instances of the subgraphs of required instances to be stored.

Returns:

an array containing the object ids representing the passed instances.

storeAll

public void storeAll(Iterable<?> instances)

Description copied from interface: PersistenceStoring

Convenience method to PersistenceStoring.store(Object) all instances of an Iterable type, usually a collection.
The passed instance itself is NOT stored.
Note that this method does not return an array of objectIds, since the amount of instances supplied by the passed Iterable cannot be known until after all instances have been stored and the memory and performance overhead to collect them dynamically would not be worth it in most cases since the returned array is hardly ever needed. If it should be needed, the desired behavior can be easily achieved with a tiny custom-made utility method.

Specified by:

storeAll in interface PersistenceStoring

Parameters:

instances - multiple root instances of the subgraphs of required instances to be stored.

ensureObjectId

public final long ensureObjectId(Object object)

Specified by:

ensureObjectId in interface PersistenceObjectManager

ensureObjectId

public final long ensureObjectId(Object object,
                                 PersistenceAcceptor newObjectIdCallback)

Specified by:

ensureObjectId in interface PersistenceObjectManager

currentObjectId

public long currentObjectId()

Specified by:

currentObjectId in interface PersistenceManager<M>

Specified by:

currentObjectId in interface PersistenceObjectIdHolder

Specified by:

currentObjectId in interface PersistenceObjectManager

lookupObjectId

public final long lookupObjectId(Object object)

Specified by:

lookupObjectId in interface PersistenceObjectIdLookup

lookupObject

public final Object lookupObject(long objectId)

Specified by:

lookupObject in interface PersistenceObjectLookup

get

public final Object get()

Specified by:

get in interface PersistenceRetrieving

collect

public final <C extends Consumer<Object>> C collect(C collector,
                                                    long... objectIds)

Specified by:

collect in interface PersistenceRetrieving

getObject

public final Object getObject(long objectId)

Specified by:

getObject in interface PersistenceObjectRetriever

Specified by:

getObject in interface PersistenceRetrieving

Specified by:

getObject in interface PersistenceSourceSupplier<M>

createLoader

public final PersistenceLoader<M> createLoader()

Specified by:

createLoader in interface PersistenceManager<M>

source

public final PersistenceSource<M> source()

Specified by:

source in interface PersistenceManager<M>

Specified by:

source in interface PersistenceSourceSupplier<M>

target

public final PersistenceTarget<M> target()

Specified by:

target in interface PersistenceManager<M>

close

public void close()

Description copied from interface: PersistenceManager

Closes all ties to outside resources, if applicable. Typ

Specified by:

close in interface PersistenceManager<M>

updateCurrentObjectId

public PersistenceManager.Default<M> updateCurrentObjectId(long currentObjectId)

Specified by:

updateCurrentObjectId in interface PersistenceManager<M>

Specified by:

updateCurrentObjectId in interface PersistenceObjectIdHolder

Specified by:

updateCurrentObjectId in interface PersistenceObjectManager

updateMetadata

public void updateMetadata(PersistenceTypeDictionary typeDictionary,
                           long highestTypeId,
                           long highestObjectId)

Specified by:

updateMetadata in interface PersistenceManager<M>