Class AbstractPersistentObjectRemoteDelegateImpl<T extends PersistentDomainObject<T>, P extends AbstractPersistentObject<T,P>>

java.lang.Object

org.tentackle.dbms.trip.RemoteDbDelegateImpl<P>

org.tentackle.dbms.trip.AbstractDbObjectRemoteDelegateImpl<P>

org.tentackle.persist.trip.AbstractPersistentObjectRemoteDelegateImpl<T,P>

Type Parameters:

T - the PersistentDomainObject class

P - the AbstractPersistentObject class (persistence implementation)

All Implemented Interfaces:

AbstractDbObjectRemoteDelegate<P>, RemoteDbDelegate, AbstractPersistentObjectRemoteDelegate<T,P>, org.tentackle.trip.Remote

Direct Known Subclasses:

NumberPoolRemoteDelegateImpl, NumberRangeRemoteDelegateImpl, SecurityRemoteDelegateImpl

public class AbstractPersistentObjectRemoteDelegateImpl<T extends PersistentDomainObject<T>, P extends AbstractPersistentObject<T,P>>
extends AbstractDbObjectRemoteDelegateImpl<P>
implements AbstractPersistentObjectRemoteDelegate<T,P>

Implementation of the remote delegate for PersistentDomainObject.

Author:

harald

Field Summary

Fields

Modifier and Type	Field	Description
protected T	pdo	PDO with a default domain context associated to the delegate's session.
protected final Class<T>	pdoClass	The PDO interface class.

Fields inherited from class AbstractDbObjectRemoteDelegateImpl

dbObject

Constructor Summary

Constructors

Constructor	Description
AbstractPersistentObjectRemoteDelegateImpl(RemoteDbSessionImpl serverSession, Class<P> persistenceClass, Class<T> pdoClass)	Creates a delegate on the serverSession socket.

Method Summary

Modifier and Type	Method	Description
RemoteResultSetCursor<T>	createRemoteResultSetCursorDelegate(org.tentackle.misc.ScrollableResource<T> cursor)	Creates and exports a remote cursor delegate for a local cursor.
long	deleteImpl(T obj)
DbObjectResult	deleteObject(P obj)
void	deletePlain(long id, long serial)
void	dummyUpdate(P obj)
protected P	getPersistenceDelegate(T pDo)	Gets the persistence delegate from a PDO.
void	initialize()
DbObjectResult	insertObject(P obj)
void	insertPlain(P obj)
boolean	isReferenced(long id)
boolean	isReferenced(DomainContext cb, long id)
protected T	newInstance(DomainContext context)	Creates a new pdo instance of the required class for methods that return a new object.
protected T	newInstance(DomainContext context, long id)	Selects by ID into a new instance. Throws NotFoundException, if no such PDO in database.
T	persistImpl(T obj)
P	persistObject(P obj)
long	saveImpl(T obj)
DbObjectResult	saveObject(P obj)
T	select(DomainContext cb, long id, boolean forUpdate, boolean tokenLocked)
List<T>	selectAll(DomainContext cb)
RemoteResultSetCursor<T>	selectAllAsCursor(DomainContext cb)
List<T>	selectAllForCache(DomainContext cb)
List<org.tentackle.misc.IdSerialTuple>	selectAllIdSerial()
List<P>	selectAllObjects()
List<T>	selectAllWithExpiredTableSerials(DomainContext cb, long oldSerial)
List<T>	selectAllWithExpiredTableSerials(DomainContext cb, long oldSerial, long maxSerial)
List<T>	selectAny(DomainContext cb, Collection<Long> ids)
List<T>	selectAnyForCache(DomainContext cb, Collection<Long> ids)
List<T>	selectByNormText(DomainContext cb, String normText)
RemoteResultSetCursor<T>	selectByNormTextAsCursor(DomainContext cb, String normText)
T	selectForCache(DomainContext cb, long id)
List<T>	selectLatest(DomainContext cb, long greaterId, int limit)
P	selectObject(long id)
P	selectObjectForUpdate(long id)
T	selectTokenLocked(DomainContext cb, long id)
protected void	setDomainContext(DomainContext context)	Sets the domain context in the default object.
T	transferTokenLock(T pdo, long userId)
void	updateAndSetSerial(long id, long serial)
DbObjectResult	updateObject(P obj)
void	updatePlain(P obj)
void	updateSerial(long id, long serial)
void	updateSerialAndTableSerial(long id, long serial, long tableSerial)
TokenLockInfo	updateTokenLock(DomainContext cb, long id, org.tentackle.common.Timestamp tokenExpiry, long userId, org.tentackle.common.Timestamp curTime)
void	updateTokenLockOnly(DomainContext cb, long id, long editedBy, org.tentackle.common.Timestamp editedSince, org.tentackle.common.Timestamp editedExpiry)

