de.ipcon.db.protocol

Class BackendConnection

java.lang.Object

de.ipcon.db.protocol.AbstractBackendConnection

de.ipcon.db.protocol.BackendConnection

All Implemented Interfaces:

ExpiringTokenStorageProviderI, FTSTermInfoProviderI, FulltextSearcherI, ServerConnectionI, L10nPackProviderI

public class BackendConnection
extends AbstractBackendConnection
implements ServerConnectionI

Field Summary

Fields inherited from interface de.ipcon.db.protocol.ServerConnectionI

EMPTY_ARRAY

Constructor Summary

Constructors

Constructor and Description
BackendConnection(BackendConnectionManagerI m, java.lang.String s, ServerConnectionInfoReceiverI r, java.lang.Long t, TransportProviderFactoryI _transportProviderFactory, boolean existsAlternativeConnection)

Method Summary

Modifier and Type	Method and Description
Anmeldung	authenticateImpl(java.lang.String user, java.lang.String pass)
void	cancelForcedClientDisconnect()
void	cancelForcedClientDisconnect(java.util.Map msgClients)
boolean	checkServerConnectivity()
boolean	checkServerConnectivity(boolean force)
void	copyRemoteBLOBsToLocalFileVault(ServerFileVaultI serverFileVault, java.util.List<java.lang.Long> pendingBLOBChangeBOIdsLocal, java.lang.Long lastAuthNodeBTId)
java.lang.String	createExpiringToken(java.lang.String serviceName, byte[] value, long expiryms) Works like @see #createExpiringToken(String,String,byte[],long), but creates a non-conflicting tokenName within the store, stores the value and returns the chosen tokenName.
void	createExpiringToken(java.lang.String serviceName, java.lang.String tokenName, byte[] value, long expiryms) Creates a time limited association of the given service and token name to a byte array value (usually a key).
void	demandForcedClientDisconnect(int cSecsDelay)
void	demandForcedClientDisconnect(int cSecsDelay, java.lang.String msg)
void	demandForcedClientDisconnect(int cSecsDelay, java.lang.String msg, java.util.Map msgClients)
byte[]	destroyExpiringToken(java.lang.String serviceName, java.lang.String tokenName) Destroys a time limited token immediately
void	disconnect()
void	execute(BatchedBackendRequestI[] bbrs)
boolean	exists(java.lang.Long id)
boolean	exists(java.lang.Long id, java.lang.Class<? extends BOI> classtip)
java.lang.String	getAddress()
java.lang.String[]	getAvailableLocalesForUserInterface()
byte[]	getBLOB(java.lang.Long id)
long	getBLOB(java.lang.Long id, java.io.DataOutput dataOutput)
long	getBLOB(java.lang.Long id, java.io.DataOutput dataOutput, boolean closeOS)
long	getBLOB(java.lang.Long id, java.io.DataOutput dataOutput, 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)
VFile	getBLOBInfo(java.lang.Long id)
VFile	getBLOBInfo(java.lang.Long id, java.lang.Long backuppingBPId)
BO	getBO(java.lang.Long id)
BO	getBO(java.lang.Long id, java.lang.Class<? extends BOI> classtip)
BO[]	getBOs(long[] ids)
BO[]	getBOs(java.lang.Long[] ids)
BO[]	getBOs(long[] ids, java.lang.Class<? extends BOI> classtip)
BO[]	getBOs(java.lang.Long[] ids, java.lang.Class<? extends BOI> classtip)
ClientSessionInfo[]	getClientSessionInfos()
int	getComplexCommandsTimeoutSeconds()
int	getConciseCommandsTimeoutSeconds()
CryptoHandlerI	getCryptoHandler()
DBManInfo	getDBManInfo()
java.lang.String	getDomain()
long[]	getIdList(java.lang.String ftClauses)
long[]	getIdList(java.lang.String ftClauses, java.lang.String classname)
java.lang.String	getIdListAsString(java.lang.String ftClauses)
java.lang.String	getIdListAsString(java.lang.String ftClauses, java.lang.String classname)
KeyRange	getIdRange(long size)
java.lang.String[]	getInitialAvailableLocalesForUserInterface()
java.lang.String	getInstanceName()
L10nInfoContainer	getL10nPackPreload(java.lang.String locale)
L10nPack[]	getL10nPacks(java.lang.String[] packNames, java.lang.String localeName)
L10nPathEntry[]	getL10nPath()
java.lang.String	getL10nViaString()
Struktur[]	getLazyStruktur(java.lang.Long botId)
Benutzer	getLoggedInUser()
int	getMaxPool()
int	getMediumCommandsTimeoutSeconds()
int	getMinPool()
java.lang.Long	getNextId()
int	getNextLegacySlot()
PermissionHandlerWithUserI	getPermissionHandler()
int	getPort()
java.lang.Integer	getPosition()
BO[]	getRelationBOs(java.lang.Long id, java.lang.Class<? extends BOI> classtip, java.lang.String attributeName)
SchemaI	getRemoteSchema()
java.lang.String	getRemoteSchemaFingerprint()
java.lang.String	getRemoteSchemaUIDs()
java.lang.String	getRemoteSchemaVersion()
int	getRoundTrips()
java.net.InetAddress	getServerInetAddress()
java.lang.String	getServerName()
java.lang.String	getServerName(boolean evenIfNoActiveConnection)
java.lang.Long	getSessionId(boolean blockUntilAvailable)
BackendSessionInfo[]	getSessionInfos()
int	getSimpleCommandsTimeoutSeconds()
int	getSimpleCommandsTimeoutSeconds(int customTimeout)
long	getSlowConnectionThreshold()
java.lang.String	getSubVersion()
TermInfoI[]	getTermsFromServer()
TermInfoI[]	getTermsFromServer(EntityI entity)
TermInfoI[]	getTermsFromServer(EntityI entity, java.lang.String regex)
TermInfoI[]	getTermsFromServer(EntityI entity, java.lang.String regex, int size)
TermInfoI[]	getTermsFromServer(EntityI entity, java.lang.String regex, int size, boolean includeDeleted)
TermInfoI[]	getTermsFromServer(EntityI entity, java.lang.String regex, int size, boolean includeDeleted, java.lang.String[] propertyNames)
TermInfoI[]	getTermsFromServer(EntityI entity, java.lang.String regex, int size, boolean includeDeleted, java.lang.String[] propertyNames, boolean sortByName)
TermInfoI[]	getTermsFromServer(EntityI entity, java.lang.String regex, int size, boolean includeDeleted, java.lang.String[] propertyNames, boolean sortByName, boolean withSubEntities)
TermInfoI[]	getTermsRaw()
TermInfoI[]	getTermsRaw(EntityI entity)
TermInfoI[]	getTermsRaw(EntityI entity, int size)
TermInfoI[]	getTermsRaw(EntityI entity, int size, boolean includeDeleted)
TermInfoI[]	getTermsRaw(EntityI entity, int size, boolean includeDeleted, java.lang.String[] propertyNames)
TermInfoI[]	getTermsRaw(EntityI entity, int size, boolean includeDeleted, java.lang.String[] propertyNames, boolean sortByName)
TermInfoI[]	getTermsRaw(EntityI entity, int size, boolean includeDeleted, java.lang.String[] propertyNames, boolean sortByName, boolean withSubEntities)
java.lang.String[]	getTermSuggestions(EntityI entity, java.lang.String term)
java.lang.String[]	getTermSuggestions(EntityI entity, java.lang.String term, int size)
java.lang.String[]	getTermSuggestions(EntityI entity, java.lang.String term, int size, boolean includeDeleted)
java.lang.String[]	getTermSuggestions(EntityI entity, java.lang.String term, int size, boolean includeDeleted, boolean morePopular)
java.lang.String[]	getTermSuggestions(EntityI entity, java.lang.String term, int size, boolean includeDeleted, boolean morePopular, float accuracy)
java.lang.String[]	getTermSuggestions(EntityI entity, java.lang.String term, int size, boolean includeDeleted, boolean morePopular, float accuracy, java.lang.String propertyName)
java.lang.String[]	getTermSuggestions(EntityI entity, java.lang.String term, int size, boolean includeDeleted, boolean morePopular, float accuracy, java.lang.String propertyName, boolean withSubEntities)
java.lang.String	getURLPrefix()
boolean	hasBLOB(java.lang.Long id)
boolean	hasBLOB(java.lang.Long id, java.lang.Long backuppingBPId)
java.util.BitSet	haveBLOB(long[] ids)
void	initiateServerShutdown()
void	initiateServerShutdown(int cSecsDelay)
void	initiateServerShutdown(int cSecsDelay, java.lang.String msg)
void	initSession() Pings the server and initializes a new session on the server.
boolean	isConnected()
boolean	isFTSActive()
boolean	isFTSAvailable()
boolean	isMemoryTightClient()
boolean	isNotificationSystemActivated()
boolean	isOperational()
boolean	isServerAuthoritativeSyncServer()
boolean	isTls()
int	legacySlotAccumulator(int i)
void	lockServer()
void	parseConnectionInfosFromServerUrl() Parses the given String and sets connection infos the given String contains.
boolean	ping() Pings the server.
BatchedBackendRequestI	prepareQuery(java.lang.String s)
BatchedBackendRequestI	prepareQuery(java.lang.String s, java.lang.Object[] o)
de.ipcon.db.core.QueryResultsI	query(java.lang.String s)
de.ipcon.db.core.QueryResultsI	query(java.lang.String s, java.lang.Object[] o)
de.ipcon.db.core.QueryResultsI	queryRelation(long id, java.lang.Class<? extends BOI> classtip, java.lang.String attributeName)
void	resetPassword(java.lang.String username)
byte[]	retrieveExpiringToken(java.lang.String serviceName, java.lang.String tokenName) Retrieves a time limited token
TransactionAnswer	saveBO(Transaction tx) Persists the changes recorded in the passed Transaction tx to the database.
TransactionAnswer	saveBO(Transaction tx, int lockTimeout) Persists the changes recorded in the passed Transaction tx to the database.
TransactionAnswer	saveBO(Transaction tx, int lockTimeout, int retries) Persists the changes recorded in the passed Transaction tx to the database.
void	sendSystemMessage(java.lang.String msg)
void	sendSystemMessage(java.lang.String msg, java.util.Map msgClients)
void	setDomain(java.lang.String $44)
void	setMaxPool(int $47)
void	setMinPool(int $46)
void	setPort(int $45)
void	setPosition(java.lang.Integer $50)
void	setSessionLocale(java.util.Locale locale) Marks a client-side locale change on the server, so the server sends messages and exceptions in the correct locale to the client.
void	setSubVersion(java.lang.String $48)
void	setTls(boolean $49)
void	skipRecheckConnection()
void	stopServerShutdown()
void	storeRemoteBLOBs(ServerFileVaultI serverFileVault, BLOBInputI in)
void	subscribeEventsAtBackend(DBManEventSubscriptionI sub)
java.lang.Long	testAuth(Anmeldung anmeldung)
boolean	testAuth(de.ipcon.db.core.PasswortUeberpruefung pu)
java.lang.String	toString()
void	unlockServer()
void	unsubscribeEventsAtBackend(DBManEventSubscriptionI[] removed)
ServerConnectionInfo	updateServerConnectionInfo()
void	updateStructureReadAccessStatistics(java.util.Map<java.lang.Long,java.lang.Integer> statistics) Pushes the passed read access statistics for structures to the server This method pushes the passed read access statistics map to the server, where the keys are structure Ids and the values are read access counts.
boolean	useOnlyDefaultPlafThemes()

