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

类 ETLColumnObj

java.lang.Object

com.sh.wf.etl.base.ETLColumnObj

public class ETLColumnObj
extends Object

Description:

Title:首亨软件 - 聚天平台

从以下版本开始:

2018年11月7日

字段概要

字段

修饰符和类型	字段	说明
ETLBase	base
String	tableCol

构造器概要

构造器

构造器	说明
ETLColumnObj()

方法概要

修饰符和类型	方法	说明
boolean	isCondition()
boolean	isFixValue()
boolean	isValid()	当前是否有效
void	parser(ETLBase base, org.jdom2.Element nodeEl)
void	processCheckExistSql(ETLContext etlContext, SqlBuilder sb, Datastore ds, RowInfo rowInfo)	查询语句条件
String	processExecuteBeforeSql(ETLContext etlContext, String sql, DataCenter toDc, Datastore ds, RowInfo rowInfo)	处理执行前的SQL
void	processExecuteBeforeSqlReset(ETLContext etlContext)
void	processFixColumnObj(ETLContext etlContext, StringBuilder toInsertColSql, StringBuilder toInsertValueSql, StringBuilder toUpdateSql, StringBuilder toUpdateWhereSql, DataCenter toDc)	设置目标表固定列

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

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

字段详细资料

base

public ETLBase base

tableCol

public String tableCol

构造器详细资料

ETLColumnObj

public ETLColumnObj()

方法详细资料

parser

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

isValid

public boolean isValid()

当前是否有效

返回:

boolean

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)

查询语句条件

参数:

etlContext - ETLContext

sb - SqlBuilder

ds - Datastore

rowInfo - RowInfo

isFixValue

public boolean isFixValue()

isCondition

public boolean isCondition()