de.ipcon.db.protocol

Class AbstractBackendConnection

java.lang.Object

de.ipcon.db.protocol.AbstractBackendConnection

All Implemented Interfaces:

ExpiringTokenStorageProviderI, FTSTermInfoProviderI, FulltextSearcherI, ServerConnectionI, L10nPackProviderI

Direct Known Subclasses:

BackendConnection

public abstract class AbstractBackendConnection
extends java.lang.Object
implements ServerConnectionI

Field Summary

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

EMPTY_ARRAY

Method Summary

Modifier and Type	Method and Description
Anmeldung	authenticate(java.lang.String username, java.lang.String pass)
abstract Anmeldung	authenticateImpl(java.lang.String username, java.lang.String pass)
void	connect() This method is called when connecting or reconnecting to a server.
void	disconnect()
void	endUOW(java.lang.Object ref) FIXME not implemented yet: ProgressAnimator: "Serververbindung zurueck."
BatchedBackendRequestI	execute(BatchedBackendRequestI sr)
abstract boolean	exists(java.lang.Long id, java.lang.Class<? extends BOI> classtip)
abstract BO	getBO(java.lang.Long id, java.lang.Class<? extends BOI> classtip)
abstract BO[]	getBOs(long[] ids, java.lang.Class<? extends BOI> classtip)
abstract BO[]	getBOs(java.lang.Long[] ids, java.lang.Class<? extends BOI> classtip)
L10nPack	getL10nPack(java.lang.String bundleName, java.lang.String locale)
long	getLatency()
BackendConnectionManagerI	getManager()
java.lang.Long	getNodeNumber()
abstract BO[]	getRelationBOs(java.lang.Long id, java.lang.Class<? extends BOI> classtip, java.lang.String attributeName)
ServerConnectionInfoReceiverI	getServerConnectionInfoReceiver()
abstract java.lang.String	getServerName(boolean evenIfNoActiveConnection)
java.lang.String	getServerUrl()
TermInfoI[]	getTerms()
TermInfoI[]	getTerms(EntityI entity)
TermInfoI[]	getTerms(EntityI entity, java.lang.String regex)
TermInfoI[]	getTerms(EntityI entity, java.lang.String regex, int size)
TermInfoI[]	getTerms(EntityI entity, java.lang.String regex, int size, boolean includeDeleted)
TermInfoI[]	getTerms(EntityI entity, java.lang.String regex, int size, boolean includeDeleted, java.lang.String[] propertyNames)
TermInfoI[]	getTerms(EntityI entity, java.lang.String regex, int size, boolean includeDeleted, java.lang.String[] propertyNames, boolean sortByName)
TermInfoI[]	getTerms(EntityI entity, java.lang.String regex, int size, boolean includeDeleted, java.lang.String[] propertyNames, boolean sortByName, boolean withSubEntities)
long	getToken()
void	handleDBManEvent(DBManEvent evt)
boolean	hasIncompatibleServerProtocolVersion()
boolean	isConnected()
boolean	isDead()
boolean	isDisconnected()
boolean	isLoggedIn()
void	markConnected()
void	markDead()
void	markDisconnected()
void	markUsable()
de.ipcon.db.core.QueryResultsI	query(BOQuery eq)
java.util.List	queryBO(BOQuery eq)
java.util.List	queryBO(java.lang.String s)
java.util.List	queryBO(java.lang.String s, java.lang.Object[] o)
abstract de.ipcon.db.core.QueryResultsI	queryRelation(long id, java.lang.Class<? extends BOI> classtip, java.lang.String attributeName)
void	receiving(java.lang.Object ref) FIXME not implemented yet: ProgressAnimator: "Daten kommen an."
void	reregisterEventsAtBackend()
void	setLatency(int i)
void	setProgressAnimator(ProgressAnimatorI pa)
void	startUOW(java.lang.Object ref) FIXME not implemented yet: ProgressAnimator: "Verbindung zum Server angefordert, Parameter werden zum Server uebertragen."
void	subscribeEvents(DBManEventListenerI listener, DBManEventFilter filter)
void	unsubscribeEvents(DBManEventListenerI listener)
void	unsubscribeEvents(DBManEventListenerI listener, DBManEventFilter filter)
void	waiting(java.lang.Object ref) FIXME not implemented yet: ProgressAnimator: "Wartet auf Serverantwort."

Methods inherited from class java.lang.Object

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

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

