| java.lang.Object
 org.netbeans.modules.etl.codegen.impl.BaseETLStrategyBuilder
org.netbeans.modules.etl.codegen.impl.SimpleETLStrategyBuilderImpl
| SimpleETLStrategyBuilderImpl | | public class SimpleETLStrategyBuilderImpl extends BaseETLStrategyBuilder (Code) | | Strategy: If extractionRequired is true we will extract all the source table to target
database and then do the transformation. If extractionRequired is false we assume
source tables and target table are from same database so we directly jump to
transformation.
Note: In some cases where the source tables and target table are flat file we will also
jump directly transformation, but the caller has to make sure the table names are
unique since there might be situation where two Database was created and both have same
table name, in that case we just prefix the table name with database name
author:
Ahimanikya Satapathy |
| generateScriptForTable | | public void generateScriptForTable(ETLStrategyBuilderContext context) throws BaseException(Code) | | Before calling apply appropriate applyConnections
|
| 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)
|
|
|