| java.lang.Object
 org.webdocwf.util.loader.DataCleaning
| DataCleaning | | public class DataCleaning (Code) | | DataCleaning class contain method for executing data cleaning process
author:
Radoslav Dutina
version:
1.0 |
| Constructor Summary | |
| public | DataCleaning(ConfigReader configReader)
Constructor of DataCleaning class, without parameters. |
| Method Summary | |
| public void | cleaningColumnValues(String tableName, String columnName, String replacement, int rowNumber, Connection conn, String typeOfInsert, String importDefinitionName)
| | public void | cleaningInsert(String tableName, Connection conn, int rowNumber, String typeOfInsert, String msg, String importDefinitionName, String logFailedStatement)
| | public String | cleaningRelationValues(String tableName, String columnName, String replacement, String dataType, int rowNumber, Connection conn, String typeOfInsert, int currentVersion, boolean oid, String importDefinitionName, String versionColumnName, String logFailedStatement)
| | public void | cutingDataLenght(String tableName, Connection conn, String strQuery, int rowNumber, String onErrorContinue, String msg, String importDefinitionName, String logFailedStatement)
| | public void | cutingDataLenghtUpdate(String tableName, Connection conn, String strQuery, int rowNumber, String update, String onErrorContinue, String importDefinitionName, String logFailedStatement)
| | public String | getLogColumnName()
| | public String | getLogFailedStatement()
| | public String | getLogImportDefinitionName()
| | public String | getLogNewValue()
| | public String | getLogOperationName()
| | public String | getLogOriginalValue()
| | public String | getLogRowNumber()
| | public String | getLogTable()
| | public String | getLogTableName()
| | public String | getLogTime()
| | public String | getLogTypeName()
| | public void | setLogColumnName(String logColumnName)
| | public void | setLogImportDefinitionName(String logImportDefinitionName)
| | public void | setLogNewValue(String logNewValue)
| | public void | setLogOperationName(String logOperationName)
| | public void | setLogOriginalValue(String logOriginalValue)
| | public void | setLogPrimaryKeyValue(String string)
| | public void | setLogRowNumber(String logRowNumber)
| | public void | setLogTable(String logTable)
| | public void | setLogTableName(String logTableName)
| | public void | setLogTime(String string)
| | public void | setLogTypeName(String logTypeName)
| | public void | setLogger(Logger logger)
|
| DataCleaning | | public DataCleaning(ConfigReader configReader)(Code) | | Constructor of DataCleaning class, without parameters.
|
| cleaningColumnValues | | public void cleaningColumnValues(String tableName, String columnName, String replacement, int rowNumber, Connection conn, String typeOfInsert, String importDefinitionName)(Code) | | This method write message in to log table if some data in sql statements has value
Parameters:
tableName - is name of the table which is in the process
Parameters:
columnName - is the name of column in current table
Parameters:
replacement - is new value of data
Parameters:
rowNumber - is current row number
Parameters:
conn - is connection to target database (table)
Parameters:
typeOfInsert - is the parameter which may be 'insert' or 'update'
Parameters:
importDefinitionName - is name of the import definition job |
| cleaningInsert | | public void cleaningInsert(String tableName, Connection conn, int rowNumber, String typeOfInsert, String msg, String importDefinitionName, String logFailedStatement)(Code) | | This method write message in to log table if insert/update fails
Parameters:
tableName - is name of the table which is in the process
Parameters:
conn - is connection to target database (table)
Parameters:
rowNumber - is current row number
Parameters:
typeOfInsert - is the parameter which may be 'insert' or 'update'
Parameters:
msg - is error message
Parameters:
importDefinitionName - is name of the import definition job |
| cleaningRelationValues | | public String cleaningRelationValues(String tableName, String columnName, String replacement, String dataType, int rowNumber, Connection conn, String typeOfInsert, int currentVersion, boolean oid, String importDefinitionName, String versionColumnName, String logFailedStatement) throws LoaderException(Code) | | This method write message in to log table if relations between table faild to
insert/update
Parameters:
tableName - is name of the table which is in the process
Parameters:
columnName - is the name of column in current table
Parameters:
replacement - is new value of data
Parameters:
dataType - is type of relation column
Parameters:
rowNumber - is current row number
Parameters:
conn - is connection to target database (table)
Parameters:
typeOfInsert - represents type of operation (insert or update)
Parameters:
currentVersion - represents update version
Parameters:
oid - define if the oid logic is present
Parameters:
importDefinitionName - is name of the import definition job value of parameter |
| cutingDataLenght | | public void cutingDataLenght(String tableName, Connection conn, String strQuery, int rowNumber, String onErrorContinue, String msg, String importDefinitionName, String logFailedStatement) throws SQLException(Code) | | This method write message in to log table if some data must be truncated
Parameters:
tableName - is name of the table which is in the process
Parameters:
conn - is connection to target database (table)
Parameters:
strQuery - is string represented sql statement
Parameters:
rowNumber - is current row number
Parameters:
onErrorContinue - represents onErrorContinue tag
Parameters:
msg - represents error message
Parameters:
importDefinitionName - is name of the import definition job
throws:
SQLException - |
| cutingDataLenghtUpdate | | public void cutingDataLenghtUpdate(String tableName, Connection conn, String strQuery, int rowNumber, String update, String onErrorContinue, String importDefinitionName, String logFailedStatement) throws SQLException, LoaderException(Code) | | This method write message in to log table if some data must be truncated
Parameters:
tableName - is name of the table which is in the process
Parameters:
conn - is connection to target database (table)
Parameters:
strQuery - is string representing sql statement
Parameters:
rowNumber - is current row number
Parameters:
update - is the parameter which may be 'insert' or 'update'
Parameters:
onErrorContinue - is value of onErrorContinue attribute
Parameters:
importDefinitionName - is name of the import definition job
throws:
SQLException - |
| getLogColumnName | | public String getLogColumnName()(Code) | | This method read value from parameter logColumnName
value of parameter |
| getLogFailedStatement | | public String getLogFailedStatement()(Code) | | This method returns value of primary key for column which data wasn't succesufuly loaded
String value which is value of primary key for column |
| getLogImportDefinitionName | | public String getLogImportDefinitionName()(Code) | | This method read value from parameter logImportDefinitionName
value of parameter |
| getLogNewValue | | public String getLogNewValue()(Code) | | This method read value from parameter logNewValue
value of parameter |
| getLogOperationName | | public String getLogOperationName()(Code) | | This method read value from parameter logImportDefinitionName
value of parameter |
| getLogOriginalValue | | public String getLogOriginalValue()(Code) | | This method read value from parameter logOriginalValue
value of parameter |
| getLogRowNumber | | public String getLogRowNumber()(Code) | | This method read value from parameter logRowNumber
value of parameter |
| getLogTable | | public String getLogTable()(Code) | | This method read value from parameter logTable
value of parameter |
| getLogTableName | | public String getLogTableName()(Code) | | This method read value from parameter logTableName
value of parameter |
| getLogTime | | public String getLogTime()(Code) | | This method returns time when log was occured
String value which is time when log is inserted in table |
| getLogTypeName | | public String getLogTypeName()(Code) | | This method read value from parameter logTypeName
value of parameter |
| setLogColumnName | | public void setLogColumnName(String logColumnName)(Code) | | This method set the value of parameter logColumnName
Parameters:
logColumnName - is value of parmeter |
| setLogImportDefinitionName | | public void setLogImportDefinitionName(String logImportDefinitionName)(Code) | | This method set the value of parameter logImportDefinitionName
Parameters:
logImportDefinitionName - is value of parameter |
| setLogNewValue | | public void setLogNewValue(String logNewValue)(Code) | | This method set the value of parameter logNewValue
Parameters:
logNewValue - is value of parameter |
| setLogOperationName | | public void setLogOperationName(String logOperationName)(Code) | | This method set the value of parameter logOperationName
Parameters:
logOperationName - is value of parameter |
| setLogOriginalValue | | public void setLogOriginalValue(String logOriginalValue)(Code) | | This method set the value of parameter logOriginalValue
Parameters:
logOriginalValue - is value of parameter |
| setLogPrimaryKeyValue | | public void setLogPrimaryKeyValue(String string)(Code) | | This method set value of primary key for column which data wasn't succesufuly loaded
Parameters:
String - primary key |
| setLogRowNumber | | public void setLogRowNumber(String logRowNumber)(Code) | | This method set the value of parameter logRowNumber
Parameters:
logRowNumber - is value of parameter |
| setLogTable | | public void setLogTable(String logTable)(Code) | | This method set the value of parameter logTable
Parameters:
logTable - is value of parameter |
| setLogTableName | | public void setLogTableName(String logTableName)(Code) | | This method set the value of parameter logTableName
Parameters:
logTableName - is value of parameter |
| setLogTime | | public void setLogTime(String string)(Code) | | This method set time when log was occured
Parameters:
String - time |
| setLogTypeName | | public void setLogTypeName(String logTypeName)(Code) | | This method set the value of parameter logTypeName
Parameters:
logTypeName - is value of parameter |
| setLogger | | public void setLogger(Logger logger)(Code) | | Set Logger object
Parameters:
logger - Logger object which is used for log file |
|
|