Methods inherited from class de.ipcon.db.protocol.AbstractBackendConnection

authenticate, connect, endUOW, execute, getL10nPack, getLatency, getManager, getNodeNumber, getServerConnectionInfoReceiver, getServerUrl, getTerms, getTerms, getTerms, getTerms, getTerms, getTerms, getTerms, getTerms, getToken, handleDBManEvent, hasIncompatibleServerProtocolVersion, isDead, isDisconnected, isLoggedIn, markConnected, markDead, markDisconnected, markUsable, query, queryBO, queryBO, queryBO, receiving, reregisterEventsAtBackend, setLatency, setProgressAnimator, startUOW, subscribeEvents, unsubscribeEvents, unsubscribeEvents, waiting

Methods inherited from class java.lang.Object

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

Methods inherited from interface de.ipcon.db.protocol.ServerConnectionI

authenticate, connect, execute, getManager, getNodeNumber, getServerConnectionInfoReceiver, getServerUrl, getToken, handleDBManEvent, hasIncompatibleServerProtocolVersion, isDead, isLoggedIn, markDead, query, queryBO, queryBO, queryBO, reregisterEventsAtBackend, setProgressAnimator, unsubscribeEvents

Methods inherited from interface de.ipcon.tools.L10nPackProviderI

getL10nPack, prefetchL10nPacks

Methods inherited from interface de.ipcon.db.fulltext.FulltextSearcherI

getTerms, getTerms, getTerms, getTerms, getTerms, getTerms, getTerms, getTerms

Constructor Detail

BackendConnection

public BackendConnection(BackendConnectionManagerI m,
                         java.lang.String s,
                         ServerConnectionInfoReceiverI r,
                         java.lang.Long t,
                         TransportProviderFactoryI _transportProviderFactory,
                         boolean existsAlternativeConnection)

Method Detail

isMemoryTightClient

public boolean isMemoryTightClient()

Specified by:

isMemoryTightClient in interface ServerConnectionI

getNextLegacySlot

public int getNextLegacySlot()

legacySlotAccumulator

public int legacySlotAccumulator(int i)

getConciseCommandsTimeoutSeconds

public int getConciseCommandsTimeoutSeconds()

Specified by:

getConciseCommandsTimeoutSeconds in interface ServerConnectionI

getSimpleCommandsTimeoutSeconds

public int getSimpleCommandsTimeoutSeconds()

Specified by:

getSimpleCommandsTimeoutSeconds in interface ServerConnectionI

getSimpleCommandsTimeoutSeconds

public int getSimpleCommandsTimeoutSeconds(int customTimeout)

getMediumCommandsTimeoutSeconds

public int getMediumCommandsTimeoutSeconds()

Specified by:

getMediumCommandsTimeoutSeconds in interface ServerConnectionI

getComplexCommandsTimeoutSeconds

public int getComplexCommandsTimeoutSeconds()

Specified by:

getComplexCommandsTimeoutSeconds in interface ServerConnectionI

getSlowConnectionThreshold

public long getSlowConnectionThreshold()

parseConnectionInfosFromServerUrl

public void parseConnectionInfosFromServerUrl()

Parses the given String and sets connection infos the given String contains.

getServerInetAddress

public java.net.InetAddress getServerInetAddress()

Specified by:

getServerInetAddress in interface ServerConnectionI

getServerName

public java.lang.String getServerName()

Specified by:

getServerName in interface ServerConnectionI

getServerName

public java.lang.String getServerName(boolean evenIfNoActiveConnection)

Specified by:

getServerName in interface ServerConnectionI

Specified by:

getServerName in class AbstractBackendConnection

getInstanceName

public java.lang.String getInstanceName()
                                 throws ServerConnectionException

Specified by:

getInstanceName in interface ServerConnectionI

Throws:

ServerConnectionException

getDBManInfo

public DBManInfo getDBManInfo()
                       throws ServerConnectionException

Specified by:

getDBManInfo in interface ServerConnectionI

Throws:

ServerConnectionException

isServerAuthoritativeSyncServer

public boolean isServerAuthoritativeSyncServer()
                                        throws ServerConnectionException

Specified by:

isServerAuthoritativeSyncServer in interface ServerConnectionI

Throws:

ServerConnectionException

isNotificationSystemActivated

public boolean isNotificationSystemActivated()

Specified by:

isNotificationSystemActivated in interface ServerConnectionI

getSessionInfos

public BackendSessionInfo[] getSessionInfos()

Specified by:

getSessionInfos in interface ServerConnectionI

updateServerConnectionInfo

public ServerConnectionInfo updateServerConnectionInfo()
                                                throws ServerConnectionException

Specified by:

updateServerConnectionInfo in interface ServerConnectionI

Throws:

ServerConnectionException

initSession

public void initSession()
                 throws ServerConnectionException

Pings the server and initializes a new session on the server.

Specified by:

initSession in interface ServerConnectionI

Throws:

ServerConnectionException

ping

public boolean ping()
             throws ServerConnectionException

Pings the server.

Throws:

ServerConnectionException

isConnected

public boolean isConnected()

Specified by:

isConnected in interface ServerConnectionI

Overrides:

isConnected in class AbstractBackendConnection

disconnect

public void disconnect()

Specified by:

disconnect in interface ServerConnectionI

Overrides:

disconnect in class AbstractBackendConnection

