| java.lang.Object org.netbeans.modules.etl.codegen.impl.BaseETLStrategyBuilder org.netbeans.modules.etl.codegen.impl.PipelinedStrategyBuilderImpl org.netbeans.modules.etl.codegen.impl.ValidatingStrategyBuilderImpl
ValidatingStrategyBuilderImpl | public class ValidatingStrategyBuilderImpl extends PipelinedStrategyBuilderImpl (Code) | | Extends base pipelining strategy builder to override methods which affect conduct and
execution of a validating collaboration.
author: Jonathan Giron version: $Revision$ |
addSelectRejectedRowCountStatement | public void addSelectRejectedRowCountStatement(ETLTaskNode updateStats, TargetTable tt) throws BaseException(Code) | | Adds statement, if appropriate, to the given ETLTaskNode in order to obtain count
of rejected rows from rejection details table.
Parameters: updateStats - ETLTaskNode to receive new statement Parameters: tt - TargetTable instance from which rejected row table information is derived throws: BaseException - if error occurs during statement generation |
buildCleanupStatements | protected void buildCleanupStatements(ETLTaskNode cleanupTask, List targetTables) throws BaseException(Code) | | |
buildInitializationStatements | protected void buildInitializationStatements(SQLDBTable table, ETLTaskNode initTask, Map connDefToLinkName) throws BaseException(Code) | | |
doBuildInitializationStatements | protected void doBuildInitializationStatements(TargetTable table, ETLTaskNode initTask, Map connDefToLinkName) throws BaseException(Code) | | Implements construction of appropriate initialization statements for a validating
engine task.
Parameters: table - TargetTable for which to construct initialization statements Parameters: initTask - ETLTaskNode representing initialization node to hold generatedstatements Parameters: connDefToLinkName - Map of DBConnectionDefinition instances to DB link names Parameters: pfGen - PipelinedFlowGenerator instance to use in generating statements throws: BaseException - if error occurs during statement generation |
Methods inherited from org.netbeans.modules.etl.codegen.impl.PipelinedStrategyBuilderImpl | public void addSelectRejectedRowCountStatement(ETLTaskNode updateStats, TargetTable tt) throws BaseException(Code)(Java Doc) protected void buildCleanupStatements(ETLTaskNode cleanupTask, List targetTables) throws BaseException(Code)(Java Doc) public ETLTaskNode buildCleanupTask(List targetTables) throws BaseException(Code)(Java Doc) void buildFlatfileSQLParts(ETLTaskNode initTask, ETLTaskNode cleanupTask, TargetTable tTable, ETLScriptBuilderModel model) throws BaseException(Code)(Java Doc) public ETLTaskNode buildInitTask(List targetTables) throws BaseException(Code)(Java Doc) protected void buildInitializationStatements(SQLDBTable table, ETLTaskNode initTask, Map connDefToLinkName) throws BaseException(Code)(Java Doc) ETLTaskNode buildPipelineTransformTask(ETLStrategyBuilderContext context, TargetTable tt) throws BaseException(Code)(Java Doc) protected void createTargetTableIfNotExists(TargetTable table, ETLTaskNode taskNode, String trgtConnName, DB targetDB) throws BaseException(Code)(Java Doc) protected SQLPart createTransformStatement(TargetTable tt, StatementContext context) throws BaseException(Code)(Java Doc) public void generateScriptForTable(ETLStrategyBuilderContext context) throws BaseException(Code)(Java Doc) protected String getCommentForTransformer(TargetTable targetTable) throws BaseException(Code)(Java Doc) protected String getCreateDBLinkSQL(DBConnectionDefinition connDef, String linkName) throws BaseException(Code)(Java Doc) protected String getDropExternalTableSQL(SQLDBTable table, String localName, boolean ifExists, StatementContext context) throws BaseException(Code)(Java Doc) public String getScriptToDisplay(ETLStrategyBuilderContext context) throws BaseException(Code)(Java Doc) protected String getTaskType()(Code)(Java Doc) protected boolean requiresRemoteAccess(SQLDBTable table)(Code)(Java Doc)
|
Methods inherited from org.netbeans.modules.etl.codegen.impl.BaseETLStrategyBuilder | protected void addCreateIfNotExistsSummaryTableStatement(ETLTaskNode initTask) throws BaseException(Code)(Java Doc) protected void addInsertNewExecutionRecordStatement(ETLTaskNode taskNode, TargetTable tt) throws BaseException(Code)(Java Doc) protected void addSelectExecutionIdForNewExecutionRecordStatement(ETLTaskNode pipeline, TargetTable tt) throws BaseException(Code)(Java Doc) protected void addUpdateExecutionRecordPreparedStatement(ETLTaskNode updateStats, TargetTable tt) throws BaseException(Code)(Java Doc) protected boolean areAllAssociatedTablesInternal(TargetTable tt) throws BaseException(Code)(Java Doc) protected void checkTargetConnectionDefinition(ETLStrategyBuilderContext context) throws BaseException(Code)(Java Doc) protected void createCorrelatedUpdateSQLParts(TargetTable tt, ETLTaskNode correlatedQueryExecutor, String trgtConnName, DB targetDB, DB statsDB, boolean genInsertSelect) throws BaseException(Code)(Java Doc) protected SQLPart createSQLPart(String sqlString, String key, String conDefnName)(Code)(Java Doc) protected void createTargetTableIfNotExists(TargetTable table, ETLTaskNode taskNode, String trgtConnName, DB targetDB, StatementContext context) throws BaseException(Code)(Java Doc) protected void createTransformerSQLPart(TargetTable tt, boolean useSourceFilter, ETLTaskNode transformerTask, String trgtConnName, ETLTaskNode cleanupTask, DB targetDB, DB statsDB) throws BaseException(Code)(Java Doc) protected SQLPart generateDefragPart(TargetTable tt, DB targetDB, int statementType) throws BaseException(Code)(Java Doc) protected SQLPart generateSQLPart(FlatfileDBTable flatfileDBTable, String tableName, String staticDirectory, String stmtType, String connPoolName, String flatfileRuntimeFilePath, boolean isDynamicPath, boolean createDataFileIfNotExist)(Code)(Java Doc) protected SQLPart generateTransformerSQLPart(TargetTable tt, boolean useSourceFilter, DB targetDB, int statementType, List srcTblList) throws BaseException(Code)(Java Doc) protected String getCommentForTransformer(TargetTable targetTable) throws BaseException(Code)(Java Doc) protected String getConDefnName(DBConnectionDefinition srcCondefn)(Code)(Java Doc) public static Properties getConnectionPropertiesFrom(DBConnectionDefinition def)(Code)(Java Doc) protected Map getCorrelatedUpdateQueries(TargetTable tt, DB targetDB, boolean genInsertSelect) throws BaseException(Code)(Java Doc) protected DB getDBFor(DBConnectionDefinition srcConDefn) throws BaseException(Code)(Java Doc) protected ETLEngine getEngine()(Code)(Java Doc) protected void getFlatfileInitSQLParts(FlatfileDefinition ffdb, InternalDBMetadata ffMetadata, boolean isAllDBTypeInternal, ETLTaskNode initTask, ETLTaskNode cleanupTask, String connPoolName, SQLDBTable flatfileRuntime, boolean createDataFileIfNotExist)(Code)(Java Doc) protected void getFlatfileInitSQLParts(FlatfileDefinition ffdb, InternalDBMetadata internalMetadata, ETLTaskNode initTask, ETLTaskNode cleanupTask, SQLDBTable flatfileRuntime, boolean createDataFileIfNotExist)(Code)(Java Doc) protected Statements getStatementsForTableDB(DBTable table) throws BaseException(Code)(Java Doc) protected Statements getStatementsForTableDB(DBTable table, ETLStrategyBuilderContext context) throws BaseException(Code)(Java Doc) protected Statements getStatementsForTargetTableDB(ETLStrategyBuilderContext context) throws BaseException(Code)(Java Doc) protected String getTargetConnName()(Code)(Java Doc) protected Statements getTargetStatements() throws BaseException(Code)(Java Doc) protected String getTransformerSQL(TargetTable targetTable, DB targetDB, List srcTblList, boolean useSourceFilter) throws BaseException(Code)(Java Doc) protected boolean isExtractionRequired(SourceTable sourceTable, TargetTable targetTable) throws BaseException(Code)(Java Doc) protected List makeUniqueTableNames(ETLStrategyBuilderContext context) throws BaseException(Code)(Java Doc) protected void populateFlatfileMetadata(TargetTable tTable, String tgtConnPoolName, InternalDBMetadata tgtInternalMetadata, ETLTaskNode initTask, ETLTaskNode cleanupTask) throws BaseException(Code)(Java Doc) protected void populateInitTask(ETLTaskNode initTask, ETLTaskNode cleanupTask, TargetTable tTable) throws BaseException(Code)(Java Doc) public void setETLScriptBuilderModel(ETLScriptBuilderModel model)(Code)(Java Doc) protected void truncateTableIfExists(SQLDBTable dbt, ETLTaskNode taskNode, String trgtConnName, Statements stmts, StatementContext sc) throws BaseException(Code)(Java Doc) protected void truncateTargetTableIfExists(TargetTable tt, ETLTaskNode taskNode, String trgtConnName, Statements stmts, StatementContext sc) throws BaseException(Code)(Java Doc) final protected void useUniqueNameIfRequired(SQLDBTable table, StatementContext sc) throws BaseException(Code)(Java Doc)
|
|
|