cancelForcedClientDisconnect, cancelForcedClientDisconnect, checkServerConnectivity, checkServerConnectivity, copyRemoteBLOBsToLocalFileVault, demandForcedClientDisconnect, demandForcedClientDisconnect, demandForcedClientDisconnect, execute, exists, getAddress, getAvailableLocalesForUserInterface, getBLOB, getBLOB, getBLOB, getBLOB, getBLOB, getBLOB, getBLOB, getBLOB, getBLOBInfo, getBLOBInfo, getBO, getBOs, getBOs, getClientSessionInfos, getComplexCommandsTimeoutSeconds, getConciseCommandsTimeoutSeconds, getCryptoHandler, getDBManInfo, getDomain, getIdRange, getInitialAvailableLocalesForUserInterface, getInstanceName, getL10nPackPreload, getL10nViaString, getLazyStruktur, getLoggedInUser, getMaxPool, getMediumCommandsTimeoutSeconds, getMinPool, getNextId, getPermissionHandler, getPort, getRemoteSchema, getRemoteSchemaFingerprint, getRemoteSchemaUIDs, getRemoteSchemaVersion, getRoundTrips, getServerInetAddress, getServerName, getSessionId, getSessionInfos, getSimpleCommandsTimeoutSeconds, getSubVersion, getURLPrefix, hasBLOB, hasBLOB, haveBLOB, initiateServerShutdown, initiateServerShutdown, initiateServerShutdown, initSession, isFTSAvailable, isMemoryTightClient, isNotificationSystemActivated, isServerAuthoritativeSyncServer, isTls, lockServer, prepareQuery, prepareQuery, query, query, resetPassword, saveBO, saveBO, saveBO, sendSystemMessage, sendSystemMessage, setSessionLocale, skipRecheckConnection, stopServerShutdown, subscribeEventsAtBackend, testAuth, testAuth, toString, unlockServer, unsubscribeEventsAtBackend, updateServerConnectionInfo, updateStructureReadAccessStatistics, useOnlyDefaultPlafThemes

Methods inherited from interface de.ipcon.tools.L10nPackProviderI

getL10nPacks, getL10nPath, isOperational, prefetchL10nPacks

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

getIdList, getIdList, getIdListAsString, getIdListAsString, getTermSuggestions, getTermSuggestions, getTermSuggestions, getTermSuggestions, getTermSuggestions, getTermSuggestions, getTermSuggestions, isFTSActive

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

getTermsRaw, getTermsRaw, getTermsRaw, getTermsRaw, getTermsRaw, getTermsRaw, getTermsRaw, isFTSActive

Methods inherited from interface de.ipcon.db.core.ExpiringTokenStorageProviderI

createExpiringToken, createExpiringToken, destroyExpiringToken, retrieveExpiringToken

Method Detail

getBO

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

Specified by:

getBO in interface ServerConnectionI

getBOs

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

Specified by:

getBOs in interface ServerConnectionI

getBOs

public abstract BO[] getBOs(long[] ids,
                            java.lang.Class<? extends BOI> classtip)

Specified by:

getBOs in interface ServerConnectionI

getRelationBOs

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

Specified by:

getRelationBOs in interface ServerConnectionI

exists

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

Specified by:

exists in interface ServerConnectionI

queryRelation

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

Specified by:

queryRelation in interface ServerConnectionI

getManager

public BackendConnectionManagerI getManager()

Specified by:

getManager in interface ServerConnectionI

getServerConnectionInfoReceiver

public ServerConnectionInfoReceiverI getServerConnectionInfoReceiver()

Specified by:

getServerConnectionInfoReceiver in interface ServerConnectionI

getToken

public long getToken()

Specified by:

getToken in interface ServerConnectionI

hasIncompatibleServerProtocolVersion

public boolean hasIncompatibleServerProtocolVersion()

Specified by:

hasIncompatibleServerProtocolVersion in interface ServerConnectionI

getLatency

public long getLatency()

handleDBManEvent

public void handleDBManEvent(DBManEvent evt)

Specified by:

handleDBManEvent in interface ServerConnectionI

subscribeEvents

public void subscribeEvents(DBManEventListenerI listener,
                            DBManEventFilter filter)

unsubscribeEvents

public void unsubscribeEvents(DBManEventListenerI listener)

unsubscribeEvents

public void unsubscribeEvents(DBManEventListenerI listener,
                              DBManEventFilter filter)