getSessionId

public java.lang.Long getSessionId(boolean blockUntilAvailable)

Specified by:

getSessionId in interface ServerConnectionI

checkServerConnectivity

public boolean checkServerConnectivity()
                                throws ServerConnectionException

Specified by:

checkServerConnectivity in interface ServerConnectionI

Throws:

ServerConnectionException

checkServerConnectivity

public boolean checkServerConnectivity(boolean force)
                                throws ServerConnectionException

Specified by:

checkServerConnectivity in interface ServerConnectionI

Throws:

ServerConnectionException

skipRecheckConnection

public void skipRecheckConnection()

Specified by:

skipRecheckConnection in interface ServerConnectionI

authenticateImpl

public Anmeldung authenticateImpl(java.lang.String user,
                                  java.lang.String pass)
                           throws AuthenticationException,
                                  ServerConnectionException

Specified by:

authenticateImpl in class AbstractBackendConnection

Throws:

AuthenticationException

ServerConnectionException

getLoggedInUser

public Benutzer getLoggedInUser()

Specified by:

getLoggedInUser in interface ServerConnectionI

resetPassword

public void resetPassword(java.lang.String username)

Specified by:

resetPassword in interface ServerConnectionI

testAuth

public java.lang.Long testAuth(Anmeldung anmeldung)
                        throws ServerConnectionException

Specified by:

testAuth in interface ServerConnectionI

Throws:

ServerConnectionException

testAuth

public boolean testAuth(de.ipcon.db.core.PasswortUeberpruefung pu)
                 throws ServerConnectionException

Specified by:

testAuth in interface ServerConnectionI

Throws:

ServerConnectionException

subscribeEventsAtBackend

public void subscribeEventsAtBackend(DBManEventSubscriptionI sub)
                              throws ServerConnectionException

Specified by:

subscribeEventsAtBackend in interface ServerConnectionI

Throws:

ServerConnectionException

unsubscribeEventsAtBackend

public void unsubscribeEventsAtBackend(DBManEventSubscriptionI[] removed)
                                throws ServerConnectionException

Specified by:

unsubscribeEventsAtBackend in interface ServerConnectionI

Throws:

ServerConnectionException

getCryptoHandler

public CryptoHandlerI getCryptoHandler()

Specified by:

getCryptoHandler in interface ServerConnectionI

getPermissionHandler

public PermissionHandlerWithUserI getPermissionHandler()

Specified by:

getPermissionHandler in interface ServerConnectionI

getRemoteSchema

public SchemaI getRemoteSchema()
                        throws ServerConnectionException

Specified by:

getRemoteSchema in interface ServerConnectionI

Throws:

ServerConnectionException

getRemoteSchemaFingerprint

public java.lang.String getRemoteSchemaFingerprint()
                                            throws ServerConnectionException

Specified by:

getRemoteSchemaFingerprint in interface ServerConnectionI

Throws:

ServerConnectionException

getRemoteSchemaVersion

public java.lang.String getRemoteSchemaVersion()
                                        throws ServerConnectionException

Specified by:

getRemoteSchemaVersion in interface ServerConnectionI

Throws:

ServerConnectionException

getRemoteSchemaUIDs

public java.lang.String getRemoteSchemaUIDs()
                                     throws ServerConnectionException

Specified by:

getRemoteSchemaUIDs in interface ServerConnectionI

Throws:

ServerConnectionException

getLazyStruktur

public Struktur[] getLazyStruktur(java.lang.Long botId)
                           throws ServerConnectionException

Specified by:

getLazyStruktur in interface ServerConnectionI

Throws:

ServerConnectionException

getInitialAvailableLocalesForUserInterface

public java.lang.String[] getInitialAvailableLocalesForUserInterface()

Specified by:

getInitialAvailableLocalesForUserInterface in interface ServerConnectionI

useOnlyDefaultPlafThemes

public boolean useOnlyDefaultPlafThemes()

Specified by:

useOnlyDefaultPlafThemes in interface ServerConnectionI

getAvailableLocalesForUserInterface

public java.lang.String[] getAvailableLocalesForUserInterface()
                                                       throws ServerConnectionException

Specified by:

getAvailableLocalesForUserInterface in interface ServerConnectionI

Throws:

ServerConnectionException

getL10nPackPreload

public L10nInfoContainer getL10nPackPreload(java.lang.String locale)
                                     throws IRuntimeException,
                                            ServerConnectionException

Specified by:

getL10nPackPreload in interface ServerConnectionI

Throws:

IRuntimeException

ServerConnectionException

getL10nViaString

public java.lang.String getL10nViaString()

Specified by:

getL10nViaString in interface ServerConnectionI

Specified by:

getL10nViaString in interface L10nPackProviderI

updateStructureReadAccessStatistics

public void updateStructureReadAccessStatistics(java.util.Map<java.lang.Long,java.lang.Integer> statistics)

Description copied from interface: ServerConnectionI

Pushes the passed read access statistics for structures to the server

This method pushes the passed read access statistics map to the server, where the keys are structure Ids and the values are read access counts.

Specified by:

updateStructureReadAccessStatistics in interface ServerConnectionI

Parameters:

statistics - a map containing structure Ids as keys and their read access counts as values.

setSessionLocale

public void setSessionLocale(java.util.Locale locale)

Description copied from interface: ServerConnectionI

Marks a client-side locale change on the server, so the server sends messages and exceptions in the correct locale to the client.

Specified by:

setSessionLocale in interface ServerConnectionI

getBLOB

public byte[] getBLOB(java.lang.Long id)
               throws IRuntimeException,
                      MissingBLOBException,
                      ServerConnectionException

Specified by:

getBLOB in interface ServerConnectionI

