Java Doc for PipelinedStrategyBuilderImpl.java in  » IDE-Netbeans » etl.project » org » netbeans » modules » etl » codegen » impl » Java Source Code / Java DocumentationJava Source Code and Java Documentation

Java Source Code / Java Documentation 1.  6.0 JDK Core 2.  6.0 JDK Modules 3.  6.0 JDK Modules com.sun 4.  6.0 JDK Modules com.sun.java 5.  6.0 JDK Modules sun 6.  6.0 JDK Platform 7.  Ajax 8.  Apache Harmony Java SE 9.  Aspect oriented 10.  Authentication Authorization 11.  Blogger System 12.  Build 13.  Byte Code 14.  Cache 15.  Chart 16.  Chat 17.  Code Analyzer 18.  Collaboration 19.  Content Management System 20.  Database Client 21.  Database DBMS 22.  Database JDBC Connection Pool 23.  Database ORM 24.  Development 25.  EJB Server geronimo 26.  EJB Server GlassFish 27.  EJB Server JBoss 4.2.1 28.  EJB Server resin 3.1.5 29.  ERP CRM Financial 30.  ESB 31.  Forum 32.  GIS 33.  Graphic Library 34.  Groupware 35.  HTML Parser 36.  IDE 37.  IDE Eclipse 38.  IDE Netbeans 39.  Installer 40.  Internationalization Localization 41.  Inversion of Control 42.  Issue Tracking 43.  J2EE 44.  JBoss 45.  JMS 46.  JMX 47.  Library 48.  Mail Clients 49.  Net 50.  Parser 51.  PDF 52.  Portal 53.  Profiler 54.  Project Management 55.  Report 56.  RSS RDF 57.  Rule Engine 58.  Science 59.  Scripting 60.  Search Engine 61.  Security 62.  Sevlet Container 63.  Source Control 64.  Swing Library 65.  Template Engine 66.  Test Coverage 67.  Testing 68.  UML 69.  Web Crawler 70.  Web Framework 71.  Web Mail 72.  Web Server 73.  Web Services 74.  Web Services apache cxf 2.0.1 75.  Web Services AXIS2 76.  Wiki Engine 77.  Workflow Engines 78.  XML 79.  XML UI Java Java Tutorial Java Open Source Jar File Download Java Articles Java Products Java by API Photoshop Tutorials Maya Tutorials Flash Tutorials 3ds-Max Tutorials Illustrator Tutorials GIMP Tutorials C# / C Sharp C# / CSharp Tutorial C# / CSharp Open Source ASP.Net ASP.NET Tutorial JavaScript DHTML JavaScript Tutorial JavaScript Reference HTML / CSS HTML CSS Reference C / ANSI-C C Tutorial C++ C++ Tutorial Ruby PHP Python Python Tutorial Python Open Source SQL Server / T-SQL SQL Server / T-SQL Tutorial Oracle PL / SQL Oracle PL/SQL Tutorial PostgreSQL SQL / MySQL MySQL Tutorial VB.Net VB.Net Tutorial Flash / Flex / ActionScript VBA / Excel / Access / Word XML XML Tutorial Microsoft Office PowerPoint 2007 Tutorial Microsoft Office Excel 2007 Tutorial Microsoft Office Word 2007 Tutorial