Specified by:

unsubscribeEvents in interface ServerConnectionI

reregisterEventsAtBackend

public void reregisterEventsAtBackend()

Specified by:

reregisterEventsAtBackend in interface ServerConnectionI

getServerUrl

public java.lang.String getServerUrl()

Specified by:

getServerUrl in interface ServerConnectionI

getNodeNumber

public java.lang.Long getNodeNumber()

Specified by:

getNodeNumber in interface ServerConnectionI

getServerName

public abstract java.lang.String getServerName(boolean evenIfNoActiveConnection)

Specified by:

getServerName in interface ServerConnectionI

isDisconnected

public boolean isDisconnected()

isConnected

public boolean isConnected()

Specified by:

isConnected in interface ServerConnectionI

isDead

public boolean isDead()

Specified by:

isDead in interface ServerConnectionI

connect

public void connect()
             throws ServerConnectionException

Description copied from interface: ServerConnectionI

This method is called when connecting or reconnecting to a server. It initializes a new session on the server and connects to it. In case it is a reconnect, the method will also log in and reregister for all previously registered server-side events.

Specified by:

connect in interface ServerConnectionI

Throws:

ServerConnectionException

disconnect

public void disconnect()

Specified by:

disconnect in interface ServerConnectionI

markConnected

public void markConnected()

markDisconnected

public void markDisconnected()

markDead

public void markDead()

Specified by:

markDead in interface ServerConnectionI

markUsable

public void markUsable()

setLatency

public void setLatency(int i)

isLoggedIn

public boolean isLoggedIn()

Specified by:

isLoggedIn in interface ServerConnectionI

authenticate

public Anmeldung authenticate(java.lang.String username,
                              java.lang.String pass)
                       throws ServerConnectionException,
                              java.lang.IllegalStateException,
                              AuthenticationException

Specified by:

authenticate in interface ServerConnectionI

Throws:

ServerConnectionException

java.lang.IllegalStateException

AuthenticationException

authenticateImpl

public abstract Anmeldung authenticateImpl(java.lang.String username,
                                           java.lang.String pass)
                                    throws AuthenticationException

Throws:

AuthenticationException

getL10nPack

public L10nPack getL10nPack(java.lang.String bundleName,
                            java.lang.String locale)

Specified by:

getL10nPack in interface L10nPackProviderI

execute

public BatchedBackendRequestI execute(BatchedBackendRequestI sr)

Specified by:

execute in interface ServerConnectionI

queryBO

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

Specified by:

queryBO in interface ServerConnectionI

queryBO

public java.util.List queryBO(java.lang.String s,
                              java.lang.Object[] o)

Specified by:

queryBO in interface ServerConnectionI

query

public de.ipcon.db.core.QueryResultsI query(BOQuery eq)

Specified by:

query in interface ServerConnectionI

queryBO

public java.util.List queryBO(BOQuery eq)

Specified by:

queryBO in interface ServerConnectionI

getTerms

public TermInfoI[] getTerms()

Specified by:

getTerms in interface FulltextSearcherI

getTerms

public TermInfoI[] getTerms(EntityI entity)

Specified by:

getTerms in interface FulltextSearcherI

getTerms

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

Specified by:

getTerms in interface FulltextSearcherI

getTerms

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

Specified by:

getTerms in interface FulltextSearcherI

getTerms

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

Specified by:

getTerms in interface FulltextSearcherI

getTerms

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

Specified by:

getTerms in interface FulltextSearcherI

getTerms

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

Specified by:

getTerms in interface FulltextSearcherI

getTerms

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

Specified by:

getTerms in interface FulltextSearcherI

setProgressAnimator

public void setProgressAnimator(ProgressAnimatorI pa)

Specified by:

setProgressAnimator in interface ServerConnectionI

startUOW

public void startUOW(java.lang.Object ref)

FIXME not implemented yet: ProgressAnimator: "Verbindung zum Server angefordert, Parameter werden zum Server uebertragen."

waiting

public void waiting(java.lang.Object ref)

FIXME not implemented yet: ProgressAnimator: "Wartet auf Serverantwort."

receiving

public void receiving(java.lang.Object ref)

FIXME not implemented yet: ProgressAnimator: "Daten kommen an."

endUOW

public void endUOW(java.lang.Object ref)

FIXME not implemented yet: ProgressAnimator: "Serververbindung zurueck."