Methods inherited from class AbstractDbObjectRemoteDelegateImpl

countModification, getExpiredTableSerials, newInstance, obtainReservedId, selectExpiredTableSerials, selectExpiredTableSerials, selectMaxId, selectMaxTableSerial, selectObjectsWithExpiredTableSerials, selectSerial, validate

Methods inherited from class RemoteDbDelegateImpl

getServerSession, getServicedClass, getSession, toString

Methods inherited from class Object

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

Methods inherited from interface AbstractDbObjectRemoteDelegate

countModification, getExpiredTableSerials, obtainReservedId, selectExpiredTableSerials, selectExpiredTableSerials, selectMaxId, selectMaxTableSerial, selectObjectsWithExpiredTableSerials, selectSerial

Field Details

pdoClass

protected final Class<T extends PersistentDomainObject<T>> pdoClass

The PDO interface class.

pdo

protected T extends PersistentDomainObject<T> pdo

PDO with a default domain context associated to the delegate's session.

Constructor Details

AbstractPersistentObjectRemoteDelegateImpl

public AbstractPersistentObjectRemoteDelegateImpl(RemoteDbSessionImpl serverSession,
 Class<P> persistenceClass,
 Class<T> pdoClass)

Creates a delegate on the serverSession socket.

Parameters:

serverSession - the TRIP session

persistenceClass - the subclass of AbstractDbObject

pdoClass - the PDO class (interface)

Method Details

initialize

public void initialize()

Overrides:

initialize in class AbstractDbObjectRemoteDelegateImpl<P extends AbstractPersistentObject<T,P>>

newInstance

protected T newInstance(DomainContext context)

Creates a new pdo instance of the required class for methods that return a new object.

Parameters:

context - the domain context

Returns:

the new pdo

newInstance

protected T newInstance(DomainContext context,
 long id)

Selects by ID into a new instance.
Throws NotFoundException, if no such PDO in database.

Parameters:

context - the domain context

id - the ID

Returns:

the pdo, never null

getPersistenceDelegate

protected P getPersistenceDelegate(T pDo)

Gets the persistence delegate from a PDO.

Parameters:

pDo - the PDO

Returns:

the persistence delegate

setDomainContext

protected void setDomainContext(DomainContext context)

Sets the domain context in the default object.

Parameters:

context - the domain context

selectObject

public P selectObject(long id)

Specified by:

selectObject in interface AbstractDbObjectRemoteDelegate<T extends PersistentDomainObject<T>>

Overrides:

selectObject in class AbstractDbObjectRemoteDelegateImpl<P extends AbstractPersistentObject<T,P>>

selectObjectForUpdate

public P selectObjectForUpdate(long id)

Specified by:

selectObjectForUpdate in interface AbstractDbObjectRemoteDelegate<T extends PersistentDomainObject<T>>

Overrides:

selectObjectForUpdate in class AbstractDbObjectRemoteDelegateImpl<P extends AbstractPersistentObject<T,P>>

selectAllObjects

public List<P> selectAllObjects()

Specified by:

selectAllObjects in interface AbstractDbObjectRemoteDelegate<T extends PersistentDomainObject<T>>

Overrides:

selectAllObjects in class AbstractDbObjectRemoteDelegateImpl<P extends AbstractPersistentObject<T,P>>

dummyUpdate

public void dummyUpdate(P obj)

Specified by:

dummyUpdate in interface AbstractDbObjectRemoteDelegate<T extends PersistentDomainObject<T>>

Overrides:

dummyUpdate in class AbstractDbObjectRemoteDelegateImpl<P extends AbstractPersistentObject<T,P>>

updateSerial

public void updateSerial(long id,
 long serial)

Specified by:

updateSerial in interface AbstractDbObjectRemoteDelegate<T extends PersistentDomainObject<T>>

Overrides:

updateSerial in class AbstractDbObjectRemoteDelegateImpl<P extends AbstractPersistentObject<T,P>>

updateAndSetSerial

public void updateAndSetSerial(long id,
 long serial)

Specified by:

updateAndSetSerial in interface AbstractDbObjectRemoteDelegate<T extends PersistentDomainObject<T>>

Overrides:

updateAndSetSerial in class AbstractDbObjectRemoteDelegateImpl<P extends AbstractPersistentObject<T,P>>

updateSerialAndTableSerial

public void updateSerialAndTableSerial(long id,
 long serial,
 long tableSerial)

Specified by:

updateSerialAndTableSerial in interface AbstractDbObjectRemoteDelegate<T extends PersistentDomainObject<T>>

Overrides:

updateSerialAndTableSerial in class AbstractDbObjectRemoteDelegateImpl<P extends AbstractPersistentObject<T,P>>

updatePlain

public void updatePlain(P obj)

Specified by:

updatePlain in interface AbstractDbObjectRemoteDelegate<T extends PersistentDomainObject<T>>

Overrides:

updatePlain in class AbstractDbObjectRemoteDelegateImpl<P extends AbstractPersistentObject<T,P>>

deletePlain

public void deletePlain(long id,
 long serial)

Specified by:

deletePlain in interface AbstractDbObjectRemoteDelegate<T extends PersistentDomainObject<T>>

Overrides:

deletePlain in class AbstractDbObjectRemoteDelegateImpl<P extends AbstractPersistentObject<T,P>>

insertPlain

public void insertPlain(P obj)

Specified by:

insertPlain in interface AbstractDbObjectRemoteDelegate<T extends PersistentDomainObject<T>>

Overrides:

insertPlain in class AbstractDbObjectRemoteDelegateImpl<P extends AbstractPersistentObject<T,P>>

updateObject

public DbObjectResult updateObject(P obj)

Specified by:

updateObject in interface AbstractDbObjectRemoteDelegate<T extends PersistentDomainObject<T>>

Overrides:

updateObject in class AbstractDbObjectRemoteDelegateImpl<P extends AbstractPersistentObject<T,P>>

insertObject

public DbObjectResult insertObject(P obj)

Specified by:

insertObject in interface AbstractDbObjectRemoteDelegate<T extends PersistentDomainObject<T>>

Overrides:

insertObject in class AbstractDbObjectRemoteDelegateImpl<P extends AbstractPersistentObject<T,P>>

deleteObject

public DbObjectResult deleteObject(P obj)

Specified by:

deleteObject in interface AbstractDbObjectRemoteDelegate<T extends PersistentDomainObject<T>>

Overrides:

deleteObject in class AbstractDbObjectRemoteDelegateImpl<P extends AbstractPersistentObject<T,P>>

persistObject

public P persistObject(P obj)

Specified by:

persistObject in interface AbstractDbObjectRemoteDelegate<T extends PersistentDomainObject<T>>

Overrides:

persistObject in class AbstractDbObjectRemoteDelegateImpl<P extends AbstractPersistentObject<T,P>>

saveObject

public DbObjectResult saveObject(P obj)

Specified by:

saveObject in interface AbstractDbObjectRemoteDelegate<T extends PersistentDomainObject<T>>

Overrides:

saveObject in class AbstractDbObjectRemoteDelegateImpl<P extends AbstractPersistentObject<T,P>>

isReferenced

public boolean isReferenced(long id)

Specified by:

isReferenced in interface AbstractDbObjectRemoteDelegate<T extends PersistentDomainObject<T>>

Overrides:

isReferenced in class AbstractDbObjectRemoteDelegateImpl<P extends AbstractPersistentObject<T,P>>

selectAllIdSerial

public List<org.tentackle.misc.IdSerialTuple> selectAllIdSerial()

Specified by:

selectAllIdSerial in interface AbstractDbObjectRemoteDelegate<T extends PersistentDomainObject<T>>

Overrides:

selectAllIdSerial in class AbstractDbObjectRemoteDelegateImpl<P extends AbstractPersistentObject<T,P>>

persistImpl

public T persistImpl(T obj)

Specified by:

persistImpl in interface AbstractPersistentObjectRemoteDelegate<T extends PersistentDomainObject<T>, P extends AbstractPersistentObject<T,P>>

saveImpl

public long saveImpl(T obj)

Specified by:

saveImpl in interface AbstractPersistentObjectRemoteDelegate<T extends PersistentDomainObject<T>, P extends AbstractPersistentObject<T,P>>

deleteImpl

public long deleteImpl(T obj)

Specified by:

deleteImpl in interface AbstractPersistentObjectRemoteDelegate<T extends PersistentDomainObject<T>, P extends AbstractPersistentObject<T,P>>

selectAll

public List<T> selectAll(DomainContext cb)

Specified by:

selectAll in interface AbstractPersistentObjectRemoteDelegate<T extends PersistentDomainObject<T>, P extends AbstractPersistentObject<T,P>>

selectAny

public List<T> selectAny(DomainContext cb,
 Collection<Long> ids)

Specified by:

selectAny in interface AbstractPersistentObjectRemoteDelegate<T extends PersistentDomainObject<T>, P extends AbstractPersistentObject<T,P>>

select

public T select(DomainContext cb,
 long id,
 boolean forUpdate,
 boolean tokenLocked)

Specified by:

select in interface AbstractPersistentObjectRemoteDelegate<T extends PersistentDomainObject<T>, P extends AbstractPersistentObject<T,P>>

selectTokenLocked

public T selectTokenLocked(DomainContext cb,
 long id)

Specified by:

selectTokenLocked in interface AbstractPersistentObjectRemoteDelegate<T extends PersistentDomainObject<T>, P extends AbstractPersistentObject<T,P>>

selectByNormText

public List<T> selectByNormText(DomainContext cb,
 String normText)

Specified by:

selectByNormText in interface AbstractPersistentObjectRemoteDelegate<T extends PersistentDomainObject<T>, P extends AbstractPersistentObject<T,P>>

selectByNormTextAsCursor

public RemoteResultSetCursor<T> selectByNormTextAsCursor(DomainContext cb,
 String normText)

Specified by:

selectByNormTextAsCursor in interface AbstractPersistentObjectRemoteDelegate<T extends PersistentDomainObject<T>, P extends AbstractPersistentObject<T,P>>

selectLatest

public List<T> selectLatest(DomainContext cb,
 long greaterId,
 int limit)

Specified by:

selectLatest in interface AbstractPersistentObjectRemoteDelegate<T extends PersistentDomainObject<T>, P extends AbstractPersistentObject<T,P>>

selectAllForCache

public List<T> selectAllForCache(DomainContext cb)

Specified by:

selectAllForCache in interface AbstractPersistentObjectRemoteDelegate<T extends PersistentDomainObject<T>, P extends AbstractPersistentObject<T,P>>

selectAnyForCache

public List<T> selectAnyForCache(DomainContext cb,
 Collection<Long> ids)

Specified by:

selectAnyForCache in interface AbstractPersistentObjectRemoteDelegate<T extends PersistentDomainObject<T>, P extends AbstractPersistentObject<T,P>>

selectForCache

public T selectForCache(DomainContext cb,
 long id)

Specified by:

selectForCache in interface AbstractPersistentObjectRemoteDelegate<T extends PersistentDomainObject<T>, P extends AbstractPersistentObject<T,P>>

selectAllAsCursor

public RemoteResultSetCursor<T> selectAllAsCursor(DomainContext cb)

Specified by:

selectAllAsCursor in interface AbstractPersistentObjectRemoteDelegate<T extends PersistentDomainObject<T>, P extends AbstractPersistentObject<T,P>>

selectAllWithExpiredTableSerials

public List<T> selectAllWithExpiredTableSerials(DomainContext cb,
 long oldSerial)

Specified by:

selectAllWithExpiredTableSerials in interface AbstractPersistentObjectRemoteDelegate<T extends PersistentDomainObject<T>, P extends AbstractPersistentObject<T,P>>

selectAllWithExpiredTableSerials

public List<T> selectAllWithExpiredTableSerials(DomainContext cb,
 long oldSerial,
 long maxSerial)

Specified by:

selectAllWithExpiredTableSerials in interface AbstractPersistentObjectRemoteDelegate<T extends PersistentDomainObject<T>, P extends AbstractPersistentObject<T,P>>

isReferenced

public boolean isReferenced(DomainContext cb,
 long id)

Specified by:

isReferenced in interface AbstractPersistentObjectRemoteDelegate<T extends PersistentDomainObject<T>, P extends AbstractPersistentObject<T,P>>

updateTokenLock

public TokenLockInfo updateTokenLock(DomainContext cb,
 long id,
 org.tentackle.common.Timestamp tokenExpiry,
 long userId,
 org.tentackle.common.Timestamp curTime)

Specified by:

updateTokenLock in interface AbstractPersistentObjectRemoteDelegate<T extends PersistentDomainObject<T>, P extends AbstractPersistentObject<T,P>>

transferTokenLock

public T transferTokenLock(T pdo,
 long userId)

Specified by:

transferTokenLock in interface AbstractPersistentObjectRemoteDelegate<T extends PersistentDomainObject<T>, P extends AbstractPersistentObject<T,P>>

updateTokenLockOnly

public void updateTokenLockOnly(DomainContext cb,
 long id,
 long editedBy,
 org.tentackle.common.Timestamp editedSince,
 org.tentackle.common.Timestamp editedExpiry)

Specified by:

updateTokenLockOnly in interface AbstractPersistentObjectRemoteDelegate<T extends PersistentDomainObject<T>, P extends AbstractPersistentObject<T,P>>

createRemoteResultSetCursorDelegate

public RemoteResultSetCursor<T> createRemoteResultSetCursorDelegate(org.tentackle.misc.ScrollableResource<T> cursor)

Creates and exports a remote cursor delegate for a local cursor.

Parameters:

cursor - the local cursor

Returns:

the remote cursor delegate