|
IBM WebSphere Multichannel Bank Transformation Toolkit Javadoc | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.ibm.btt.base.BTTProcessorNotifier
com.ibm.btt.base.Service
com.ibm.btt.services.jdbc.JDBCService
com.ibm.btt.services.jdbc.Journal
com.ibm.btt.services.jdbc.JDBCJournal
@ATTR(value={"statementPoolSize#String#IMPLIED","poolName#String#IMPLIED","dataSourceName#String#IMPLIED","schema#String#IMPLIED","autoCommit#String#IMPLIED","waitRetry#String#REQUIRED","JDBCDriver#String#IMPLIED","createSchema#String#IMPLIED","sharedConnection#String#IMPLIED"}) public class JDBCJournal
Field Summary | |
---|---|
protected Hashtable |
columnsTable
Contains information about the relationship between a column in the database table and a data field in the context. |
protected boolean |
createSchema
Keeps whether the journal schema was also created in the database or not. |
protected java.lang.String |
date
Keeps the today date |
protected java.lang.String |
JDBCDriver
Keeps the name of the JDBC driver to be used to access the database. |
protected static java.lang.Object |
poolSem
|
protected static java.lang.Object |
resetSem
|
protected java.lang.String |
schemaName
Keeps the name of the schema where all journal tables are defined. |
protected static Hashtable |
schemasMetaData
Contains a hashtable that, for each schema created by the JDBCJournal, will keep a DatabaseResultSetMetaData object containing the definition of the columns of the schema tables. |
protected static boolean |
singleTableReset
|
protected java.lang.String |
tableName
Keeps the table name that is schemaName.entity_wrapNumber. |
protected static java.lang.String |
var_insert
|
protected static java.lang.String |
var_update
|
protected static java.lang.String |
var_where
|
protected int |
wrapNumber
Keeps the number of the generation being used by the current journal. |
Fields inherited from class com.ibm.btt.services.jdbc.Journal |
---|
COMPID, currentSingleTableReset, entity, fromPool, lastRecordNumber, recIdFromTable, recIdSem, singleTable, singleTableLastRecordNumber |
Fields inherited from class com.ibm.btt.services.jdbc.JDBCService |
---|
addPstmt, addString, autoCommit, connectionProperties, databaseConnection, databaseURL, dataSourceName, metaData, password, poolName, sharedConnection, STMT_POOL_SIZE_DEFAULT, stmtPool, stmtPoolSize, updateString, user, waitRetry |
Fields inherited from class com.ibm.btt.base.Service |
---|
externalizer, name |
Fields inherited from class com.ibm.btt.base.BTTProcessorNotifier |
---|
handlersList |
Constructor Summary | |
---|---|
JDBCJournal()
This constructor creates a JDBCJournal object. |
|
JDBCJournal(java.lang.String anEntityName,
java.lang.String aSchemaName)
This constructor creates a JDBCJournal object. |
Method Summary | |
---|---|
int |
addRecord(Context aContext,
HashtableFormat aHashtableFormat)
Calls the formatter (HashtableFormat parameter) format method by passing aContext as an argument. |
int |
addRecord(Context aContext,
java.lang.String aFormatName)
Instantiates the journal format with the name aFormatName and calls its format method by passing aContext as an argument. |
int |
addRecord(Hashtable aDataHashtable)
Inserts the data in aDataHashtable as a new row in the current journal table. |
protected Vector |
allEntitiesFromDatabase(java.lang.String aSchemaName)
Retrieves all entities from the Database for the specified schema. |
protected void |
buildAddString()
Builds an instance variable that is used when adding a record. |
protected void |
buildConnectionProperties()
Builds the hashtable containing all details needed to request the database connection. |
protected void |
buildUpdateString()
Builds an instance variable that is used when updating all columns of a record. |
void |
commit()
Commits all changes to the database. |
protected java.lang.String |
controlTableName()
Returns the current Control Table name. |
protected java.lang.String |
controlTableName(java.lang.String aSchemaName)
Returns the name of the control table for the aSchemaName schema. |
java.lang.String |
currentGenerationDate()
Returns the last date that the journal service was used by a specific entity. |
protected int |
currentWrapNumber()
Returns the current table generation number being used by the journal instance for the schema set in the schemaName attribute. |
protected int |
currentWrapNumberForSchema(java.lang.String aSchemaName)
Returns the current table generation number being used by the journal instance for the schema aSchemaName. |
protected void |
deleteJournalContent(int aGeneration)
Deletes the contents of a current journal table. |
protected void |
deleteRecord(int aRecordNumber)
Deletes a record in the current journal table. |
protected boolean |
existsSchema(java.lang.String aSchemaName)
Returns true if the given schema exists in the Database. |
Hashtable |
getColumnsTable()
Returns the columnsTable attribute value of the current journal. |
protected java.sql.Connection |
getDatabaseConnection()
Returns the databaseConnection attribute value. |
protected java.lang.String |
getDBType()
Return the DBType in String Format, default is DB2 |
Vector |
getEntities()
Retrieves all entities from the Database. |
java.lang.String |
getJDBCDriver()
Returns the JDBCDriver property value. |
int |
getLastRecordNumberFromTable()
Returns the lastRecordNumber from control table. |
int |
getNumberOfGenerations()
Returns the number of journal generations. |
protected DatabaseResultSetMetaData |
getSchemaMetaData(java.lang.String aSchemaName)
Returns the DatabaseResultSetMetaData instance associated with the schema aSchemaName. |
java.lang.String |
getSchemaName()
Returns the schemaName attribute value. |
java.lang.String |
getTableName()
Returns the current journal tableName. |
protected int |
getWrapNumber()
Returns the wrapNumber attribute value |
java.lang.Object |
initializeColumnFrom(Tag aTag)
Used by the JDBCJournal service externalizer to create the contents of the columnsTable instance attribute. |
java.lang.Object |
initializeFrom(Tag aTag)
Used by the services externalizer to set the JDBCJournal instance attributes as defined in the XML file. |
boolean |
isConnected()
Returns true if there is a connection to the database or false if there is not. |
boolean |
isCreateSchema()
Returns the createSchema property value. |
static boolean |
isSingleTableReset()
Returns the singleTableReset. |
boolean |
isValidEntity()
Returns true if the entity set for the current journal is valid or false if it is not. |
protected java.lang.String |
journalTableRowInsertDefinition()
Returns the Journal Table Row definition for an SQL INSERT request. |
void |
loadDriver()
Loads and registers the JDBC Driver given in the external definition of the service or the default JDBC Driver as set in the JournalConstants EJ_DEFAULT_JDBCDRIVER attribute. |
void |
loadDriver(java.lang.String aDriverName)
Loads and registers the JDBC Driver explicitly provided as an argument. |
static JDBCJournal |
newFor(java.lang.String anEntityName,
java.lang.String aSchemaName)
Returns a new JDBCJournal instance with the entityName and schemaName attributes set to the provided values. |
protected int |
nextWrapNumber()
Returns the next generation number to be used for the default schema. |
protected int |
nextWrapNumberForSchema(java.lang.String aSchemaName)
Returns the next generation number available for the specified schema. |
protected int |
numberOfGenerations(java.lang.String aSchemaName)
Returns the number of journal generations for the schema aSchemaName. |
void |
open(java.lang.String anEntity,
int aGeneration)
Opens the journal service with an entity and a generation number |
void |
open(java.lang.String aSchemaName,
java.lang.String anEntity,
int aGeneration)
Opens the journal service with a specific shema, an entity, and a generation number. |
void |
openForEntity(java.lang.String anEntity)
Opens the current journal table for anEntity. |
void |
openForEntity(java.lang.String anEntity,
java.lang.String aSchemaName)
Decides which is going to be the current journal table for anEntity. |
void |
openForSchema(java.lang.String aSchemaName)
Decides which is going to be the current journal table. |
void |
openOnCurrentTable()
Selects the already selected table generation for the current schema as the current journal table. |
void |
openOnCurrentTableForSchema(java.lang.String aSchemaName)
Selects the already selected table generation for the specified schema as the current journal table. |
void |
openOnNextTable()
Selects the next available table generation for the current schema as the current journal table. |
void |
openOnNextTableForSchema(java.lang.String aSchemaName)
Selects the next available table generation for the specified schema as the current journal table. |
int |
queryLastRecordNumber()
Returns the last record number in the current journal table. |
protected Vector |
recordToRow(Hashtable aDataHashtable)
Returns a list of ordered data field values. |
void |
resetSingleTableLastRecordNumber()
Resets the Journal last record number when different instances are accessing the same tables |
Hashtable |
retrieveLastRecord()
Retrieves the last record of the current journal table. |
void |
retrieveLastRecord(Context aContext,
HashtableFormat aHashtableFormat)
Retrieves the last record of the current journal table by calling the retrieveRecord(int, Context, HashtableFormat) method with the last record number as the first parameter. |
void |
retrieveLastRecord(Context aContext,
java.lang.String aFormatName)
Retrieves the last record of the current journal table by calling the retrieveRecord(int, Context, String) method with the last record number as first parameter. |
Vector |
retrieveLastRecords(int aNumber)
Returns a vector with aNumber or any number between 0 and aNumber of record Hashtables. |
void |
retrieveLastRecords(int aNumber,
Context aContext,
HashtableIndexedCollectionFormat anOutputFormat)
Retrieves the last aNumber records from the journal table and unformats them into the aContext using the anOutputFormat formatter. |
void |
retrieveLastRecords(int aNumber,
Context aContext,
java.lang.String anOutputFormatName)
Retrieves the last aNumber records from the journal table and unformats them into the aContext using the named anOutputFormatName formatter. |
Hashtable |
retrieveRecord(int aRecordNumber)
Retrieves the record with the record identification in the database equal to aRecordNumber. |
void |
retrieveRecord(int aRecordNumber,
Context aContext,
HashtableFormat aHashtableFormat)
Retrieves the record with record identification in the database equal to aRecordNumber. |
void |
retrieveRecord(int aRecordNumber,
Context aContext,
java.lang.String aFormatName)
Retrieves the record with record identification in the database equal to aRecordNumber. |
Vector |
retrieveRecords(java.lang.String aSearchCondition)
Retrieves all the records within the current journal that match aSearchCondition. |
void |
retrieveRecords(java.lang.String aSearchCondition,
Context aContext,
HashtableIndexedCollectionFormat anOutputFormat)
Retrieves all the records within the current journal that match aSearchCondition. |
void |
retrieveRecords(java.lang.String aSearchCondition,
Context aContext,
java.lang.String anOutputFormatName)
Retrieves all the records within the current journal that match aSearchCondition. |
Vector |
retrieveRecords(java.lang.String aSearchCondition,
Vector aColumnsVector)
Retrieves the columns in aColumnsVector of all the records within the current journal that match aSearchCondition. |
void |
retrieveRecords(java.lang.String aSearchCondition,
Vector aColumnsVector,
Context aContext,
HashtableIndexedCollectionFormat anOutputFormat)
Retrieves the columns in aColumnsVector of all the records within the current journal that match aSearchCondition. |
void |
retrieveRecords(java.lang.String aSearchCondition,
Vector aColumnsVector,
Context aContext,
java.lang.String anOutputFormatName)
Retrieves the columns in aColumnsVector of all the records within the current journal that match aSearchCondition. |
void |
rollback()
Rolls back all database changes. |
protected void |
setColumnsTable(Hashtable aColumnsHashtable)
Sets the columnsTable property to aColumnsHashtable value. |
void |
setCreateSchema(boolean newCreateSchema)
Sets the createSchema property to newCreateSchema. |
protected void |
setDatabaseConnection(java.sql.Connection aDatabaseConnection)
Sets the database connection property to aDatabaseConnection. |
void |
setEntity(java.lang.String anEntityName)
Sets the entity property value to anEntityName. |
void |
setJDBCDriver(java.lang.String newJDBCDriver)
Sets the JDBCDriver property value to newJDBCDriver. |
void |
setLastRecordNumberFromTable(int aLastRecordNumberFromTable)
Sets the lastRecordNumberFromTable into control table. |
void |
setSchemaName(java.lang.String aSchemaName)
Sets the schemaName property to aSchemaName |
static void |
setSingleTableReset(boolean singleTableReset)
Sets the singleTableReset. |
protected void |
setTableName(java.lang.String aTableName)
Sets the tableName. |
protected java.lang.String |
tableName(java.lang.String aSchemaName,
java.lang.String anEntityName,
int aGeneration)
Returns the journal table name for a specific schema name, entity name and generation. |
Vector |
toStrings()
Used by the Db2Journal service externalizer. |
int |
updateLastRecord(Context aContext,
HashtableFormat aHashtableFormat)
Updates the last record of the current journal table by calling the updateRecords(String, Context, HashtableFormat) method. |
int |
updateLastRecord(Context aContext,
HashtableFormat aHashtableFormat,
Vector aColumnsVector)
Updates the columns specified in aColumnsVector for the last record of the current journal table by calling the updateRecords(String, Context, HashtableFormat, Vector) method. |
int |
updateLastRecord(Context aContext,
java.lang.String aFormatName)
Updates the last record of the current journal table by calling the updateRecords(String, Context, String) method. |
int |
updateLastRecord(Context aContext,
java.lang.String aFormatName,
Vector aColumnsVector)
Updates the columns in aColumnsVector for the last record of the current journal table by calling the updateRecords(String, Context, String, Vector) method. |
int |
updateLastRecord(Hashtable aDataHashtable)
Updates the last record of the current journal table with the data in aDataHashtable. |
int |
updateLastRecord(Hashtable aDataHashtable,
Vector aColumnsVector)
Updates the columns in aColumnsVector for the last record of the current journal table with the data in aDataHashtable. |
int |
updateRecord(int aRecordNumber,
Context aContext,
HashtableFormat aHashtableFormat)
Updates the record identified by aRecordNumber within the journal table by calling the updateRecords(String, Context, HashtableFormat) method. |
int |
updateRecord(int aRecordNumber,
Context aContext,
HashtableFormat aHashtableFormat,
Vector aColumnsVector)
Updates the columns in aColumnsVector for the record identified by aRecordNumber within the journal table by calling the updateRecords(String, Context, HashtableFormat, Vector) method. |
int |
updateRecord(int aRecordNumber,
Context aContext,
java.lang.String aFormatName)
Updates the record identified by aRecordNumber within the journal table by calling the updateRecords(String, Context, String) method. |
int |
updateRecord(int aRecordNumber,
Context aContext,
java.lang.String aFormatName,
Vector aColumnsVector)
Updates the columns in aColumnsVector for the record identified by aRecordNumber within the journal table by calling the updateRecords(String, Context, String, Vector) method. |
int |
updateRecord(int aRecordNumber,
Hashtable aDataHashtable)
Updates the record identified by aRecordNumber within the journal table with the data provided in aDataHashtable by calling the updateRecords(String, Hashtable) method. |
int |
updateRecord(int aRecordNumber,
Hashtable aDataHashtable,
Vector aColumnsVector)
Updates the columns specified in aColumnsVector, for the record identified by aRecordNumber within the journal table, with the data provided in aDataHashtable. |
int |
updateRecords(java.lang.String aSearchCondition,
Context aContext,
HashtableFormat aHashtableFormat)
Updates all the current journal table records that match the search condition passed as an argument, with the data obtained by formatting aContext with the journal aHashtableFormat formatter. |
int |
updateRecords(java.lang.String aSearchCondition,
Context aContext,
HashtableFormat aHashtableFormat,
Vector aColumnsVector)
Updates the columns specified in aColumnsVector for all the current journal table records that match the search condition passed as an argument, with the data obtained by formatting aContext with the journal formatter aHashtableFormat. |
int |
updateRecords(java.lang.String aSearchCondition,
Context aContext,
java.lang.String aFormatName)
Updates all the current journal table records that match the search condition passed as an argument, with the data obtained by formatting aContext with the formatter defined by aFormatName. |
int |
updateRecords(java.lang.String aSearchCondition,
Context aContext,
java.lang.String aFormatName,
Vector aColumnsVector)
Updates the columns specified in aColumnsVector for all the current journal table records that match the search condition passed as an argument, with the data obtained by formatting aContext with the formatter defined by aFormatName. |
int |
updateRecords(java.lang.String aSearchCondition,
Hashtable aDataHashtable)
Updates all the current journal table records that match the search condition with the aDataHashtable data. |
int |
updateRecords(java.lang.String aSearchCondition,
Hashtable aDataHashtable,
Vector aColumnsVector)
Updates the columns specified in aColumnsVector with the data provided in aDataHashtable for the records matching the search condition within the journal table. |
Methods inherited from class com.ibm.btt.services.jdbc.Journal |
---|
close, getDate, getEntity, getInUse, getLastRecordNumber, getSingleTableLastRecordNumber, getState, initialize, isActive, isCurrentSingleTableReset, isFromPool, isRecIdFromTable, isSingleTable, open, reset, setCurrentSingleTableReset, setFromPool, setInUse, setLastRecordNumber, setRecIdFromTable, setSingleTable, setSingleTableLastRecordNumber, setState, terminate, today |
Methods inherited from class com.ibm.btt.base.Service |
---|
externalizer, getExternalizer, getTagName, readExternal, readExternal, readObject, removeExternal, setExternalizer, toString, toTags, writeExternal, writeExternal |
Methods inherited from class com.ibm.btt.base.BTTProcessorNotifier |
---|
addHandler, getHandlersList, getName, removeHandler, setName, signalEvent, signalEvent, signalEvent |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface com.ibm.btt.services.jdbc.JournalService |
---|
getAutoCommit, setAutoCommit |
Methods inherited from interface com.ibm.btt.services.jdbc.DatabaseConnect |
---|
connect, connect, connect, connect, connect, connect, disconnect, getDatabaseURL, getDataSourceName, getPoolName, getSharedConnection, isWaitRetry, setDatabaseURL, setDataSourceName, setPoolName, setSharedConnection, setWaitRetry |
Methods inherited from interface com.ibm.btt.base.Externalizable |
---|
getName, setName |
Field Detail |
---|
protected Hashtable columnsTable
protected java.lang.String JDBCDriver
protected boolean createSchema
protected java.lang.String schemaName
protected int wrapNumber
protected java.lang.String date
protected java.lang.String tableName
protected static final java.lang.String var_insert
protected static final java.lang.String var_update
protected static final java.lang.String var_where
protected static java.lang.Object poolSem
protected static java.lang.Object resetSem
protected static boolean singleTableReset
protected static Hashtable schemasMetaData
Constructor Detail |
---|
public JDBCJournal()
public JDBCJournal(java.lang.String anEntityName, java.lang.String aSchemaName) throws DSEInvalidRequestException
anEntityName
- java.lang.String - the Entity nameaSchemaName
- java.lang.String - the Schema name
DSEInvalidRequestException
- if the request is not validMethod Detail |
---|
public int addRecord(Context aContext, HashtableFormat aHashtableFormat) throws DSEInvalidArgumentException, DSEInvalidRequestException, DSEInternalErrorException, DSESQLException
addRecord
in interface JournalService
addRecord
in class Journal
aContext
- com.ibm.dse.base.ContextaHashtableFormat
- com.ibm.dse.base.HashtableFormat
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSEInvalidRequestException
- if the request is not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic int addRecord(Context aContext, java.lang.String aFormatName) throws DSEInvalidArgumentException, DSEInvalidRequestException, DSEInternalErrorException, DSESQLException
addRecord
in interface JournalService
addRecord
in class Journal
aContext
- com.ibm.dse.base.Context, the context where the data isaFormatName
- java.lang.String, the format name of the formatter to be used
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSEInvalidRequestException
- if the request is not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic int addRecord(Hashtable aDataHashtable) throws DSEInvalidRequestException, DSEInvalidArgumentException, DSEInternalErrorException, DSESQLException
addRecord
in interface JournalService
addRecord
in class Journal
aDataHashtable
- Hashtable - the Hashtable with the data to be inserted in the
database table
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSEInvalidRequestException
- if the request is not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtprotected void buildAddString() throws DSESQLException, DSEInternalErrorException, DSEInvalidRequestException, DSEInvalidArgumentException, DSEException
buildAddString
in class JDBCService
DSEInvalidRequestException
- if the request is not valid
DSEInternalErrorException
- if an internal program error occurs
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSESQLException
- if an SQLException is caught
DSEObjectNotFoundException
- if the JDBCServicesConnectionManager cannot be found
DSEException
- if an exception is thrown when calling the pool of
connections managerprotected void buildConnectionProperties()
buildConnectionProperties
in class JDBCService
protected void buildUpdateString() throws DSESQLException, DSEInternalErrorException, DSEInvalidRequestException, DSEInvalidArgumentException, DSEException
buildUpdateString
in class JDBCService
DSEInvalidRequestException
- if the request is not valid
DSEInternalErrorException
- if an internal program error occurs
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSESQLException
- if an SQLException is caught
DSEObjectNotFoundException
- if the JDBCServicesConnectionManager cannot be found
DSEException
- if an exception is thrown when calling the pool of
connections managerpublic void commit() throws DSESQLException
commit
in interface JournalService
commit
in class Journal
DSESQLException
- if commit failedprotected java.lang.String controlTableName()
controlTableName
in class Journal
public java.lang.String currentGenerationDate() throws DSEInternalErrorException, DSESQLException
currentGenerationDate
in class Journal
DSEInternalErrorException
- if an internal Program error is detected
DSESQLException
- if a SQLException occursprotected int currentWrapNumber() throws DSEInternalErrorException, DSEInvalidRequestException, DSEInvalidArgumentException, DSESQLException
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSEInvalidRequestException
- if the request is not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtprotected int currentWrapNumberForSchema(java.lang.String aSchemaName) throws DSEInternalErrorException, DSEInvalidRequestException, DSEInvalidArgumentException, DSESQLException
aSchemaName
- java.lang.String - the journal schema name
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSEInvalidRequestException
- if the request is not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtprotected void deleteJournalContent(int aGeneration) throws DSEInternalErrorException, DSESQLException
aGeneration
- int
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtprotected void deleteRecord(int aRecordNumber) throws DSEInternalErrorException, DSESQLException
aRecordNumber
- int
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic Hashtable getColumnsTable()
protected java.sql.Connection getDatabaseConnection()
getDatabaseConnection
in class JDBCService
public Vector getEntities() throws DSESQLException, DSEInternalErrorException
DSESQLException
- if an SQLException is caught
DSEInternalErrorException
- if an internal program error occurspublic java.lang.String getJDBCDriver()
getJDBCDriver
in interface JournalService
getJDBCDriver
in class Journal
public int getNumberOfGenerations() throws DSESQLException, DSEInternalErrorException
DSEInvalidRequestException
- if the request is not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic java.lang.String getSchemaName()
getSchemaName
in interface JournalService
getSchemaName
in class Journal
public java.lang.String getTableName()
getTableName
in interface JournalService
getTableName
in class Journal
protected int getWrapNumber()
public java.lang.Object initializeColumnFrom(Tag aTag)
aTag
- com.ibm.dse.base.Tag
public java.lang.Object initializeFrom(Tag aTag) throws java.io.IOException
initializeFrom
in class Service
aTag
- com.ibm.dse.base.Tag
java.io.IOException
- if an I/O exception occurs.public boolean isConnected() throws DSEInvalidRequestException, DSEInternalErrorException, DSESQLException, DSEObjectNotFoundException, DSEException
isConnected
in interface DatabaseConnect
isConnected
in class JDBCService
DSEInvalidRequestException
- if the request is not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caught
DSEObjectNotFoundException
DSEException
public boolean isCreateSchema()
isCreateSchema
in interface JournalService
isCreateSchema
in class Journal
public boolean isValidEntity() throws DSEInternalErrorException, DSESQLException
isValidEntity
in class Journal
DSEInternalErrorException
- if an internal program error is detected
DSESQLException
- if a SQLException is caughtprotected java.lang.String journalTableRowInsertDefinition() throws DSEInvalidArgumentException, DSEInvalidRequestException, DSEInternalErrorException, DSESQLException
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caught
DSEInvalidRequestException
- if the request is invalidpublic void loadDriver() throws DSEInternalErrorException
DSEInternalErrorException
- if an internal program error occurspublic void loadDriver(java.lang.String aDriverName) throws DSEInternalErrorException
aDriverName
- java.lang.String, the driver name (full path)
DSEInternalErrorException
- if an internal program error occurspublic static JDBCJournal newFor(java.lang.String anEntityName, java.lang.String aSchemaName) throws DSEInvalidRequestException
anEntityName
- java.lang.String, the name of the EntityaSchemaName
- java.lang.String, the name of the Schema
DSEInvalidRequestException
- if the request is not validprotected int nextWrapNumber() throws DSEInternalErrorException, DSEInvalidRequestException, DSEInvalidArgumentException, DSESQLException
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSEInvalidRequestException
- if the request is not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtprotected int nextWrapNumberForSchema(java.lang.String aSchemaName) throws DSEInternalErrorException, DSEInvalidRequestException, DSEInvalidArgumentException, DSESQLException
aSchemaName
- java.lang.String - the journal schema name
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSEInvalidRequestException
- if the request is not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic void open(java.lang.String anEntity, int aGeneration) throws DSEInvalidRequestException, DSEInternalErrorException, DSESQLException
anEntity
- java.lang.StringaGeneration
- int
DSEInvalidRequestException
- if journal service state is active
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic void open(java.lang.String aSchemaName, java.lang.String anEntity, int aGeneration) throws DSEInvalidRequestException, DSEInternalErrorException, DSESQLException
aSchemaName
- java.lang.StringanEntity
- java.lang.StringaGeneration
- int
DSEInvalidRequestException
- if journal service state is active
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic void openForEntity(java.lang.String anEntity) throws DSEInternalErrorException, DSEInvalidRequestException, DSEInvalidArgumentException, DSESQLException
anEntity
- java.lang.String, the name of the entity
DSEInvalidRequestException
- if the entity name is not valid
DSEInternalErrorException
- if an internal program error occurs
DSEInvalidArgumentException
- if an argument is not valid
DSESQLException
- if a SQLException occurspublic void openForEntity(java.lang.String anEntity, java.lang.String aSchemaName) throws DSEInternalErrorException, DSEInvalidRequestException, DSEInvalidArgumentException, DSESQLException
anEntity
- java.lang.String, the name of the entityaSchemaName
- java.lang.String, the name of the schema
DSEInvalidRequestException
- if the entity name is not valid
DSEInternalErrorException
- if an internal program error occurs
DSEInvalidArgumentException
- if an argument is not valid
DSESQLException
- if a SQLException occurspublic void openForSchema(java.lang.String aSchemaName) throws DSEInternalErrorException, DSEInvalidRequestException, DSEInvalidArgumentException, DSESQLException
aSchemaName
- java.lang.String, the name of the schema
DSEInvalidRequestException
- if the entity name is not valid
DSEInternalErrorException
- if an internal program error occurs
DSEInvalidArgumentException
- if an argument is not valid
DSESQLException
- if a SQLException occurspublic void openOnCurrentTable() throws DSEInvalidRequestException, DSEInternalErrorException, DSEInvalidArgumentException, DSESQLException
openOnCurrentTable
in class Journal
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSEInvalidRequestException
- if the request is not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic void openOnCurrentTableForSchema(java.lang.String aSchemaName) throws DSEInvalidRequestException, DSEInternalErrorException, DSEInvalidArgumentException, DSESQLException
aSchemaName
- java.lang.String, the journal schema name
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSEInvalidRequestException
- if the request is not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic void openOnNextTable() throws DSEInternalErrorException, DSEInvalidRequestException, DSEInvalidArgumentException, DSESQLException
openOnNextTable
in class Journal
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSEInvalidRequestException
- if the request is not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic void openOnNextTableForSchema(java.lang.String aSchemaName) throws DSEInternalErrorException, DSEInvalidRequestException, DSEInvalidArgumentException, DSESQLException
aSchemaName
- java.lang.String, the journal schema name
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSEInvalidRequestException
- if the request is not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic void resetSingleTableLastRecordNumber() throws DSESQLException, DSEInternalErrorException
resetSingleTableLastRecordNumber
in interface JournalService
resetSingleTableLastRecordNumber
in class Journal
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQL Exception is caughtpublic int queryLastRecordNumber() throws DSESQLException, DSEInternalErrorException
queryLastRecordNumber
in interface JournalService
queryLastRecordNumber
in class Journal
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtprotected Vector recordToRow(Hashtable aDataHashtable) throws DSEInvalidRequestException, DSEInternalErrorException, DSEInvalidArgumentException, DSESQLException
aDataHashtable
- Hashtable, the data to be used to build the database record
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSEInvalidRequestException
- if the request is not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic Hashtable retrieveLastRecord() throws DSEInternalErrorException, DSEInvalidArgumentException, DSESQLException
retrieveLastRecord
in interface JournalService
retrieveLastRecord
in class Journal
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic void retrieveLastRecord(Context aContext, HashtableFormat aHashtableFormat) throws DSEInvalidRequestException, DSEInternalErrorException, DSEInvalidArgumentException, DSESQLException
retrieveLastRecord
in interface JournalService
retrieveLastRecord
in class Journal
aContext
- com.ibm.dse.base.ContextaHashtableFormat
- com.ibm.dse.base.HashtableFormat
DSEInvalidRequestException
- if the input parameters are not valid
DSEInternalErrorException
- if an internal program error occurs
DSEInvalidArgumentException
- if an argument is not valid
DSESQLException
- if an SQLException is caughtpublic void retrieveLastRecord(Context aContext, java.lang.String aFormatName) throws DSEInvalidRequestException, DSEInternalErrorException, DSEInvalidArgumentException, DSESQLException
retrieveLastRecord
in interface JournalService
retrieveLastRecord
in class Journal
aContext
- com.ibm.dse.base.ContextaFormatName
- java.lang.String
DSEInvalidRequestException
- if the input parameters are not valid
DSEInternalErrorException
- if an internal program error occurs
DSEInvalidArgumentException
- if an argument is not valid
DSESQLException
- if an SQLException is caughtpublic Vector retrieveLastRecords(int aNumber) throws DSEInternalErrorException, DSEInvalidArgumentException, DSEInvalidRequestException, DSESQLException
retrieveLastRecords
in interface JournalService
retrieveLastRecords
in class Journal
aNumber
- int, the number of records to retrieve
DSEInvalidRequestException
- if the request is not valid
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic void retrieveLastRecords(int aNumber, Context aContext, HashtableIndexedCollectionFormat anOutputFormat) throws DSEInternalErrorException, DSEInvalidArgumentException, DSEInvalidRequestException, DSESQLException, DSEObjectNotFoundException
aNumber
- int - the number of records to retrieveaContext
- com.ibm.dse.base.Context - the context to where the retrieved
records will be unformattedanOutputFormat
- com.ibm.dse.base.HashtableIndexedCollectionFormat - the
formatter to unformat the retrieved records
DSEInvalidRequestException
- if the request is not valid
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caught
DSESObjectNotFoundException
- if an object is not found
DSEObjectNotFoundException
public void retrieveLastRecords(int aNumber, Context aContext, java.lang.String anOutputFormatName) throws DSEInternalErrorException, DSEInvalidArgumentException, DSEInvalidRequestException, DSESQLException, DSEObjectNotFoundException
aNumber
- int - the number of records to retrieveaContext
- com.ibm.dse.base.Context - the context to where the retrieved
records will be unformattedanOutputFormatName
- java.lang.String - the name of the formatter to unformat the
retrieved records
DSEInvalidRequestException
- if the request is not valid
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caught
DSESObjectNotFoundException
- if an object is not found
DSEObjectNotFoundException
public Hashtable retrieveRecord(int aRecordNumber) throws DSEInternalErrorException, DSEInvalidArgumentException, DSESQLException
retrieveRecord
in interface JournalService
retrieveRecord
in class Journal
aRecordNumber
- int - the record number
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic void retrieveRecord(int aRecordNumber, Context aContext, HashtableFormat aHashtableFormat) throws DSEInvalidRequestException, DSEInternalErrorException, DSEInvalidArgumentException, DSESQLException
retrieveRecord
in interface JournalService
retrieveRecord
in class Journal
aRecordNumber
- intaContext
- com.ibm.dse.base.ContextaHashtableFormat
- com.ibm.dse.base.HashtableFormat
DSEInvalidRequestException
- if the input parameters are not valid
DSEInternalErrorException
- if an internal program error occurs
DSEInvalidArgumentException
- if an argument is not valid
DSESQLException
- if an SQLException is caughtpublic void retrieveRecord(int aRecordNumber, Context aContext, java.lang.String aFormatName) throws DSEInvalidRequestException, DSEInternalErrorException, DSEInvalidArgumentException, DSESQLException
retrieveRecord
in interface JournalService
retrieveRecord
in class Journal
aRecordNumber
- intaContext
- com.ibm.dse.base.ContextaFormatName
- java.lang.String
DSEInvalidRequestException
- if the input parameters are not valid
DSEInternalErrorException
- if an internal program error occurs
DSEInvalidArgumentException
- if an argument is not valid
DSESQLException
- if an SQLException is caughtpublic Vector retrieveRecords(java.lang.String aSearchCondition) throws DSEInternalErrorException, DSEInvalidRequestException, DSEInvalidArgumentException, DSESQLException
retrieveRecords
in interface JournalService
retrieveRecords
in class Journal
aSearchCondition
- java.lang.String - the search condition in SQL format
DSEInvalidRequestException
- if the request is not valid
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic void retrieveRecords(java.lang.String aSearchCondition, Context aContext, HashtableIndexedCollectionFormat anOutputFormat) throws DSEInternalErrorException, DSEInvalidRequestException, DSEInvalidArgumentException, DSESQLException, DSEObjectNotFoundException
aSearchCondition
- java.lang.String - the search condition in SQL formataContext
- com.ibm.dse.base.Context - the context to where the retrieved
records will be unformattedanOutputFormat
- com.ibm.dse.base.HashtableIndexedCollectionFormat - the
formatter to unformat the retrieved records
DSEInvalidRequestException
- if the request is not valid
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caught
DSESObjectNotFoundException
- if an object is not found
DSEObjectNotFoundException
public void retrieveRecords(java.lang.String aSearchCondition, Context aContext, java.lang.String anOutputFormatName) throws DSEInternalErrorException, DSEInvalidRequestException, DSEInvalidArgumentException, DSESQLException, DSEObjectNotFoundException
aSearchCondition
- java.lang.String - the search condition in SQL formataContext
- com.ibm.dse.base.Context - the context to where the retrieved
records will be unformattedanOutputFormatName
- java.lang.String - the name of the formatter to unformat the
retrieved records
DSEInvalidRequestException
- if the request is not valid
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caught
DSESObjectNotFoundException
- if an object is not found
DSEObjectNotFoundException
public Vector retrieveRecords(java.lang.String aSearchCondition, Vector aColumnsVector) throws DSEInternalErrorException, DSEInvalidRequestException, DSEInvalidArgumentException, DSESQLException
aSearchCondition
- java.lang.String - the search condition in SQL formataColumnsVector
- com.ibm.dse.base.Vector - the vector that contains the columns
to be retrieved
DSEInvalidRequestException
- if the request is not valid
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic void retrieveRecords(java.lang.String aSearchCondition, Vector aColumnsVector, Context aContext, HashtableIndexedCollectionFormat anOutputFormat) throws DSEInternalErrorException, DSEInvalidRequestException, DSEInvalidArgumentException, DSESQLException, DSEObjectNotFoundException
aSearchCondition
- java.lang.String - the search condition in SQL formataColumnsVector
- com.ibm.dse.base.Vector - the vector that contains the columns
to be retrievedaContext
- com.ibm.dse.base.Context - the context to where the retrieved
records will be unformattedanOutputFormat
- com.ibm.dse.base.HashtableIndexedCollectionFormat - the
formatter to unformat the retrieved records
DSEInvalidRequestException
- if the request is not valid
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caught
DSEObjectNotFoundException
- if an object is not foundpublic void retrieveRecords(java.lang.String aSearchCondition, Vector aColumnsVector, Context aContext, java.lang.String anOutputFormatName) throws DSEInternalErrorException, DSEInvalidRequestException, DSEInvalidArgumentException, DSESQLException, DSEObjectNotFoundException
aSearchCondition
- java.lang.String - the search condition in SQL formataColumnsVector
- com.ibm.dse.base.Vector - the vector that contains the columns
to be retrievedaContext
- com.ibm.dse.base.Context - the context to where the retrieved
records will be unformattedanOutputFormatName
- java.lang.String - the name of the formatter to unformat the
retrieved records
DSEInvalidRequestException
- if the request is not valid
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caught
DSEObjectNotFoundException
- if an object is not foundpublic void rollback() throws DSESQLException
rollback
in interface JournalService
rollback
in class Journal
DSESQLException
- Thrown when the rollback failsprotected void setColumnsTable(Hashtable aColumnsHashtable)
aColumnsHashtable
- Hashtablepublic void setCreateSchema(boolean newCreateSchema)
setCreateSchema
in interface JournalService
setCreateSchema
in class Journal
newCreateSchema
- booleanprotected void setDatabaseConnection(java.sql.Connection aDatabaseConnection)
setDatabaseConnection
in class JDBCService
aDatabaseConnection
- Connectionpublic void setEntity(java.lang.String anEntityName)
setEntity
in interface JournalService
setEntity
in class Journal
anEntityName
- java.lang.Stringpublic void setJDBCDriver(java.lang.String newJDBCDriver)
setJDBCDriver
in interface JournalService
setJDBCDriver
in class Journal
newJDBCDriver
- java.lang.Stringpublic void setSchemaName(java.lang.String aSchemaName)
setSchemaName
in interface JournalService
setSchemaName
in class Journal
aSchemaName
- java.lang.String - the journal schema nameprotected void setTableName(java.lang.String aTableName)
setTableName
in class Journal
aTableName
- java.lang.Stringprotected java.lang.String tableName(java.lang.String aSchemaName, java.lang.String anEntityName, int aGeneration)
aSchemaName
- java.lang.String, the schema nameanEntityName
- java.lang.String - the entity nameaGeneration
- int - the generation number
public Vector toStrings()
toStrings
in class Service
public int updateLastRecord(Context aContext, HashtableFormat aHashtableFormat) throws DSEInvalidRequestException, DSEInternalErrorException, DSEInvalidArgumentException, DSESQLException
updateLastRecord
in interface JournalService
updateLastRecord
in class Journal
aContext
- com.ibm.dse.base.ContextaHashtableFormat
- com.ibm.dse.base.HashtableFormat
DSEInvalidArgumentException
- if an argument is not valid
DSEInvalidRequestException
- if the input parameters are not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic int updateLastRecord(Context aContext, HashtableFormat aHashtableFormat, Vector aColumnsVector) throws DSEInvalidRequestException, DSEInternalErrorException, DSEInvalidArgumentException, DSESQLException
aContext
- com.ibm.dse.base.ContextaHashtableFormat
- com.ibm.dse.base.HashtableFormataColumnsVector
- com.ibm.dse.base.Vector, the columns to be changed
DSEInvalidArgumentException
- if an argument is not valid
DSEInvalidRequestException
- if the input parameters are not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic int updateLastRecord(Context aContext, java.lang.String aFormatName) throws DSEInvalidRequestException, DSEInternalErrorException, DSEInvalidArgumentException, DSESQLException
updateLastRecord
in interface JournalService
updateLastRecord
in class Journal
aContext
- com.ibm.dse.base.Context - the context with the dataaFormatName
- java.lang.String - the journal format name to be used
DSEInvalidArgumentException
- if an argument is not valid
DSEInvalidRequestException
- if the input parameters are not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic int updateLastRecord(Context aContext, java.lang.String aFormatName, Vector aColumnsVector) throws DSEInvalidRequestException, DSEInternalErrorException, DSEInvalidArgumentException, DSESQLException
aContext
- com.ibm.dse.base.Context - the context with the dataaFormatName
- java.lang.String - the journal format name to be usedaColumnsVector
- com.ibm.dse.base.Vector - the columns to be changed
DSEInvalidArgumentException
- if an argument is not valid
DSEInvalidRequestException
- if the input parameters are not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic int updateLastRecord(Hashtable aDataHashtable) throws DSEInvalidRequestException, DSEInternalErrorException, DSEInvalidArgumentException, DSESQLException
updateLastRecord
in interface JournalService
updateLastRecord
in class Journal
aDataHashtable
- Hashtable - the Hashtable that contains the data
DSEInvalidArgumentException
- if an argument is not valid
DSEInvalidRequestException
- if the input parameters are not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic int updateLastRecord(Hashtable aDataHashtable, Vector aColumnsVector) throws DSEInvalidRequestException, DSEInternalErrorException, DSEInvalidArgumentException, DSESQLException
aDataHashtable
- Hashtable - the Hashtable that contains the dataaColumnsVector
- com.ibm.dse.base.Vector - the columns to be changed
DSEInvalidArgumentException
- if an argument is not valid
DSEInvalidRequestException
- if the input parameters are not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic int updateRecord(int aRecordNumber, Context aContext, HashtableFormat aHashtableFormat) throws DSEInvalidRequestException, DSEInternalErrorException, DSEInvalidArgumentException, DSESQLException
updateRecord
in interface JournalService
updateRecord
in class Journal
aRecordNumber
- int - the number of the record to be updatedaContext
- com.ibm.dse.base.ContextaHashtableFormat
- com.ibm.dse.base.HashtableFormat
DSEInvalidArgumentException
- if an argument is not valid
DSEInvalidRequestException
- if the input parameters are not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic int updateRecord(int aRecordNumber, Context aContext, HashtableFormat aHashtableFormat, Vector aColumnsVector) throws DSEInvalidRequestException, DSEInternalErrorException, DSEInvalidArgumentException, DSESQLException
aRecordNumber
- int - the number of the record to be updatedaContext
- com.ibm.dse.base.ContextaHashtableFormat
- com.ibm.dse.base.HashtableFormataColumnsVector
- com.ibm.dse.base.Vector - the columns to be changed
DSEInvalidArgumentException
- if an argument is not valid
DSEInvalidRequestException
- if the input parameters are not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic int updateRecord(int aRecordNumber, Context aContext, java.lang.String aFormatName) throws DSEInvalidRequestException, DSEInternalErrorException, DSEInvalidArgumentException, DSESQLException
updateRecord
in interface JournalService
updateRecord
in class Journal
aRecordNumber
- int - the number of the record to be updatedaContext
- com.ibm.dse.base.Context - the context with the dataaFormatName
- java.lang.String - the journal format name to be used
DSEInvalidArgumentException
- if an argument is not valid
DSEInvalidRequestException
- if the input parameters are not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic int updateRecord(int aRecordNumber, Context aContext, java.lang.String aFormatName, Vector aColumnsVector) throws DSEInvalidRequestException, DSEInternalErrorException, DSEInvalidArgumentException, DSESQLException
aRecordNumber
- int - the number of the record to be updatedaContext
- com.ibm.dse.base.Context - the context with the dataaFormatName
- java.lang.String - the journal format name to be usedaColumnsVector
- com.ibm.dse.base.Vector - the columns to be changed
DSEInvalidArgumentException
- if an argument is not valid
DSEInvalidRequestException
- if the input parameters are not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic int updateRecord(int aRecordNumber, Hashtable aDataHashtable) throws DSEInvalidRequestException, DSEInternalErrorException, DSEInvalidArgumentException, DSESQLException
updateRecord
in interface JournalService
updateRecord
in class Journal
aRecordNumber
- int - the number of the record to be updatedaDataHashtable
- Hashtable - the Hashtable containing the new data
DSEInvalidArgumentException
- if an argument is not valid
DSEInvalidRequestException
- if the input parameters are not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic int updateRecord(int aRecordNumber, Hashtable aDataHashtable, Vector aColumnsVector) throws DSEInvalidArgumentException, DSEInternalErrorException, DSEInvalidRequestException, DSESQLException
aRecordNumber
- int - the number of the record to be updatedaDataHashtable
- com.ibm.dse.base.Hashtable - the Hashtable that contains the
new dataaColumnsVector
- com.ibm.dse.base.Vector - the columns to be changed
com.ibm.dse.base.DSEInvalidArgumentException
- if the argument(s) is(are) not valid.
com.ibm.dse.base.DSEInternalErrorException
- if an internal program error occurs.
com.ibm.dse.base.DSEInvalidRequestException
- if the request is not valid.
DSESQLException
- if an SQLException is caught.
DSEInvalidArgumentException
DSEInternalErrorException
DSEInvalidRequestException
public int updateRecords(java.lang.String aSearchCondition, Context aContext, HashtableFormat aHashtableFormat) throws DSEInvalidRequestException, DSEInternalErrorException, DSEInvalidArgumentException, DSESQLException
updateRecords
in interface JournalService
updateRecords
in class Journal
aSearchCondition
- java.lang.StringaContext
- com.ibm.dse.base.ContextaHashtableFormat
- com.ibm.dse.base.HashtableFormat
DSEInvalidArgumentException
- if an argument is not valid
DSEInvalidRequestException
- if the input parameters are not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic int updateRecords(java.lang.String aSearchCondition, Context aContext, HashtableFormat aHashtableFormat, Vector aColumnsVector) throws DSEInvalidRequestException, DSEInternalErrorException, DSEInvalidArgumentException, DSESQLException
aSearchCondition
- java.lang.StringaContext
- com.ibm.dse.base.ContextaHashtableFormat
- com.ibm.dse.base.HashtableFormataColumnsVector
- com.ibm.dse.base.Vector - the columns to be changed
DSEInvalidArgumentException
- if an argument is not valid
DSEInvalidRequestException
- if the input parameters are not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic int updateRecords(java.lang.String aSearchCondition, Context aContext, java.lang.String aFormatName) throws DSEInvalidRequestException, DSEInternalErrorException, DSEInvalidArgumentException, DSESQLException
updateRecords
in interface JournalService
updateRecords
in class Journal
aSearchCondition
- java.lang.String - the search conditionaContext
- com.ibm.dse.base.Context - the context with the dataaFormatName
- java.lang.String - the journal format name that defines the
formatter to be used
DSEInvalidArgumentException
- if an argument is not valid
DSEInvalidRequestException
- if the input parameters are not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic int updateRecords(java.lang.String aSearchCondition, Context aContext, java.lang.String aFormatName, Vector aColumnsVector) throws DSEInvalidRequestException, DSEInternalErrorException, DSEInvalidArgumentException, DSESQLException
aSearchCondition
- java.lang.String - the search conditionaContext
- com.ibm.dse.base.Context - the context with the dataaFormatName
- java.lang.String - the journal format name that defines the
formatter to be usedaColumnsVector
- com.ibm.dse.base.Vector - the columns to be changed
DSEInvalidArgumentException
- if an argument is not valid
DSEInvalidRequestException
- if the input parameters are not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic int updateRecords(java.lang.String aSearchCondition, Hashtable aDataHashtable) throws DSEInvalidRequestException, DSEInternalErrorException, DSEInvalidArgumentException, DSESQLException
updateRecords
in interface JournalService
updateRecords
in class Journal
aSearchCondition
- java.lang.String - the search conditionaDataHashtable
- Hashtable - the Hashtable that contains the new data
DSEInvalidArgumentException
- if an argument is not valid
DSEInvalidRequestException
- if the input parameters are not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtpublic int updateRecords(java.lang.String aSearchCondition, Hashtable aDataHashtable, Vector aColumnsVector) throws DSEInvalidArgumentException, DSEInternalErrorException, DSEInvalidRequestException, DSESQLException
aSearchCondition
- java.lang.String - the search conditionaDataHashtable
- com.ibm.dse.base.Hashtable - the Hashtable that contains the
new dataaColumnsVector
- com.ibm.dse.base.Vector - the columns to be changed
com.ibm.dse.base.DSEInvalidArgumentException
- if the argument(s) is(are) not valid.
com.ibm.dse.base.DSEInternalErrorException
- if an internal program error occurs.
com.ibm.dse.base.DSEInvalidRequestException
- if the request is not valid.
DSESQLException
- if an SQLException is caught.
DSEInvalidArgumentException
DSEInternalErrorException
DSEInvalidRequestException
public static boolean isSingleTableReset()
public static void setSingleTableReset(boolean singleTableReset)
singleTableReset
- The singleTableReset to setpublic int getLastRecordNumberFromTable() throws DSEInvalidRequestException
getLastRecordNumberFromTable
in interface JournalService
getLastRecordNumberFromTable
in class Journal
DSEInvalidRequestException
public void setLastRecordNumberFromTable(int aLastRecordNumberFromTable) throws DSEInvalidRequestException
setLastRecordNumberFromTable
in interface JournalService
setLastRecordNumberFromTable
in class Journal
lastRecordNumberFromTable
- The lastRecordNumberFromTable to set
DSEInvalidRequestException
DSEException
protected int numberOfGenerations(java.lang.String aSchemaName) throws DSEInvalidRequestException, DSESQLException, DSEInternalErrorException
aSchemaName
- java.lang.String the journal schema nameschemaInDatabase
- java.lang.String indicates whether the schema was created in
the database
DSEInvalidRequestException
- if the request is not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtprotected java.lang.String controlTableName(java.lang.String aSchemaName)
aSchemaName
- java.lang.String the name of the journal schemaprotected boolean existsSchema(java.lang.String aSchemaName) throws DSEInternalErrorException, DSESQLException
aSchemaName
- java.lang.String the journal schema name
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caughtprotected DatabaseResultSetMetaData getSchemaMetaData(java.lang.String aSchemaName) throws DSEInvalidArgumentException, DSEInvalidRequestException, DSEInternalErrorException, DSESQLException
aSchemaName
- java.lang.String the journal schema nameschemaInDatabase
- java.lang.String indicates whether the schema was created in
the database
DSEInvalidArgumentException
- if the argument(s) is(are) not valid
DSEInvalidRequestException
- if the request is not valid
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQL Exception is caughtprotected Vector allEntitiesFromDatabase(java.lang.String aSchemaName) throws DSEInternalErrorException, DSESQLException, DSEInvalidRequestException
aSchemaName
- java.lang.String, the name of the journal schema
DSEInternalErrorException
- if an internal program error occurs
DSESQLException
- if an SQLException is caught
DSEInvalidRequestException
protected java.lang.String getDBType()
|
IBM WebSphere Multichannel Bank Transformation Toolkit Javadoc | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |