程序包 com.sh.wf.etl.compontent

类 ETLBase

java.lang.Object
com.sh.wf.etl.compontent.ETLBase
直接已知子类:
ETLSource
public abstract class ETLBase extends Object

Description:

Title:首亨软件 - TSS/CRM等

从以下版本开始:
2017年7月18日

  • 字段详细资料

    • etlData

      protected ETLData etlData

    • id

      protected String id

    • dbId

      protected String dbId

    • tableName

      protected String tableName

    • toLineMap

      protected Map<ETLBase,List<ArrowLine>> toLineMap

    • isStartNode

      protected boolean isStartNode

    • pkCol

      protected String pkCol

    • pkDataType

      protected String pkDataType

    • pageCol

      protected String pageCol

    • pageDataType

      protected String pageDataType

    • pageColValue

      protected String pageColValue

    • everyRows

      protected int everyRows

    • maxSyncRows

      protected int maxSyncRows

    • javaAttr

      protected JavaAttr javaAttr

  • 构造器详细资料

    • ETLBase

      public ETLBase()

  • 方法详细资料

    • parser

      public abstract void parser(org.jdom2.Element nodeEl)

    • commonParser

      public void commonParser(org.jdom2.Element nodeEl)

    • run

      public abstract void run(ETLContext etlContext)

    • addToLine

      public void addToLine(ETLBase base, ArrowLine line)

    • getColumnObj

      public ETLColumnObj getColumnObj(String tableCol)

    • processFixColumnObj

      public void processFixColumnObj(ETLContext etlContext, StringBuilder toInsertColSql, StringBuilder toInsertValueSql, StringBuilder toUpdateSql, StringBuilder toUpdateWhereSql, DataCenter toDc)
      设置固定列
      参数:
      etlContext - ETLContext
      toInsertColSql - StringBuilder
      toInsertValueSql - StringBuilder
      toUpdateSql - StringBuilder
      toUpdateWhereSql - StringBuilder
      toDc - DataCenter

    • processExecuteBeforeSqlReset

      public void processExecuteBeforeSqlReset(ETLContext etlContext)

    • processExecuteBeforeSql

      public String processExecuteBeforeSql(ETLContext etlContext, String sql, DataCenter toDc, Datastore ds, RowInfo rowInfo)
      处理执行前的SQL
      参数:
      etlContext - ETLContext
      sql - String
      toDc - DataCenter
      ds - Datastore
      rowInfo - RowInfo
      返回:
      String

    • processCheckExistSql

      public void processCheckExistSql(ETLContext etlContext, SqlBuilder sb, Datastore ds, RowInfo rowInfo)

    • reSortLine

      public void reSortLine()
      线条重排序，将主键列排在最后

    • getId

      public String getId()

    • setId

      public void setId(String id)

    • getEtlData

      public ETLData getEtlData()

    • setEtlData

      public void setEtlData(ETLData etlData)

    • isStartNode

      public boolean isStartNode()

    • setStartNode

      public void setStartNode(boolean isStartNode)

    • getDbId

      public String getDbId()

    • getTableName

      public String getTableName()

    • isSqlNode

      public boolean isSqlNode()

    • getPkCol

      public String getPkCol()

    • isPkCol

      public boolean isPkCol(String col)

    • getPkDataType

      public String getPkDataType()

    • getEveryRows

      public int getEveryRows()

    • getMaxSyncRows

      public int getMaxSyncRows()

    • isErrorContinue

      public boolean isErrorContinue()

    • getJavaAttr

      public JavaAttr getJavaAttr()

    • isHasRepeatCondition

      public boolean isHasRepeatCondition()

    • isPageColValid

      public boolean isPageColValid()

    • getPageCol

      public String getPageCol()

    • getPageDataType

      public String getPageDataType()

    • getPageColValue

      public Object getPageColValue()