Java Source Code / Java Documentation » IDE Netbeans » etl.project » org.netbeans.modules.etl.codegen.impl   Source Cross Reference   Class Diagram   Java Document (Java Doc)   java.lang.Object    org.netbeans.modules.etl.codegen.impl.BaseETLStrategyBuilder       org.netbeans.modules.etl.codegen.impl.PipelinedStrategyBuilderImpl All known Subclasses:   org.netbeans.modules.etl.codegen.impl.ValidatingStrategyBuilderImpl, PipelinedStrategyBuilderImpl public class PipelinedStrategyBuilderImpl extends BaseETLStrategyBuilder (Code) author:    Jonathan Giron author:    Ritesh Adval version:    $Revision$ Field Summary protected  AxionDB db      protected  Map linkTableMap      protected  AxionPipelineStatements pipelineStmts      protected  List remoteTables      protected  AxionStatements stmts      Constructor Summary public   PipelinedStrategyBuilderImpl(ETLScriptBuilderModel model)      Method Summary public  void addSelectRejectedRowCountStatement(ETLTaskNode updateStats, TargetTable tt)      protected  void buildCleanupStatements(ETLTaskNode cleanupTask, List targetTables)      public  ETLTaskNode buildCleanupTask(List targetTables)      Builds ETLTaskNode to hold and execute statements associated with execution cleanup for the given List of TargetTables.  void buildFlatfileSQLParts(ETLTaskNode initTask, ETLTaskNode cleanupTask, TargetTable tTable, ETLScriptBuilderModel model)      public  ETLTaskNode buildInitTask(List targetTables)      protected  void buildInitializationStatements(SQLDBTable table, ETLTaskNode initTask, Map connDefToLinkName)       ETLTaskNode buildPipelineTransformTask(ETLStrategyBuilderContext context, TargetTable tt)      protected  void createTargetTableIfNotExists(TargetTable table, ETLTaskNode taskNode, String trgtConnName, DB targetDB)      protected  SQLPart createTransformStatement(TargetTable tt, StatementContext context)      Creates SQLPart containing appropriate transformation statement for the given run mode and TargetTable instance, using the given StatementContext to assist in statement generation. public  void generateScriptForTable(ETLStrategyBuilderContext context)      protected  String getCommentForTransformer(TargetTable targetTable)      protected  String getCreateDBLinkSQL(DBConnectionDefinition connDef, String linkName)      protected  String getDropExternalTableSQL(SQLDBTable table, String localName, boolean ifExists, StatementContext context)      Generates drop external statement for the given SQLDBTable if appropriate. public  String getScriptToDisplay(ETLStrategyBuilderContext context)      protected  String getTaskType()      protected  boolean requiresRemoteAccess(SQLDBTable table)      Field Detail db protected AxionDB db(Code) linkTableMap protected Map linkTableMap(Code) pipelineStmts protected AxionPipelineStatements pipelineStmts(Code) remoteTables protected List remoteTables(Code) stmts protected AxionStatements stmts(Code) Constructor Detail PipelinedStrategyBuilderImpl public PipelinedStrategyBuilderImpl(ETLScriptBuilderModel model) throws BaseException(Code) Method Detail addSelectRejectedRowCountStatement public void addSelectRejectedRowCountStatement(ETLTaskNode updateStats, TargetTable tt) throws BaseException(Code) buildCleanupStatements protected void buildCleanupStatements(ETLTaskNode cleanupTask, List targetTables) throws BaseException(Code) Parameters:   cleanupTask - Parameters:   pfGen - Parameters:   targetTables - buildCleanupTask public ETLTaskNode buildCleanupTask(List targetTables) throws BaseException(Code) Builds ETLTaskNode to hold and execute statements associated with execution cleanup for the given List of TargetTables. Parameters:   pfGen - PipelinedFlowGenerator to use in building the cleanup task node Parameters:   targetTables - List of TargetTables whose cleanup statements are to begenerated ETLTaskNode containing cleanup statements to be executed throws:   BaseException - if error occurs during statement generation buildFlatfileSQLParts void buildFlatfileSQLParts(ETLTaskNode initTask, ETLTaskNode cleanupTask, TargetTable tTable, ETLScriptBuilderModel model) throws BaseException(Code) buildInitTask public ETLTaskNode buildInitTask(List targetTables) throws BaseException(Code) buildInitializationStatements protected void buildInitializationStatements(SQLDBTable table, ETLTaskNode initTask, Map connDefToLinkName) throws BaseException(Code) buildPipelineTransformTask ETLTaskNode buildPipelineTransformTask(ETLStrategyBuilderContext context, TargetTable tt) throws BaseException(Code) createTargetTableIfNotExists protected void createTargetTableIfNotExists(TargetTable table, ETLTaskNode taskNode, String trgtConnName, DB targetDB) throws BaseException(Code) createTransformStatement protected SQLPart createTransformStatement(TargetTable tt, StatementContext context) throws BaseException(Code) Creates SQLPart containing appropriate transformation statement for the given run mode and TargetTable instance, using the given StatementContext to assist in statement generation. Parameters:   runMode - ETLProcessFlowGenerator.DESIGN_TIME if statement will be executed indesign time, ETLProcessFlowGenerator.RUN_TIME if statement will be executedin runtime on an app server Parameters:   tt - TargetTable whose transformation statement is to be generated Parameters:   context - StatementContext to use in generating transformation statement SQLPart containing transformation statement throws:   BaseException - if error occurs during statement generation generateScriptForTable public void generateScriptForTable(ETLStrategyBuilderContext context) throws BaseException(Code) Before calling apply appropriate applyConnections getCommentForTransformer protected String getCommentForTransformer(TargetTable targetTable) throws BaseException(Code) Generate Transformer comment line for a given target table Parameters:   targetTable - Comment String getCreateDBLinkSQL protected String getCreateDBLinkSQL(DBConnectionDefinition connDef, String linkName) throws BaseException(Code) getDropExternalTableSQL protected String getDropExternalTableSQL(SQLDBTable table, String localName, boolean ifExists, StatementContext context) throws BaseException(Code) Generates drop external statement for the given SQLDBTable if appropriate. Parameters:   table - SQLDBTable for which to generate a drop external statement Parameters:   localName - local name of table as used in the Axion database; may bedifferent from the table name contained in table Parameters:   ifExists - true if statement should include an "IF EXISTS" qualifier Parameters:   context - StatementContext to use in generating statement SQL statement representing drop external statement for SQLDBTable. throws:   BaseException - if error occurs during statement generation getScriptToDisplay public String getScriptToDisplay(ETLStrategyBuilderContext context) throws BaseException(Code) getTaskType protected String getTaskType()(Code) requiresRemoteAccess protected boolean requiresRemoteAccess(SQLDBTable table)(Code) Fields inherited from org.netbeans.modules.etl.codegen.impl.BaseETLStrategyBuilder final protected static MessageManager MSG_MGR(Code)(Java Doc) protected ETLScriptBuilderModel builderModel(Code)(Java Doc) protected DBConnectionFactory connFactory(Code)(Java Doc) protected DBConnectionDefinition targtConDef(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) Methods inherited from java.lang.Object native protected Object clone() throws CloneNotSupportedException(Code)(Java Doc) public boolean equals(Object obj)(Code)(Java Doc) protected void finalize() throws Throwable(Code)(Java Doc) final native public Class getClass()(Code)(Java Doc) native public int hashCode()(Code)(Java Doc) final native public void notify()(Code)(Java Doc) final native public void notifyAll()(Code)(Java Doc) public String toString()(Code)(Java Doc) final native public void wait(long timeout) throws InterruptedException(Code)(Java Doc) final public void wait(long timeout, int nanos) throws InterruptedException(Code)(Java Doc) final public void wait() throws InterruptedException(Code)(Java Doc)