Throws:

IRuntimeException

MissingBLOBException

ServerConnectionException

getBLOB

public byte[] getBLOB(java.lang.Long id,
                      java.lang.Long backuppingBPId)
               throws IRuntimeException,
                      MissingBLOBException,
                      ServerConnectionException

Specified by:

getBLOB in interface ServerConnectionI

Throws:

IRuntimeException

MissingBLOBException

ServerConnectionException

getBLOB

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

Specified by:

getBLOB in interface ServerConnectionI

getBLOB

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

Specified by:

getBLOB in interface ServerConnectionI

getBLOB

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

Specified by:

getBLOB in interface ServerConnectionI

getBLOB

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

Specified by:

getBLOB in interface ServerConnectionI

getBLOB

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

Specified by:

getBLOB in interface ServerConnectionI

getBLOB

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

Specified by:

getBLOB in interface ServerConnectionI

getBLOBInfo

public VFile getBLOBInfo(java.lang.Long id)
                  throws IRuntimeException,
                         ServerConnectionException

Specified by:

getBLOBInfo in interface ServerConnectionI

Throws:

IRuntimeException

ServerConnectionException

getBLOBInfo

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

Specified by:

getBLOBInfo in interface ServerConnectionI

Throws:

IRuntimeException

ServerConnectionException

hasBLOB

public boolean hasBLOB(java.lang.Long id)
                throws IRuntimeException,
                       ServerConnectionException

Specified by:

hasBLOB in interface ServerConnectionI

Throws:

IRuntimeException

ServerConnectionException

hasBLOB

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

Specified by:

hasBLOB in interface ServerConnectionI

Throws:

IRuntimeException

ServerConnectionException

haveBLOB

public java.util.BitSet haveBLOB(long[] ids)
                          throws IRuntimeException,
                                 ServerConnectionException

Specified by:

haveBLOB in interface ServerConnectionI

Throws:

IRuntimeException

ServerConnectionException

copyRemoteBLOBsToLocalFileVault

public void copyRemoteBLOBsToLocalFileVault(ServerFileVaultI serverFileVault,
                                            java.util.List<java.lang.Long> pendingBLOBChangeBOIdsLocal,
                                            java.lang.Long lastAuthNodeBTId)
                                     throws IRuntimeException,
                                            ServerConnectionException

Specified by:

copyRemoteBLOBsToLocalFileVault in interface ServerConnectionI

Throws:

IRuntimeException

ServerConnectionException

storeRemoteBLOBs

public void storeRemoteBLOBs(ServerFileVaultI serverFileVault,
                             BLOBInputI in)

saveBO

public TransactionAnswer saveBO(Transaction tx)
                         throws IRuntimeException,
                                ObjectNotPersistentException,
                                ObjectsNotPersistentException,
                                SaveException,
                                ServerConnectionException,
                                FeatureNotAvailableException

Description copied from interface: ServerConnectionI

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

Specified by:

saveBO in interface ServerConnectionI

Parameters:

tx - the Transaction to save

Returns:

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

Throws:

IRuntimeException

ObjectNotPersistentException

ObjectsNotPersistentException

SaveException

ServerConnectionException

FeatureNotAvailableException

saveBO

public TransactionAnswer saveBO(Transaction tx,
                                int lockTimeout)
                         throws IRuntimeException,
                                ObjectNotPersistentException,
                                ObjectsNotPersistentException,
                                SaveException,
                                ServerConnectionException,
                                FeatureNotAvailableException

Description copied from interface: ServerConnectionI

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

Specified by:

saveBO in interface ServerConnectionI

Parameters:

tx - the Transaction to save

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.

Returns:

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

Throws:

IRuntimeException

ObjectNotPersistentException

ObjectsNotPersistentException

SaveException

ServerConnectionException

FeatureNotAvailableException

saveBO

public TransactionAnswer saveBO(Transaction tx,
                                int lockTimeout,
                                int retries)
                         throws IRuntimeException,
                                ObjectNotPersistentException,
                                ObjectsNotPersistentException,
                                SaveException,
                                ServerConnectionException,
                                FeatureNotAvailableException

Description copied from interface: ServerConnectionI

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

Specified by:

saveBO in interface ServerConnectionI

Parameters:

tx - the Transaction to save

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

Returns:

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

Throws:

IRuntimeException

ObjectNotPersistentException

ObjectsNotPersistentException

SaveException

ServerConnectionException

FeatureNotAvailableException

getIdRange

public KeyRange getIdRange(long size)
                    throws IRuntimeException,
                           ServerConnectionException

Specified by:

getIdRange in interface ServerConnectionI

Throws:

IRuntimeException

ServerConnectionException

getNextId

public java.lang.Long getNextId()
                         throws IRuntimeException,
                                ServerConnectionException

Specified by:

getNextId in interface ServerConnectionI

Throws:

IRuntimeException

ServerConnectionException

prepareQuery

public BatchedBackendRequestI prepareQuery(java.lang.String s)

Specified by:

prepareQuery in interface ServerConnectionI

prepareQuery

public BatchedBackendRequestI prepareQuery(java.lang.String s,
                                           java.lang.Object[] o)

Specified by:

prepareQuery in interface ServerConnectionI

query

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

Specified by:

query in interface ServerConnectionI

query

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

Specified by:

query in interface ServerConnectionI

queryRelation

public de.ipcon.db.core.QueryResultsI queryRelation(long id,
                                                    java.lang.Class<? extends BOI> classtip,
                                                    java.lang.String attributeName)

Specified by:

queryRelation in interface ServerConnectionI

Specified by:

queryRelation in class AbstractBackendConnection

execute

public void execute(BatchedBackendRequestI[] bbrs)
             throws java.lang.IllegalArgumentException,
                    IRuntimeException,
                    ServerConnectionException

Specified by:

execute in interface ServerConnectionI

Throws:

java.lang.IllegalArgumentException

IRuntimeException

ServerConnectionException

exists

public boolean exists(java.lang.Long id)
               throws IRuntimeException,
                      ServerConnectionException

Specified by:

exists in interface ServerConnectionI

Throws:

IRuntimeException

ServerConnectionException

exists

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

Specified by:

exists in interface ServerConnectionI

Specified by:

exists in class AbstractBackendConnection

Throws:

IRuntimeException

ServerConnectionException

getBO

public BO getBO(java.lang.Long id)
         throws IRuntimeException,
                ObjectNotPersistentException,
                ObjectsNotPersistentException,
                ServerConnectionException

Specified by:

getBO in interface ServerConnectionI

Throws:

IRuntimeException

ObjectNotPersistentException

ObjectsNotPersistentException

ServerConnectionException

getBO

public BO getBO(java.lang.Long id,
                java.lang.Class<? extends BOI> classtip)
         throws IRuntimeException,
                ObjectNotPersistentException,
                ObjectsNotPersistentException,
                ServerConnectionException

Specified by:

getBO in interface ServerConnectionI

Specified by:

getBO in class AbstractBackendConnection

Throws:

IRuntimeException

ObjectNotPersistentException

ObjectsNotPersistentException

ServerConnectionException

getBOs

public BO[] getBOs(long[] ids)
            throws IRuntimeException,
                   ObjectNotPersistentException,
                   ObjectsNotPersistentException,
                   ServerConnectionException

Specified by:

getBOs in interface ServerConnectionI

Throws:

IRuntimeException

ObjectNotPersistentException

ObjectsNotPersistentException

ServerConnectionException

getBOs

public BO[] getBOs(long[] ids,
                   java.lang.Class<? extends BOI> classtip)
            throws IRuntimeException,
                   ObjectNotPersistentException,
                   ObjectsNotPersistentException,
                   ServerConnectionException

Specified by:

getBOs in interface ServerConnectionI

Specified by:

getBOs in class AbstractBackendConnection

Throws:

IRuntimeException

ObjectNotPersistentException

ObjectsNotPersistentException

ServerConnectionException

getBOs

public BO[] getBOs(java.lang.Long[] ids)
            throws IRuntimeException,
                   ObjectNotPersistentException,
                   ObjectsNotPersistentException,
                   ServerConnectionException

Specified by:

getBOs in interface ServerConnectionI

Throws:

IRuntimeException

ObjectNotPersistentException

ObjectsNotPersistentException

ServerConnectionException

getBOs

public BO[] getBOs(java.lang.Long[] ids,
                   java.lang.Class<? extends BOI> classtip)
            throws IRuntimeException,
                   ObjectNotPersistentException,
                   ObjectsNotPersistentException,
                   ServerConnectionException

Specified by:

getBOs in interface ServerConnectionI

Specified by:

getBOs in class AbstractBackendConnection

Throws:

IRuntimeException

ObjectNotPersistentException

ObjectsNotPersistentException

ServerConnectionException

getRelationBOs

public BO[] getRelationBOs(java.lang.Long id,
                           java.lang.Class<? extends BOI> classtip,
                           java.lang.String attributeName)
                    throws IRuntimeException,
                           ServerConnectionException

Specified by:

getRelationBOs in interface ServerConnectionI

Specified by:

getRelationBOs in class AbstractBackendConnection

Throws:

IRuntimeException

ServerConnectionException

lockServer

public void lockServer()
                throws ServerConnectionException

Specified by:

lockServer in interface ServerConnectionI

Throws:

ServerConnectionException

unlockServer

public void unlockServer()
                  throws ServerConnectionException

Specified by:

unlockServer in interface ServerConnectionI

Throws:

ServerConnectionException

initiateServerShutdown

public void initiateServerShutdown()
                            throws ServerConnectionException

Specified by:

initiateServerShutdown in interface ServerConnectionI

Throws:

ServerConnectionException

initiateServerShutdown

public void initiateServerShutdown(int cSecsDelay)
                            throws ServerConnectionException

Specified by:

initiateServerShutdown in interface ServerConnectionI

Throws:

ServerConnectionException

initiateServerShutdown

public void initiateServerShutdown(int cSecsDelay,
                                   java.lang.String msg)
                            throws ServerConnectionException

Specified by:

initiateServerShutdown in interface ServerConnectionI

Throws:

ServerConnectionException

stopServerShutdown

public void stopServerShutdown()
                        throws ServerConnectionException

Specified by:

stopServerShutdown in interface ServerConnectionI

Throws:

ServerConnectionException

sendSystemMessage

public void sendSystemMessage(java.lang.String msg)
                       throws ServerConnectionException

Specified by:

sendSystemMessage in interface ServerConnectionI

Throws:

ServerConnectionException

sendSystemMessage

public void sendSystemMessage(java.lang.String msg,
                              java.util.Map msgClients)
                       throws ServerConnectionException

Specified by:

sendSystemMessage in interface ServerConnectionI

Throws:

ServerConnectionException

demandForcedClientDisconnect

public void demandForcedClientDisconnect(int cSecsDelay)
                                  throws ServerConnectionException

Specified by:

demandForcedClientDisconnect in interface ServerConnectionI

Throws:

ServerConnectionException

demandForcedClientDisconnect

public void demandForcedClientDisconnect(int cSecsDelay,
                                         java.lang.String msg)
                                  throws ServerConnectionException

Specified by:

demandForcedClientDisconnect in interface ServerConnectionI

Throws:

ServerConnectionException

demandForcedClientDisconnect

public void demandForcedClientDisconnect(int cSecsDelay,
                                         java.lang.String msg,
                                         java.util.Map msgClients)
                                  throws ServerConnectionException

Specified by:

demandForcedClientDisconnect in interface ServerConnectionI

Throws:

ServerConnectionException

cancelForcedClientDisconnect

public void cancelForcedClientDisconnect()
                                  throws ServerConnectionException

Specified by:

cancelForcedClientDisconnect in interface ServerConnectionI

Throws:

ServerConnectionException

cancelForcedClientDisconnect

public void cancelForcedClientDisconnect(java.util.Map msgClients)
                                  throws ServerConnectionException

Specified by:

cancelForcedClientDisconnect in interface ServerConnectionI

Throws:

ServerConnectionException

isOperational

public boolean isOperational()

Specified by:

isOperational in interface L10nPackProviderI

getL10nPacks

public L10nPack[] getL10nPacks(java.lang.String[] packNames,
                               java.lang.String localeName)
                        throws IRuntimeException,
                               ServerConnectionException

Specified by:

getL10nPacks in interface L10nPackProviderI

Throws:

IRuntimeException

ServerConnectionException

getL10nPath

public L10nPathEntry[] getL10nPath()

Specified by:

getL10nPath in interface L10nPackProviderI

createExpiringToken

public void createExpiringToken(java.lang.String serviceName,
                                java.lang.String tokenName,
                                byte[] value,
                                long expiryms)

Description copied from interface: ExpiringTokenStorageProviderI

Creates a time limited association of the given service and token name to a byte array value (usually a key).

Specified by:

createExpiringToken in interface ExpiringTokenStorageProviderI

Parameters:

serviceName - name (fqn) of the service who provided the value

tokenName - name of the token variable which in conjunction with the service name provides a key to the value

value - the actual value, as byte array

expiryms - the time the value will be valid. After that time, the value is removed from the store

createExpiringToken

public java.lang.String createExpiringToken(java.lang.String serviceName,
                                            byte[] value,
                                            long expiryms)

Description copied from interface: ExpiringTokenStorageProviderI

Works like @see #createExpiringToken(String,String,byte[],long), but creates a non-conflicting tokenName within the store, stores the value and returns the chosen tokenName.

Specified by:

createExpiringToken in interface ExpiringTokenStorageProviderI

Parameters:

serviceName - name (fqn) of the service who provided the value

value - the actual value, as byte array

expiryms - the time the value will be valid. After that time, the value is removed from the store

Returns:

chosen, non-conflicting tokenName

retrieveExpiringToken

public byte[] retrieveExpiringToken(java.lang.String serviceName,
                                    java.lang.String tokenName)

Description copied from interface: ExpiringTokenStorageProviderI

Retrieves a time limited token

Specified by:

retrieveExpiringToken in interface ExpiringTokenStorageProviderI

Parameters:

serviceName - name (fqn) of the service who provided the value

tokenName - name of the token variable which in conjunction with the service name provides a key to the value

Returns:

the token data as byte array

destroyExpiringToken

public byte[] destroyExpiringToken(java.lang.String serviceName,
                                   java.lang.String tokenName)

Description copied from interface: ExpiringTokenStorageProviderI

Destroys a time limited token immediately

Specified by:

destroyExpiringToken in interface ExpiringTokenStorageProviderI

Parameters:

serviceName - name (fqn) of the service who provided the value

tokenName - name of the token variable which in conjunction with the service name provides a key to the value

Returns:

the former token data or null if there was nothing to destroy any more

isFTSActive

public boolean isFTSActive()
                    throws IRuntimeException,
                           ServerConnectionException

Specified by:

isFTSActive in interface FTSTermInfoProviderI

Specified by:

isFTSActive in interface FulltextSearcherI

Returns:

true if the FTS system is active and ready for use; false if its initialization is still in progress.

Throws:

IRuntimeException

ServerConnectionException

getIdListAsString

public java.lang.String getIdListAsString(java.lang.String ftClauses)
                                   throws ServerConnectionException

Specified by:

getIdListAsString in interface FulltextSearcherI

Throws:

ServerConnectionException

getIdListAsString

public java.lang.String getIdListAsString(java.lang.String ftClauses,
                                          java.lang.String classname)
                                   throws ServerConnectionException

Specified by:

getIdListAsString in interface FulltextSearcherI

Throws:

ServerConnectionException

getIdList

public long[] getIdList(java.lang.String ftClauses)
                 throws ServerConnectionException

Specified by:

getIdList in interface FulltextSearcherI

Throws:

ServerConnectionException

getIdList

public long[] getIdList(java.lang.String ftClauses,
                        java.lang.String classname)
                 throws ServerConnectionException

Specified by:

getIdList in interface FulltextSearcherI

Throws:

ServerConnectionException

getTermSuggestions

public java.lang.String[] getTermSuggestions(EntityI entity,
                                             java.lang.String term)

Specified by:

getTermSuggestions in interface FulltextSearcherI

getTermSuggestions

public java.lang.String[] getTermSuggestions(EntityI entity,
                                             java.lang.String term,
                                             int size)

Specified by:

getTermSuggestions in interface FulltextSearcherI

getTermSuggestions

public java.lang.String[] getTermSuggestions(EntityI entity,
                                             java.lang.String term,
                                             int size,
                                             boolean includeDeleted)

Specified by:

getTermSuggestions in interface FulltextSearcherI

getTermSuggestions

public java.lang.String[] getTermSuggestions(EntityI entity,
                                             java.lang.String term,
                                             int size,
                                             boolean includeDeleted,
                                             boolean morePopular)

Specified by:

getTermSuggestions in interface FulltextSearcherI

getTermSuggestions

public java.lang.String[] getTermSuggestions(EntityI entity,
                                             java.lang.String term,
                                             int size,
                                             boolean includeDeleted,
                                             boolean morePopular,
                                             float accuracy)

Specified by:

getTermSuggestions in interface FulltextSearcherI

getTermSuggestions

public java.lang.String[] getTermSuggestions(EntityI entity,
                                             java.lang.String term,
                                             int size,
                                             boolean includeDeleted,
                                             boolean morePopular,
                                             float accuracy,
                                             java.lang.String propertyName)

Specified by:

getTermSuggestions in interface FulltextSearcherI

getTermSuggestions

public java.lang.String[] getTermSuggestions(EntityI entity,
                                             java.lang.String term,
                                             int size,
                                             boolean includeDeleted,
                                             boolean morePopular,
                                             float accuracy,
                                             java.lang.String propertyName,
                                             boolean withSubEntities)

Specified by:

getTermSuggestions in interface FulltextSearcherI

isFTSAvailable

public boolean isFTSAvailable()
                       throws IRuntimeException,
                              ServerConnectionException

Specified by:

isFTSAvailable in interface ServerConnectionI

Throws:

IRuntimeException

ServerConnectionException

getTermsRaw

public TermInfoI[] getTermsRaw()

Specified by:

getTermsRaw in interface FTSTermInfoProviderI

getTermsRaw

public TermInfoI[] getTermsRaw(EntityI entity)

Specified by:

getTermsRaw in interface FTSTermInfoProviderI

getTermsRaw

public TermInfoI[] getTermsRaw(EntityI entity,
                               int size)

Specified by:

getTermsRaw in interface FTSTermInfoProviderI

getTermsRaw

public TermInfoI[] getTermsRaw(EntityI entity,
                               int size,
                               boolean includeDeleted)

Specified by:

getTermsRaw in interface FTSTermInfoProviderI

getTermsRaw

public TermInfoI[] getTermsRaw(EntityI entity,
                               int size,
                               boolean includeDeleted,
                               java.lang.String[] propertyNames)

Specified by:

getTermsRaw in interface FTSTermInfoProviderI

getTermsRaw

public TermInfoI[] getTermsRaw(EntityI entity,
                               int size,
                               boolean includeDeleted,
                               java.lang.String[] propertyNames,
                               boolean sortByName)

Specified by:

getTermsRaw in interface FTSTermInfoProviderI

getTermsRaw

public TermInfoI[] getTermsRaw(EntityI entity,
                               int size,
                               boolean includeDeleted,
                               java.lang.String[] propertyNames,
                               boolean sortByName,
                               boolean withSubEntities)

Specified by:

getTermsRaw in interface FTSTermInfoProviderI

getTermsFromServer

public TermInfoI[] getTermsFromServer()

getTermsFromServer

public TermInfoI[] getTermsFromServer(EntityI entity)

getTermsFromServer

public TermInfoI[] getTermsFromServer(EntityI entity,
                                      java.lang.String regex)

getTermsFromServer

public TermInfoI[] getTermsFromServer(EntityI entity,
                                      java.lang.String regex,
                                      int size)

getTermsFromServer

public TermInfoI[] getTermsFromServer(EntityI entity,
                                      java.lang.String regex,
                                      int size,
                                      boolean includeDeleted)

getTermsFromServer

public TermInfoI[] getTermsFromServer(EntityI entity,
                                      java.lang.String regex,
                                      int size,
                                      boolean includeDeleted,
                                      java.lang.String[] propertyNames)

getTermsFromServer

public TermInfoI[] getTermsFromServer(EntityI entity,
                                      java.lang.String regex,
                                      int size,
                                      boolean includeDeleted,
                                      java.lang.String[] propertyNames,
                                      boolean sortByName)

getTermsFromServer

public TermInfoI[] getTermsFromServer(EntityI entity,
                                      java.lang.String regex,
                                      int size,
                                      boolean includeDeleted,
                                      java.lang.String[] propertyNames,
                                      boolean sortByName,
                                      boolean withSubEntities)

getClientSessionInfos

public ClientSessionInfo[] getClientSessionInfos()

Specified by:

getClientSessionInfos in interface ServerConnectionI

getRoundTrips

public int getRoundTrips()

Specified by:

getRoundTrips in interface ServerConnectionI

getURLPrefix

public java.lang.String getURLPrefix()

Specified by:

getURLPrefix in interface ServerConnectionI

getAddress

public java.lang.String getAddress()

Specified by:

getAddress in interface ServerConnectionI

toString

public java.lang.String toString()

Specified by:

toString in interface ServerConnectionI

Overrides:

toString in class java.lang.Object

getDomain

public java.lang.String getDomain()

Specified by:

getDomain in interface ServerConnectionI

setDomain

public void setDomain(java.lang.String $44)

getPort

public int getPort()

Specified by:

getPort in interface ServerConnectionI

setPort

public void setPort(int $45)

getMinPool

public int getMinPool()

Specified by:

getMinPool in interface ServerConnectionI

setMinPool

public void setMinPool(int $46)

getMaxPool

public int getMaxPool()

Specified by:

getMaxPool in interface ServerConnectionI

setMaxPool

public void setMaxPool(int $47)

getSubVersion

public java.lang.String getSubVersion()

Specified by:

getSubVersion in interface ServerConnectionI

setSubVersion

public void setSubVersion(java.lang.String $48)

isTls

public boolean isTls()

Specified by:

isTls in interface ServerConnectionI

setTls

public void setTls(boolean $49)

getPosition

public java.lang.Integer getPosition()

setPosition

public void setPosition(java.lang.Integer $50)