com.sh.wf.etl.compontent

类 ETLBase

java.lang.Object

com.sh.wf.etl.compontent.ETLBase

直接已知子类:

ETLSource

public abstract class ETLBase
extends java.lang.Object

Description:

Title:首亨软件 - TSS/CRM等

从以下版本开始:

2017年7月18日

版本:

3.0

作者:

江兴春

构造器概要

构造器

构造器和说明
ETLBase()

方法概要

限定符和类型	方法和说明
void	addToLine(ETLBase base, ArrowLine line)
void	commonParser(org.jdom.Element nodeEl)
ETLColumnObj	getColumnObj(java.lang.String tableCol)
java.lang.String	getDbId()
ETLData	getEtlData()
int	getEveryRows()
java.lang.String	getId()
JavaAttr	getJavaAttr()
int	getMaxSyncRows()
java.lang.String	getPageCol()
java.lang.Object	getPageColValue()
java.lang.String	getPageDataType()
java.lang.String	getPkCol()
java.lang.String	getPkDataType()
java.lang.String	getTableName()
boolean	isErrorContinue()
boolean	isHasRepeatCondition()
boolean	isPageColValid()
boolean	isPkCol(java.lang.String col)
boolean	isSqlNode()
boolean	isStartNode()
abstract void	parser(org.jdom.Element nodeEl)
void	processCheckExistSql(ETLContext etlContext, SqlBuilder sb, Datastore ds, RowInfo rowInfo)
java.lang.String	processExecuteBeforeSql(ETLContext etlContext, java.lang.String sql, DataCenter toDc, Datastore ds, RowInfo rowInfo) 处理执行前的SQL
void	processExecuteBeforeSqlReset(ETLContext etlContext)
void	processFixColumnObj(ETLContext etlContext, java.lang.StringBuilder toInsertColSql, java.lang.StringBuilder toInsertValueSql, java.lang.StringBuilder toUpdateSql, java.lang.StringBuilder toUpdateWhereSql, DataCenter toDc) 设置固定列
void	reSortLine() 线条重排序，将主键列排在最后
abstract void	run(ETLContext etlContext)
void	setEtlData(ETLData etlData)
void	setId(java.lang.String id)
void	setStartNode(boolean isStartNode)

从类继承的方法 java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

ETLBase

public ETLBase()

方法详细资料

parser

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

commonParser

public void commonParser(org.jdom.Element nodeEl)

run

public abstract void run(ETLContext etlContext)

addToLine

public void addToLine(ETLBase base,
                      ArrowLine line)

getColumnObj

public ETLColumnObj getColumnObj(java.lang.String tableCol)

processFixColumnObj

public void processFixColumnObj(ETLContext etlContext,
                                java.lang.StringBuilder toInsertColSql,
                                java.lang.StringBuilder toInsertValueSql,
                                java.lang.StringBuilder toUpdateSql,
                                java.lang.StringBuilder toUpdateWhereSql,
                                DataCenter toDc)

设置固定列

参数:

etlContext - ETLContext

toInsertColSql - StringBuilder

toInsertValueSql - StringBuilder

toUpdateSql - StringBuilder

toUpdateWhereSql - StringBuilder

toDc - DataCenter

processExecuteBeforeSqlReset

public void processExecuteBeforeSqlReset(ETLContext etlContext)

processExecuteBeforeSql

public java.lang.String processExecuteBeforeSql(ETLContext etlContext,
                                                java.lang.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 java.lang.String getId()

setId

public void setId(java.lang.String id)

getEtlData

public ETLData getEtlData()

setEtlData

public void setEtlData(ETLData etlData)

isStartNode

public boolean isStartNode()

setStartNode

public void setStartNode(boolean isStartNode)

getDbId

public java.lang.String getDbId()

getTableName

public java.lang.String getTableName()

isSqlNode

public boolean isSqlNode()

getPkCol

public java.lang.String getPkCol()

isPkCol

public boolean isPkCol(java.lang.String col)

getPkDataType

public java.lang.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 java.lang.String getPageCol()

getPageDataType

public java.lang.String getPageDataType()

getPageColValue

public java.lang.Object getPageColValue()