de.ipcon.db

Class DBManUserContextImpl

java.lang.Object

de.ipcon.db.DBManUserContextImpl

All Implemented Interfaces:

DBManUserContextI, DBManVetoHandlerI

public class DBManUserContextImpl
extends java.lang.Object
implements DBManUserContextI, DBManVetoHandlerI

Constructor Summary

Constructors

Constructor and Description
DBManUserContextImpl(DBManLocalI _dbm)

Method Summary

Modifier and Type	Method and Description
void	addSubscription(java.lang.String key, DBManEventFilter filter)
DBManEvent	applyFilters(DBManEvent evt)
boolean	areGratuitousLocalConnectionsAvailable()
PermissionHandlerDecisionI	checkCreateAllowed(BO bo)
void	checkCreateRightForSavingOfTransaction(Transaction tx) Checks if the current user has the necessary rights to create the objects within the given transaction.
PermissionHandlerDecisionI	checkDeleteAllowed(BO bo)
boolean	checkDemandForcedClientDisconnectAllowed()
PermissionHandlerDecisionI	checkReadAllowed(BO bo)
PermissionHandlerDecisionI	checkReadAllowed(BO bo, java.lang.String attributeName)
boolean	checkSendingSystemMessagesAllowed()
boolean	checkServerLockActionsAllowed()
boolean	checkServerShutdownActionsAllowed()
void	checkUpdateAndDeleteRightsForSavingOfTransaction(Transaction tx) Checks if the current user has the necessary rights to update or delete the objects within the given transaction.
PermissionHandlerDecisionI	checkWriteAllowed(BO bo)
PermissionHandlerDecisionI	checkWriteAllowed(BO bo, java.lang.String attributeName)
boolean	exists(java.lang.Long id)
boolean	exists(java.lang.Long id, java.lang.Class<? extends BOI> classtip)
byte[]	getBLOB(java.lang.Long id)
long	getBLOB(java.lang.Long id, java.io.DataOutput os)
long	getBLOB(java.lang.Long id, java.io.DataOutput os, boolean closeOS)
long	getBLOB(java.lang.Long id, java.io.DataOutput os, boolean closeOS, java.lang.Long backuppingBPId)
byte[]	getBLOB(java.lang.Long id, java.lang.Long backuppingBPId)
long	getBLOB(java.lang.Long id, java.io.OutputStream os)
long	getBLOB(java.lang.Long id, java.io.OutputStream os, boolean closeOS)
long	getBLOB(java.lang.Long id, java.io.OutputStream os, boolean closeOS, java.lang.Long backuppingBPId)
InputStreamWrapper	getBLOBAsStream(java.lang.Long id)
InputStreamWrapper	getBLOBAsStream(java.lang.Long id, java.lang.Long backuppingBPId)
InitialBLOBTransferMetaDataContainer	getBLOBBOIdsForIntitialBLOBCopy(java.util.Map idsAndVFilesOnSyncNode, java.util.List pendingBLOBChangeBOIdsOnSyncNode, java.util.List pendingBLOBChangeBOIdsOnAuthNode)
VFile	getBLOBInfo(java.lang.Long id)
VFile	getBLOBInfo(java.lang.Long id, java.lang.Long backuppingBPId)
DBManConfigurationHelperI	getConfiguration()
Benutzer	getCurrentUser()
java.lang.String	getCurrentUserName()
java.lang.String	getCurrentUserRemark()
KeyRange	getIdRange(long size)
java.lang.Long	getNextId()
PermissionHandlerI	getPermissionHandler()
PersistenceHandlerI	getPersistenceHandler()
PersistenceHandlerI	getPersistenceHandlerForSaving()
SchemaI	getSchema()
boolean	hasBLOB(java.lang.Long id)
boolean	hasBLOB(java.lang.Long id, java.lang.Long backuppingBPId)
java.util.BitSet	haveBLOB(long[] ids)
boolean	isAuthoritativeSyncServer()
BO	loadBO(java.lang.Long id)
BO	loadBO(java.lang.Long id, java.lang.Class<? extends BOI> classtip)
BO[]	loadBOs(java.lang.Long[] ids)
BO[]	loadBOs(java.lang.Long[] ids, java.lang.Class<? extends BOI> classtip)
void	login(BackendSessionI session)
de.ipcon.db.core.QueryResultsI	query(java.lang.String t)
de.ipcon.db.core.QueryResultsI	query(java.lang.String t, java.lang.Object[] pvals)
java.util.List	queryBO(java.lang.String t)
java.util.List	queryBO(java.lang.String t, java.lang.Object[] pvals)
void	removeSubscription(java.lang.String key)
TransactionAnswer	saveBO(Transaction tx, SerializedTransaction stx, PersistenceHandlerI ph, int lockTimeout, int retries, SecureObjectOutputI out) Persists the changes recorded in the passed Transaction tx to the database.

Methods inherited from class java.lang.Object

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

Constructor Detail

DBManUserContextImpl

public DBManUserContextImpl(DBManLocalI _dbm)

Method Detail

getConfiguration

public DBManConfigurationHelperI getConfiguration()

Specified by:

getConfiguration in interface DBManUserContextI

getPersistenceHandler

public PersistenceHandlerI getPersistenceHandler()

Specified by:

getPersistenceHandler in interface DBManUserContextI

getPersistenceHandlerForSaving

public PersistenceHandlerI getPersistenceHandlerForSaving()

Specified by:

getPersistenceHandlerForSaving in interface DBManUserContextI

isAuthoritativeSyncServer

public boolean isAuthoritativeSyncServer()

Specified by:

isAuthoritativeSyncServer in interface DBManUserContextI

getCurrentUser

public Benutzer getCurrentUser()

Specified by:

getCurrentUser in interface DBManUserContextI

getCurrentUserName

public java.lang.String getCurrentUserName()

Specified by:

getCurrentUserName in interface DBManUserContextI

getCurrentUserRemark

public java.lang.String getCurrentUserRemark()

Specified by:

getCurrentUserRemark in interface DBManUserContextI

getPermissionHandler

public PermissionHandlerI getPermissionHandler()

Specified by:

getPermissionHandler in interface DBManUserContextI

checkReadAllowed

public PermissionHandlerDecisionI checkReadAllowed(BO bo)

Specified by:

checkReadAllowed in interface DBManUserContextI

checkReadAllowed

public PermissionHandlerDecisionI checkReadAllowed(BO bo,
                                                   java.lang.String attributeName)

Specified by:

checkReadAllowed in interface DBManUserContextI

checkWriteAllowed

public PermissionHandlerDecisionI checkWriteAllowed(BO bo)

Specified by:

checkWriteAllowed in interface DBManUserContextI

checkWriteAllowed

public PermissionHandlerDecisionI checkWriteAllowed(BO bo,
                                                    java.lang.String attributeName)

Specified by:

checkWriteAllowed in interface DBManUserContextI

checkCreateAllowed

public PermissionHandlerDecisionI checkCreateAllowed(BO bo)

Specified by:

checkCreateAllowed in interface DBManUserContextI

checkDeleteAllowed

public PermissionHandlerDecisionI checkDeleteAllowed(BO bo)

Specified by:

checkDeleteAllowed in interface DBManUserContextI

checkServerLockActionsAllowed

public boolean checkServerLockActionsAllowed()

Specified by:

checkServerLockActionsAllowed in interface DBManUserContextI

checkServerShutdownActionsAllowed

public boolean checkServerShutdownActionsAllowed()

Specified by:

checkServerShutdownActionsAllowed in interface DBManUserContextI

checkSendingSystemMessagesAllowed

public boolean checkSendingSystemMessagesAllowed()

Specified by:

checkSendingSystemMessagesAllowed in interface DBManUserContextI

checkDemandForcedClientDisconnectAllowed

public boolean checkDemandForcedClientDisconnectAllowed()

Specified by:

checkDemandForcedClientDisconnectAllowed in interface DBManUserContextI

getBLOB

public byte[] getBLOB(java.lang.Long id)

Specified by:

getBLOB in interface DBManUserContextI

getBLOB

public byte[] getBLOB(java.lang.Long id,
                      java.lang.Long backuppingBPId)

Specified by:

getBLOB in interface DBManUserContextI

getBLOBAsStream

public InputStreamWrapper getBLOBAsStream(java.lang.Long id)

Specified by:

getBLOBAsStream in interface DBManUserContextI

getBLOBAsStream

public InputStreamWrapper getBLOBAsStream(java.lang.Long id,
                                          java.lang.Long backuppingBPId)

Specified by:

getBLOBAsStream in interface DBManUserContextI

getBLOB

public long getBLOB(java.lang.Long id,
                    java.io.OutputStream os)

Specified by:

getBLOB in interface DBManUserContextI

getBLOB

public long getBLOB(java.lang.Long id,
                    java.io.OutputStream os,
                    boolean closeOS)

Specified by:

getBLOB in interface DBManUserContextI

getBLOB

public long getBLOB(java.lang.Long id,
                    java.io.OutputStream os,
                    boolean closeOS,
                    java.lang.Long backuppingBPId)

Specified by:

getBLOB in interface DBManUserContextI

getBLOB

public long getBLOB(java.lang.Long id,
                    java.io.DataOutput os)

Specified by:

getBLOB in interface DBManUserContextI

getBLOB

public long getBLOB(java.lang.Long id,
                    java.io.DataOutput os,
                    boolean closeOS)

Specified by:

getBLOB in interface DBManUserContextI

getBLOB

public long getBLOB(java.lang.Long id,
                    java.io.DataOutput os,
                    boolean closeOS,
                    java.lang.Long backuppingBPId)

Specified by:

getBLOB in interface DBManUserContextI

getBLOBInfo

public VFile getBLOBInfo(java.lang.Long id)

Specified by:

getBLOBInfo in interface DBManUserContextI

getBLOBInfo

public VFile getBLOBInfo(java.lang.Long id,
                         java.lang.Long backuppingBPId)

Specified by:

getBLOBInfo in interface DBManUserContextI

hasBLOB

public boolean hasBLOB(java.lang.Long id)

Specified by:

hasBLOB in interface DBManUserContextI

hasBLOB

public boolean hasBLOB(java.lang.Long id,
                       java.lang.Long backuppingBPId)

Specified by:

hasBLOB in interface DBManUserContextI

haveBLOB

public java.util.BitSet haveBLOB(long[] ids)

Specified by:

haveBLOB in interface DBManUserContextI

getBLOBBOIdsForIntitialBLOBCopy

public InitialBLOBTransferMetaDataContainer getBLOBBOIdsForIntitialBLOBCopy(java.util.Map idsAndVFilesOnSyncNode,
                                                                            java.util.List pendingBLOBChangeBOIdsOnSyncNode,
                                                                            java.util.List pendingBLOBChangeBOIdsOnAuthNode)
                                                                     throws java.io.IOException

Specified by:

getBLOBBOIdsForIntitialBLOBCopy in interface DBManUserContextI

Throws:

java.io.IOException

getSchema

public SchemaI getSchema()

Specified by:

getSchema in interface DBManUserContextI

getNextId

public java.lang.Long getNextId()

Specified by:

getNextId in interface DBManUserContextI

getIdRange

public KeyRange getIdRange(long size)

Specified by:

getIdRange in interface DBManUserContextI

query

public de.ipcon.db.core.QueryResultsI query(java.lang.String t)

query

