de.ipcon.db.sync

Class AbstractSync

java.lang.Object

de.ipcon.db.sync.AbstractSync

All Implemented Interfaces:

TransactionBuilderI, TransactionProviderI, ServiceI, L10nLocaleChangeListenerI, java.io.Serializable, java.lang.Runnable

Direct Known Subclasses:

ScriptService, SyncService

public abstract class AbstractSync
extends java.lang.Object
implements ServiceI, TransactionProviderI, L10nLocaleChangeListenerI

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static java.math.BigDecimal	D_ONE
static java.math.BigDecimal	D_ZERO
static org.apache.log4j.Logger	log
static java.lang.String	SLASH

Constructor Summary

Constructors

Constructor and Description
AbstractSync()

Method Summary

Modifier and Type	Method and Description
void	addBO(BO _bo)
void	addFeatureListener(FeatureListenerI fl)
void	allowRestart()
boolean	canStopRun() Returns TRUE if this ServiceI can execute a run directly after a stop, FALSE if it must be unprepared and prepared again.
boolean	canUnpreparePrepare() Returns TRUE if this ServiceI can be prepared again after an unprepare, FALSE if it needs to be reinstantiated.
boolean	char2bool(java.lang.String c) returns boolean depending upon the string (i.e. true if 1 else false..)
float	char2float(java.lang.String c) gets the float value out of string and returns the same.
int	char2int(java.lang.String c) gets the int value out of string and returns the same.
void	commit()
void	commit(Transaction tx)
java.lang.String	formatNum(java.lang.String str, java.lang.String form)
byte[]	getBLOB(java.lang.Long id)
BO	getBO(java.lang.Long id)
BO[]	getBOs(java.lang.Long[] ids)
electric.xml.Element	getConfRoot()
Transaction	getCurrentTx()
Benutzer	getCurrentUser() Returns Benutzer object containing the current user
ErrorHandler	getEh()
long	getKeepAliveTimeout()
static byte[]	getLocalFile(java.io.File infile)
Transaction	getNewTransaction()
Transaction	getNewTransaction(java.lang.String desc)
Transaction	getNewTransaction(java.lang.String desc, TemporaryIdSupplierI tempIdSupplier)
Transaction	getNewTransaction(TemporaryIdSupplierI tempIdSupplier)
Transaction	getNewTransactionWithInstrumentedSchema()
Transaction	getNewTransactionWithInstrumentedSchema(java.lang.String desc)
Transaction	getNewTransactionWithInstrumentedSchema(java.lang.String desc, TemporaryIdSupplierI tempIdSupplier)
Transaction	getNewTransactionWithInstrumentedSchema(TemporaryIdSupplierI tempIdSupplier)
Transaction	getNewTx() Retrieves a new Transaction object.
Transaction	getNewTx(java.lang.String desc) Retrieves a new Transaction object, providing a description.
BackendConnectionManager	getRcl()
SchemaI	getSchema()
AbstractScript	getScript()
java.lang.String	getScriptLanguage()
java.lang.String	getServer()
java.lang.String	getSlash()
Transaction	getTx() Returns the current Transaction
java.lang.Object	ifSetQuery1BO(java.lang.String val, java.lang.String query)
java.lang.Object	ifSetQuery1BO(java.lang.String val, java.lang.String query, boolean warn)
java.lang.Object	ifSetQuery1BO(java.lang.String val, java.lang.String query, boolean warn, java.lang.Object nullValue)
java.lang.Object	ifSetQuery1BO(java.lang.String val, java.lang.String query, java.lang.Object[] o)
java.lang.Object	ifSetQuery1BO(java.lang.String val, java.lang.String query, java.lang.Object[] o, boolean warn)
java.lang.Object	ifSetQuery1BO(java.lang.String val, java.lang.String query, java.lang.Object[] o, boolean warn, java.lang.Object nullValue)
void	initMyTISMConnection()
void	initScript()
void	initScriptPostConnect()
boolean	isActivateL10nProvider()
boolean	isAvailable(java.lang.String feature)
boolean	isAvailable(java.lang.String feature, boolean defaultIfNoDBM)
boolean	isAvailableWithNoise(java.lang.String feature)
boolean	isAvailableWithNoise(java.lang.String feature, boolean defaultIfNoDBM)
boolean	isNotSet(java.lang.String str)
boolean	isPleaseStop()
boolean	isServerAuthoritativeSyncServer()
boolean	isSet(java.lang.String str)
java.lang.String	justify(java.lang.String str, int len, java.lang.String dir)
java.lang.String	justifyNum(java.lang.String str, int len, java.lang.String dir)
long	keepAlive(long millis) If there is a watchdog for this ServiceI, tell it to hold on for the passed amount of milliseconds.
java.lang.String	left(java.lang.String str, int len)
void	logon(netrexx.lang.Rexx _user, netrexx.lang.Rexx _passwd)
java.lang.String	maxLen(java.lang.String str, int len)
java.lang.String	maxLen(java.lang.String str, int len, java.lang.String nullValue)
java.lang.String	oqlString(java.lang.String val)
java.lang.String	oqlString(java.lang.String val, java.lang.String nullValue)
void	prepare(electric.xml.Element _confRoot) Prepares this ServiceI for running.
void	prepareFromFile(java.lang.String _file)
void	processLocaleChanged(java.util.Locale oldLocale, java.util.Locale newLocale)
static void	putLocalFile(java.io.File outfile, byte[] data)
java.lang.Object	query1BO(java.lang.String query)
java.lang.Object	query1BO(java.lang.String query, boolean warn)
java.lang.Object	query1BO(java.lang.String query, boolean warn, java.lang.Object nullValue)
java.lang.Object	query1BO(java.lang.String query, java.lang.Object[] o)
java.lang.Object	query1BO(java.lang.String query, java.lang.Object[] o, boolean warn)
java.lang.Object	query1BO(java.lang.String query, java.lang.Object[] o, boolean warn, java.lang.Object nullValue)
java.util.List	queryBO(java.lang.String s)
java.util.List	queryBO(java.lang.String s, java.lang.Object[] o)
void	removeFeatureListener(FeatureListenerI fl)
java.lang.String	right(java.lang.String str, int len)
TransactionAnswer	saveBO(Transaction _tx) Persists the changes recorded in the passed transaction tx to the database.
TransactionAnswer	saveBO(Transaction _tx, boolean ignoreConflicts)
void	setActivateL10nProvider(boolean $25)
void	setConfRoot(electric.xml.Element $21)
void	setCurrentTx(Transaction $24)
void	setDbm(DBManLocalI _dbm) Sets the DBManLocalI instance for this ServiceI to the passed value.
void	setEh(ErrorHandler $20)
void	setKeepAliveTimeout(long $23)
void	setPleaseStop(boolean $22)
void	setSchema(SchemaI $17)
void	setScript(AbstractScript $18)
void	setScriptLanguage(java.lang.String $19)
void	setTransactionDescription(java.lang.String desc) Sets the default description for new Transaction instances to the passed String, typically a description of the run business service (BS).
java.lang.String	sqlString(java.lang.String val)
java.lang.String	sqlString(java.lang.String val, java.lang.String nullValue)
void	stop() Asks this ServiceI instance to terminate.
java.lang.String	strip(java.lang.String str)
java.lang.String	strip(java.lang.String str, java.lang.String nullValue)
java.math.BigDecimal	toBigDecimal(java.lang.String s)
java.math.BigDecimal	toBigDecimal(java.lang.String s, java.math.BigDecimal nv)
java.lang.Boolean	toBoolean(java.lang.String s)
java.lang.Boolean	toBoolean(java.lang.String s, java.lang.Boolean nv)
java.lang.Float	toFloat(java.lang.String s)
java.lang.Float	toFloat(java.lang.String s, java.lang.Float nv)
java.lang.Integer	toInteger(java.lang.String s)
java.lang.Integer	toInteger(java.lang.String s, java.lang.Integer nv)
void	unprepare() Cleans up this ServiceI.
java.lang.String	validateField(java.lang.String val)

Methods inherited from class java.lang.Object

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

Methods inherited from interface de.ipcon.db.ServiceI

run

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

saveWithRetries, saveWithRetries

Field Detail

D_ZERO

public static final java.math.BigDecimal D_ZERO

D_ONE

public static final java.math.BigDecimal D_ONE

log

public static final org.apache.log4j.Logger log

SLASH

public static final java.lang.String SLASH

Constructor Detail

AbstractSync

public AbstractSync()

Method Detail

getSlash

public java.lang.String getSlash()

getRcl

public BackendConnectionManager getRcl()

getServer

public java.lang.String getServer()

getTx

public Transaction getTx()

Returns the current Transaction

Returns:

Transaction

getNewTransaction

public Transaction getNewTransaction(java.lang.String desc)

Specified by:

getNewTransaction in interface TransactionBuilderI

Returns:

a new Transaction-instance, with a pre-set description, if not null.

getNewTransaction

public Transaction getNewTransaction(java.lang.String desc,
                                     TemporaryIdSupplierI tempIdSupplier)

Specified by:

getNewTransaction in interface TransactionBuilderI

Returns:

a new Transaction-instance, with a pre-set description and a temporary id supplier, if not null.

getNewTransaction

public Transaction getNewTransaction()

Specified by:

getNewTransaction in interface TransactionBuilderI

Returns:

a new Transaction-instance.

getNewTransaction

public Transaction getNewTransaction(TemporaryIdSupplierI tempIdSupplier)

Specified by:

getNewTransaction in interface TransactionBuilderI

Returns:

a new Transaction-instance, with a pre-set temporary id supplier, if not null.

getNewTransactionWithInstrumentedSchema

public Transaction getNewTransactionWithInstrumentedSchema(java.lang.String desc)

Specified by:

getNewTransactionWithInstrumentedSchema in interface TransactionBuilderI

Returns:

a new Transaction-instance with an InstrumentedSchema, with a pre-set description, if not null.

getNewTransactionWithInstrumentedSchema

public Transaction getNewTransactionWithInstrumentedSchema(java.lang.String desc,
                                                           TemporaryIdSupplierI tempIdSupplier)

Specified by:

getNewTransactionWithInstrumentedSchema in interface TransactionBuilderI

Returns:

a new Transaction-instance with an InstrumentedSchema, with a pre-set description and a temporary id supplier, if not null.

getNewTransactionWithInstrumentedSchema

public Transaction getNewTransactionWithInstrumentedSchema()

Specified by:

getNewTransactionWithInstrumentedSchema in interface TransactionBuilderI

Returns:

a new Transaction-instance with an InstrumentedSchema.

getNewTransactionWithInstrumentedSchema

public Transaction getNewTransactionWithInstrumentedSchema(TemporaryIdSupplierI tempIdSupplier)

Specified by:

getNewTransactionWithInstrumentedSchema in interface TransactionBuilderI

Returns:

a new Transaction-instance with an InstrumentedSchema, with a pre-set temporary id supplier, if not null.

getNewTx

public Transaction getNewTx(java.lang.String desc)

Retrieves a new Transaction object, providing a description.

Parameters:

desc - A description for the transaction.

Returns:

A new Transaction object.

getNewTx

public Transaction getNewTx()

Retrieves a new Transaction object.

Returns:

A new Transaction object.

processLocaleChanged

public void processLocaleChanged(java.util.Locale oldLocale,
                                 java.util.Locale newLocale)

Specified by:

processLocaleChanged in interface L10nLocaleChangeListenerI

setDbm

public void setDbm(DBManLocalI _dbm)

Description copied from interface: ServiceI

Sets the DBManLocalI instance for this ServiceI to the passed value.

Specified by:

setDbm in interface ServiceI

setTransactionDescription

public void setTransactionDescription(java.lang.String desc)

Description copied from interface: ServiceI

Sets the default description for new Transaction instances to the passed String, typically a description of the run business service (BS).

Specified by:

setTransactionDescription in interface ServiceI

prepare

public void prepare(electric.xml.Element _confRoot)

Description copied from interface: ServiceI

Prepares this ServiceI for running. Possibly resets its state, initializes the script and the injected variables, initializes the connection to the server.

Specified by:

prepare in interface ServiceI

See Also:

ServiceI.canUnpreparePrepare()

unprepare

public void unprepare()

Description copied from interface: ServiceI

Cleans up this ServiceI. Terminates the connection to the server.

Specified by:

unprepare in interface ServiceI

See Also:

ServiceI.canUnpreparePrepare()

allowRestart

public void allowRestart()

stop

public void stop()

Description copied from interface: ServiceI

Asks this ServiceI instance to terminate.

Specified by:

stop in interface ServiceI

keepAlive

public long keepAlive(long millis)

Description copied from interface: ServiceI

If there is a watchdog for this ServiceI, tell it to hold on for the passed amount of milliseconds. Returns the previously set value.

Specified by:

keepAlive in interface ServiceI

canStopRun

public boolean canStopRun()

Description copied from interface: ServiceI

Returns TRUE if this ServiceI can execute a run directly after a stop, FALSE if it must be unprepared and prepared again.

Specified by:

canStopRun in interface ServiceI

canUnpreparePrepare

public boolean canUnpreparePrepare()

Description copied from interface: ServiceI

Returns TRUE if this ServiceI can be prepared again after an unprepare, FALSE if it needs to be reinstantiated.

Specified by:

canUnpreparePrepare in interface ServiceI

prepareFromFile

public void prepareFromFile(java.lang.String _file)

initMyTISMConnection

public void initMyTISMConnection()

initScript

public void initScript()

initScriptPostConnect

public void initScriptPostConnect()

logon

public void logon(netrexx.lang.Rexx _user,
                  netrexx.lang.Rexx _passwd)

saveBO

public TransactionAnswer saveBO(Transaction _tx)

Description copied from interface: TransactionProviderI

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

Specified by:

saveBO in interface TransactionProviderI

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

saveBO

public TransactionAnswer saveBO(Transaction _tx,
                                boolean ignoreConflicts)

Specified by:

saveBO in interface TransactionProviderI

commit

public void commit()

commit

public void commit(Transaction tx)

queryBO

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

queryBO

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

getBO

public BO getBO(java.lang.Long id)

getBOs

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

isServerAuthoritativeSyncServer

public boolean isServerAuthoritativeSyncServer()

getCurrentUser

public Benutzer getCurrentUser()

Returns Benutzer object containing the current user

Returns:

Benutzer

getBLOB

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

getLocalFile

public static byte[] getLocalFile(java.io.File infile)

putLocalFile

public static void putLocalFile(java.io.File outfile,
                                byte[] data)

justifyNum

public java.lang.String justifyNum(java.lang.String str,
                                   int len,
                                   java.lang.String dir)

justify

public java.lang.String justify(java.lang.String str,
                                int len,
                                java.lang.String dir)

left

public java.lang.String left(java.lang.String str,
                             int len)

right

public java.lang.String right(java.lang.String str,
                              int len)

maxLen

public java.lang.String maxLen(java.lang.String str,
                               int len)

maxLen

public java.lang.String maxLen(java.lang.String str,
                               int len,
                               java.lang.String nullValue)

formatNum

public java.lang.String formatNum(java.lang.String str,
                                  java.lang.String form)

strip

public java.lang.String strip(java.lang.String str)

strip

public java.lang.String strip(java.lang.String str,
                              java.lang.String nullValue)

isSet

public boolean isSet(java.lang.String str)

isNotSet

public boolean isNotSet(java.lang.String str)

query1BO

public java.lang.Object query1BO(java.lang.String query)

query1BO

public java.lang.Object query1BO(java.lang.String query,
                                 boolean warn)

query1BO

public java.lang.Object query1BO(java.lang.String query,
                                 boolean warn,
                                 java.lang.Object nullValue)

query1BO

public java.lang.Object query1BO(java.lang.String query,
                                 java.lang.Object[] o)

query1BO

public java.lang.Object query1BO(java.lang.String query,
                                 java.lang.Object[] o,
                                 boolean warn)

query1BO

public java.lang.Object query1BO(java.lang.String query,
                                 java.lang.Object[] o,
                                 boolean warn,
                                 java.lang.Object nullValue)

ifSetQuery1BO

public java.lang.Object ifSetQuery1BO(java.lang.String val,
                                      java.lang.String query)

ifSetQuery1BO

public java.lang.Object ifSetQuery1BO(java.lang.String val,
                                      java.lang.String query,
                                      boolean warn)

ifSetQuery1BO

public java.lang.Object ifSetQuery1BO(java.lang.String val,
                                      java.lang.String query,
                                      boolean warn,
                                      java.lang.Object nullValue)

ifSetQuery1BO

public java.lang.Object ifSetQuery1BO(java.lang.String val,
                                      java.lang.String query,
                                      java.lang.Object[] o)

ifSetQuery1BO

public java.lang.Object ifSetQuery1BO(java.lang.String val,
                                      java.lang.String query,
                                      java.lang.Object[] o,
                                      boolean warn)

ifSetQuery1BO

public java.lang.Object ifSetQuery1BO(java.lang.String val,
                                      java.lang.String query,
                                      java.lang.Object[] o,
                                      boolean warn,
                                      java.lang.Object nullValue)

sqlString

public java.lang.String sqlString(java.lang.String val)

sqlString

public java.lang.String sqlString(java.lang.String val,
                                  java.lang.String nullValue)

oqlString

public java.lang.String oqlString(java.lang.String val)

oqlString

public java.lang.String oqlString(java.lang.String val,
                                  java.lang.String nullValue)

validateField

public java.lang.String validateField(java.lang.String val)

addBO

public void addBO(BO _bo)

char2bool

public boolean char2bool(java.lang.String c)

returns boolean depending upon the string (i.e. true if 1 else false..)

char2int

public int char2int(java.lang.String c)

gets the int value out of string and returns the same.

char2float

public float char2float(java.lang.String c)

gets the float value out of string and returns the same.

toBoolean

public java.lang.Boolean toBoolean(java.lang.String s)

toBoolean

public java.lang.Boolean toBoolean(java.lang.String s,
                                   java.lang.Boolean nv)

toInteger

public java.lang.Integer toInteger(java.lang.String s)

toInteger

public java.lang.Integer toInteger(java.lang.String s,
                                   java.lang.Integer nv)

toFloat

public java.lang.Float toFloat(java.lang.String s)

toFloat

public java.lang.Float toFloat(java.lang.String s,
                               java.lang.Float nv)

toBigDecimal

public java.math.BigDecimal toBigDecimal(java.lang.String s)

toBigDecimal

public java.math.BigDecimal toBigDecimal(java.lang.String s,
                                         java.math.BigDecimal nv)

isAvailable

public boolean isAvailable(java.lang.String feature)

isAvailable

public boolean isAvailable(java.lang.String feature,
                           boolean defaultIfNoDBM)

isAvailableWithNoise

public boolean isAvailableWithNoise(java.lang.String feature)

isAvailableWithNoise

public boolean isAvailableWithNoise(java.lang.String feature,
                                    boolean defaultIfNoDBM)

addFeatureListener

public void addFeatureListener(FeatureListenerI fl)

removeFeatureListener

public void removeFeatureListener(FeatureListenerI fl)

getSchema

public SchemaI getSchema()

setSchema

public void setSchema(SchemaI $17)

getScript

public AbstractScript getScript()

setScript

public void setScript(AbstractScript $18)

getScriptLanguage

public java.lang.String getScriptLanguage()

setScriptLanguage

public void setScriptLanguage(java.lang.String $19)

getEh

public ErrorHandler getEh()

setEh

public void setEh(ErrorHandler $20)

getConfRoot

public electric.xml.Element getConfRoot()

setConfRoot

public void setConfRoot(electric.xml.Element $21)

isPleaseStop

public boolean isPleaseStop()

setPleaseStop

public void setPleaseStop(boolean $22)

getKeepAliveTimeout

public long getKeepAliveTimeout()

setKeepAliveTimeout

public void setKeepAliveTimeout(long $23)

getCurrentTx

public Transaction getCurrentTx()

setCurrentTx

public void setCurrentTx(Transaction $24)

isActivateL10nProvider

public boolean isActivateL10nProvider()

setActivateL10nProvider

public void setActivateL10nProvider(boolean $25)