de.ipcon.db

Class DBManUserContextImpl

java.lang.Object

de.ipcon.db.DBManUserContextImpl

All Implemented Interfaces:

DBManUserContextI, DBManVetoHandlerI, ServerAdminAuthorizerI

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() Checks whether the current context is authorized to force-disconnect clients.
PermissionHandlerDecisionI	checkReadAllowed(BO bo)
PermissionHandlerDecisionI	checkReadAllowed(BO bo, java.lang.String attributeName)
boolean	checkSendingSystemMessagesAllowed() Checks whether the current context is authorized to broadcast system messages.
boolean	checkServerLockActionsAllowed() Checks whether the current context is authorized to perform server lock actions.
boolean	checkServerShutdownActionsAllowed() Checks whether the current context is authorized to initiate server shutdown actions.
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()
L10nCurrentLocaleProviderI	getCurrentLocaleProvider()
Benutzer	getCurrentUser()
java.util.Locale	getCurrentUserLocale()
java.lang.String	getCurrentUserName()
java.lang.String	getCurrentUserRemark()
KeyRange	getIdRange(long size)
java.lang.Long	getNextId()
PermissionHandlerI	getPermissionHandler()
PersistenceHandlerI	getPersistenceHandler()
PersistenceHandlerI	getPersistenceHandlerForSaving()
SchemaI	getSchema()
Benutzer	getServerAdminAuthorizerCheckedUser() Returns the user entity whose permissions are currently evaluated by this authorizer, irrespective of whether the checks pass or fail.
boolean	hasBLOB(java.lang.Long id)
boolean	hasBLOB(java.lang.Long id, java.lang.Long backuppingBPId)
java.util.BitSet	haveBLOB(long[] ids)
void	init(Benutzer user, PermissionHandlerI ph) This is the method to use if the user is already logged in or does not require an additional login (e.g. through cauldron), and a permission handler is already available
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 s)
de.ipcon.db.core.QueryResultsI	query(java.lang.String s, 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 to the database within this user context.
void	setCurrentUserLocale(java.util.Locale locale)

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

getCurrentUserLocale

public java.util.Locale getCurrentUserLocale()

Specified by:

getCurrentUserLocale in interface DBManUserContextI

setCurrentUserLocale

public void setCurrentUserLocale(java.util.Locale locale)

Specified by:

setCurrentUserLocale in interface DBManUserContextI

getCurrentLocaleProvider

public L10nCurrentLocaleProviderI getCurrentLocaleProvider()

Specified by:

getCurrentLocaleProvider 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()

Description copied from interface: ServerAdminAuthorizerI

Checks whether the current context is authorized to perform server lock actions.

Specified by:

checkServerLockActionsAllowed in interface ServerAdminAuthorizerI

Returns:

true if server lock actions are permitted; false otherwise

checkServerShutdownActionsAllowed

public boolean checkServerShutdownActionsAllowed()

Description copied from interface: ServerAdminAuthorizerI

Checks whether the current context is authorized to initiate server shutdown actions.

Specified by:

checkServerShutdownActionsAllowed in interface ServerAdminAuthorizerI

Returns:

true if server shutdown actions are permitted; false otherwise

checkSendingSystemMessagesAllowed

public boolean checkSendingSystemMessagesAllowed()

Description copied from interface: ServerAdminAuthorizerI

Checks whether the current context is authorized to broadcast system messages.

Specified by:

checkSendingSystemMessagesAllowed in interface ServerAdminAuthorizerI

Returns:

true if sending system messages is permitted; false otherwise

checkDemandForcedClientDisconnectAllowed

public boolean checkDemandForcedClientDisconnectAllowed()

Description copied from interface: ServerAdminAuthorizerI

Checks whether the current context is authorized to force-disconnect clients.

Specified by:

checkDemandForcedClientDisconnectAllowed in interface ServerAdminAuthorizerI

Returns:

true if demanding forced client disconnections is permitted; false otherwise

getServerAdminAuthorizerCheckedUser

public Benutzer getServerAdminAuthorizerCheckedUser()

Description copied from interface: ServerAdminAuthorizerI

Returns the user entity whose permissions are currently evaluated by this authorizer, irrespective of whether the checks pass or fail.

Specified by:

getServerAdminAuthorizerCheckedUser in interface ServerAdminAuthorizerI

Returns:

the checked user (Benutzer) instance, or null if no user context exists

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 s)

query

public de.ipcon.db.core.QueryResultsI query(java.lang.String s,
                                            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 to the database within this user context.

Specified by:

saveBO in interface DBManUserContextI

Parameters:

tx - the Transaction containing modified or newly created business objects

stx - optional SerializedTransaction to be closed additionally upon successful commit

ph - the PersistenceHandlerI driving the low-level persistence mapping

lockTimeout - timeout in seconds when waiting for locked database records; 0 indicates no timeout (wait indefinitely), values > 0 specify an explicit duration in seconds, and values < 0 retain the underlying persistence default (30 seconds)

retries - maximum retry attempts on lock contention or serialization conflicts before aborting

out - optional SecureObjectOutputI stream to write the TransactionAnswer to

Returns:

the resulting TransactionAnswer, or null if persistence was skipped

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

init

public void init(Benutzer user,
                 PermissionHandlerI ph)

This is the method to use if the user is already logged in or does not require an additional login (e.g. through cauldron), and a permission handler is already available

Specified by:

init in interface DBManUserContextI

Parameters:

user - the user object associated with the permission handler

ph - the permission handler to use

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