public de.ipcon.db.core.QueryResultsI query(java.lang.String t,
                                            java.lang.Object[] pvals)

queryBO

public java.util.List queryBO(java.lang.String t)

Specified by:

queryBO in interface DBManUserContextI

queryBO

public java.util.List queryBO(java.lang.String t,
                              java.lang.Object[] pvals)

Specified by:

queryBO in interface DBManUserContextI

exists

public boolean exists(java.lang.Long id)

Specified by:

exists in interface DBManUserContextI

exists

public boolean exists(java.lang.Long id,
                      java.lang.Class<? extends BOI> classtip)

Specified by:

exists in interface DBManUserContextI

loadBO

public BO loadBO(java.lang.Long id)

Specified by:

loadBO in interface DBManUserContextI

loadBO

public BO loadBO(java.lang.Long id,
                 java.lang.Class<? extends BOI> classtip)

Specified by:

loadBO in interface DBManUserContextI

loadBOs

public BO[] loadBOs(java.lang.Long[] ids)

Specified by:

loadBOs in interface DBManUserContextI

loadBOs

public BO[] loadBOs(java.lang.Long[] ids,
                    java.lang.Class<? extends BOI> classtip)

Specified by:

loadBOs in interface DBManUserContextI

saveBO

public TransactionAnswer saveBO(Transaction tx,
                                SerializedTransaction stx,
                                PersistenceHandlerI ph,
                                int lockTimeout,
                                int retries,
                                SecureObjectOutputI out)

Description copied from interface: DBManUserContextI

Persists the changes recorded in the passed Transaction tx to the database.

Specified by:

saveBO in interface DBManUserContextI

Parameters:

tx - the Transaction to save

stx - a SerializedTransaction that shall be closed additionally after successful saving

ph - the PersistenceHandlerI to use for persisting the changes

lockTimeout - time to wait in seconds until a locking error is reported in case some object is already locked by another thread; defaults to -1. Zero or less for no waiting, i.e. immediate timeout (or rather the defined lock-timeout of JDO, which defaults to 30s), an infinite value for no timeout.

retries - an int reflecting the number of retries that shall be attempted before saving is aborted

out - a SecureObjectOutputI the TransactionAnswer shall be written to

Returns:

the TransactionAnswer resulting from the save process, or null if no saving was actually done for some reason

checkCreateRightForSavingOfTransaction

public void checkCreateRightForSavingOfTransaction(Transaction tx)

Description copied from interface: DBManVetoHandlerI

Checks if the current user has the necessary rights to create the objects within the given transaction.

Specified by:

checkCreateRightForSavingOfTransaction in interface DBManVetoHandlerI

Parameters:

tx - The transaction containing the objects to be created.

checkUpdateAndDeleteRightsForSavingOfTransaction

public void checkUpdateAndDeleteRightsForSavingOfTransaction(Transaction tx)

Description copied from interface: DBManVetoHandlerI

Checks if the current user has the necessary rights to update or delete the objects within the given transaction.

Specified by:

checkUpdateAndDeleteRightsForSavingOfTransaction in interface DBManVetoHandlerI

Parameters:

tx - The transaction containing the objects to be updated or deleted.

login

public void login(BackendSessionI session)
           throws AuthenticationException

Specified by:

login in interface DBManUserContextI

Throws:

AuthenticationException

addSubscription

public void addSubscription(java.lang.String key,
                            DBManEventFilter filter)

Specified by:

addSubscription in interface DBManUserContextI

removeSubscription

public void removeSubscription(java.lang.String key)

Specified by:

removeSubscription in interface DBManUserContextI

applyFilters

public DBManEvent applyFilters(DBManEvent evt)

Specified by:

applyFilters in interface DBManUserContextI

areGratuitousLocalConnectionsAvailable

public boolean areGratuitousLocalConnectionsAvailable()

Specified by:

areGratuitousLocalConnectionsAvailable in interface DBManUserContextI