|
xmlBlaster 2.2.0 contributions API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.xmlBlaster.contrib.replication.TableToWatchInfo
public class TableToWatchInfo
TableToWatchInfo is a place holder (as an ejb) for data which is stored in the ${replPrefix}tables table. It also offers facility to retrieve the data from info objects.
Field Summary | |
---|---|
static java.lang.String |
ACTION_KEY
|
static java.lang.String |
ALL_TOKEN
|
static java.lang.String |
EMPTY
|
static java.lang.String |
KEY_SEP
|
static java.lang.String |
SCHEMA_PREFIX
|
static java.lang.String |
SEQUENCE_KEY
|
static java.lang.String |
STATUS_CREATING
|
static java.lang.String |
STATUS_OK
|
static java.lang.String |
STATUS_REMOVE
|
static java.lang.String |
TABLE_PREFIX
|
static java.lang.String |
TABLE_PREFIX_WITH_SEP
this is used as the prefix for all tables to replicate |
static java.lang.String |
TRIGGER_KEY
|
static java.lang.String |
VAL_SEP
|
Constructor Summary | |
---|---|
TableToWatchInfo()
|
|
TableToWatchInfo(java.lang.String catalog,
java.lang.String schema,
java.lang.String table)
|
Method Summary | |
---|---|
void |
assignFromInfoPair(java.lang.String key,
java.lang.String value)
Parses the data which is passed as a key/value pair. |
static TableToWatchInfo |
get(java.sql.Connection conn,
java.lang.String tableName,
java.lang.String catalog,
java.lang.String schema,
java.lang.String table,
TableToWatchInfo tableToWatch)
|
java.lang.String |
getActions()
|
static TableToWatchInfo[] |
getAll(java.sql.Connection conn,
java.lang.String confTableName)
Gets the entire configuration information of the configuration table specified in the argument list. |
java.lang.String |
getCatalog()
|
java.lang.String |
getConfigKey()
|
java.lang.String |
getConfigValue()
|
int |
getDebug()
|
long |
getReplKey()
|
java.lang.String |
getSchema()
|
static java.lang.String |
getSortedTablesToWatch(java.sql.Connection conn,
I_Info info,
java.util.List outputSequence)
|
java.lang.String |
getStatus()
|
java.lang.String |
getTable()
|
static TableToWatchInfo[] |
getTablesToWatch(java.sql.Connection conn,
I_Info originalInfo)
Gets an array containing all the tables to watch found in this configuration info object. |
java.lang.String |
getTrigger()
|
boolean |
isReplicate()
|
boolean |
isStatusOk(I_DbSpecific dbSpecific,
java.sql.Connection conn)
Checks if the status is OK. |
void |
removeFromDb(java.lang.String replicationPrefix,
I_DbPool dbPool)
|
void |
setActions(java.lang.String actions)
|
void |
setCatalog(java.lang.String catalog)
|
void |
setDebug(int debug)
|
void |
setReplKey(long replKey)
|
void |
setSchema(java.lang.String schema)
|
void |
setStatus(java.lang.String status)
|
void |
setTable(java.lang.String table)
|
void |
setTrigger(java.lang.String trigger)
|
void |
store(java.lang.String replPrefix,
I_DbPool dbPool,
java.sql.Connection conn)
First checks if the entry exists already. |
void |
storeStatus(java.lang.String replicationPrefix,
I_DbPool dbPool)
|
java.lang.String |
toXml()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final java.lang.String ACTION_KEY
public static final java.lang.String TRIGGER_KEY
public static final java.lang.String SEQUENCE_KEY
public static final java.lang.String STATUS_CREATING
public static final java.lang.String STATUS_OK
public static final java.lang.String STATUS_REMOVE
public static final java.lang.String TABLE_PREFIX
public static final java.lang.String SCHEMA_PREFIX
public static final java.lang.String KEY_SEP
public static final java.lang.String VAL_SEP
public static final java.lang.String EMPTY
public static final java.lang.String ALL_TOKEN
public static final java.lang.String TABLE_PREFIX_WITH_SEP
Constructor Detail |
---|
public TableToWatchInfo()
public TableToWatchInfo(java.lang.String catalog, java.lang.String schema, java.lang.String table)
Method Detail |
---|
public static java.lang.String getSortedTablesToWatch(java.sql.Connection conn, I_Info info, java.util.List outputSequence) throws java.lang.Exception
java.lang.Exception
public static TableToWatchInfo[] getTablesToWatch(java.sql.Connection conn, I_Info originalInfo) throws java.lang.Exception
info
-
java.lang.Exception
public java.lang.String getConfigKey()
public java.lang.String getConfigValue()
public void assignFromInfoPair(java.lang.String key, java.lang.String value) throws java.lang.Exception
key
- value
-
java.lang.Exception
public java.lang.String getCatalog()
public void setCatalog(java.lang.String catalog)
catalog
- The catalog to set.public boolean isReplicate()
public void setActions(java.lang.String actions)
replicate
- The replicate to set.public long getReplKey()
public void setReplKey(long replKey)
replKey
- The replKey to set.public java.lang.String getSchema()
public void setSchema(java.lang.String schema)
schema
- The schema to set.public java.lang.String getStatus()
public void setStatus(java.lang.String status)
status
- The status to set.public java.lang.String getTable()
public void setTable(java.lang.String table)
table
- The table to set.public java.lang.String getTrigger()
public void setTrigger(java.lang.String trigger)
trigger
- The trigger to set.public void store(java.lang.String replPrefix, I_DbPool dbPool, java.sql.Connection conn) throws java.lang.Exception
replPrefix
- dbPool
- conn
-
java.lang.Exception
public static TableToWatchInfo get(java.sql.Connection conn, java.lang.String tableName, java.lang.String catalog, java.lang.String schema, java.lang.String table, TableToWatchInfo tableToWatch) throws java.lang.Exception
conn
- tableName
- The name of the table from which to retrieve the informationcatalog
- schema
- table
- tableToWatch
- can be null. If it is not null, it will be changed appropriately and returned.
java.lang.Exception
public static TableToWatchInfo[] getAll(java.sql.Connection conn, java.lang.String confTableName)
conn
- tableName
-
public java.lang.String getActions()
public java.lang.String toXml()
public int getDebug()
public void setDebug(int debug)
public void storeStatus(java.lang.String replicationPrefix, I_DbPool dbPool) throws java.lang.Exception
java.lang.Exception
public void removeFromDb(java.lang.String replicationPrefix, I_DbPool dbPool) throws java.lang.Exception
java.lang.Exception
public boolean isStatusOk(I_DbSpecific dbSpecific, java.sql.Connection conn)
dbSpecific
- conn
-
|
xmlBlaster 2.2.0 contributions API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |