com.sh.wf.etl.base

类 ETLColumnObj

java.lang.Object

com.sh.wf.etl.base.ETLColumnObj

public class ETLColumnObj
extends java.lang.Object

Description:

Title:首亨软件 - 聚天平台

从以下版本开始:

2018年11月7日

版本:

3.0

作者:

江兴春

字段概要

字段

限定符和类型	字段和说明
ETLBase	base
java.lang.String	tableCol

构造器概要

构造器

构造器和说明
ETLColumnObj()

方法概要

限定符和类型	方法和说明
boolean	isCondition()
boolean	isFixValue()
boolean	isValid() 当前是否有效
void	parser(ETLBase base, 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) 设置目标表固定列

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

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

字段详细资料

base

public ETLBase base

tableCol

public java.lang.String tableCol

构造器详细资料

ETLColumnObj

public ETLColumnObj()

方法详细资料

parser

public void parser(ETLBase base,
                   org.jdom.Element nodeEl)

isValid

public boolean isValid()

当前是否有效

返回:

boolean

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)

查询语句条件

参数:

etlContext - ETLContext

sb - SqlBuilder

ds - Datastore

rowInfo - RowInfo

isFixValue

public boolean isFixValue()

isCondition

public boolean isCondition()