com.sh.wf.etl.log

类 ETLRunLog

java.lang.Object

com.sh.wf.etl.log.ETLRunLog

所有已实现的接口:

DBQueue

public class ETLRunLog
extends java.lang.Object
implements DBQueue

Description: ETL执行记录的日志

Title:首亨软件 - TSS/CRM等

从以下版本开始:

2017-07-31

版本:

3.0

作者:

江兴春

构造器概要

构造器

构造器和说明
ETLRunLog()

方法概要

限定符和类型	方法和说明
void	execute(DataCenter dc) 执行当前需要处理的队列里的操作
boolean	getWaitTimeout() 该队列等待执行超时设置，当返回true时表示进入执行时间
static void	putQueue(ETLContext etlContext, java.lang.Exception _ex)
static void	putQueue(ETLContext etlContext, java.lang.String log) 添加到队列
static void	putQueue(ETLContext etlContext, java.lang.String sql, Datastore ds)
static void	putQueue(ETLContext etlContext, java.lang.String sql, java.lang.String[] updateMsg)
static void	putQueue(ETLContext etlContext, java.lang.String sql, java.lang.String[] colsType, java.lang.Object[] obj)
static void	putQueue(ETLContext etlContext, java.lang.String sql, java.lang.String[] colsType, java.lang.Object[] obj, Datastore ds)
static void	putQueue(ETLContext etlContext, java.lang.String sql, java.lang.String[] colsType, java.lang.Object[] obj, java.lang.String[] updateMsg)
boolean	start() 启动队列，只会执行一次

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

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

构造器详细资料

ETLRunLog

public ETLRunLog()

方法详细资料

putQueue

public static void putQueue(ETLContext etlContext,
                            java.lang.String log)

添加到队列

参数:

etlContext - ETLContext

log - 日志信息

putQueue

public static void putQueue(ETLContext etlContext,
                            java.lang.String sql,
                            java.lang.String[] colsType,
                            java.lang.Object[] obj)

putQueue

public static void putQueue(ETLContext etlContext,
                            java.lang.String sql,
                            Datastore ds)

putQueue

public static void putQueue(ETLContext etlContext,
                            java.lang.String sql,
                            java.lang.String[] colsType,
                            java.lang.Object[] obj,
                            Datastore ds)

putQueue

public static void putQueue(ETLContext etlContext,
                            java.lang.String sql,
                            java.lang.String[] updateMsg)

putQueue

public static void putQueue(ETLContext etlContext,
                            java.lang.String sql,
                            java.lang.String[] colsType,
                            java.lang.Object[] obj,
                            java.lang.String[] updateMsg)

putQueue

public static void putQueue(ETLContext etlContext,
                            java.lang.Exception _ex)

start

public boolean start()

从接口复制的说明: DBQueue

启动队列，只会执行一次

指定者:

start 在接口中 DBQueue

返回:

boolean

getWaitTimeout

public boolean getWaitTimeout()

从接口复制的说明: DBQueue

该队列等待执行超时设置，当返回true时表示进入执行时间

指定者:

getWaitTimeout 在接口中 DBQueue

返回:

boolean

execute

public void execute(DataCenter dc)

从接口复制的说明: DBQueue

执行当前需要处理的队列里的操作

指定者:

execute 在接口中 DBQueue

参数:

dc - DataCenter