java调用kettle api 操作日志写入到数据库表
来源：互联网
CREATE TABLE `t_lzfx_data_log` (
`ID` bigint(20) NOT NULL AUTO_INCREMENT,
`ID_BATCH` int(11) DEFAULT '0',
`CHANNEL_ID` varchar(255) DEFAULT NULL,
`TRANSNAME` varchar(255) DEFAULT NULL,
`STEPNAME` varchar(200) DEFAULT NULL,
`STEP_COPY` int(11) DEFAULT NULL,
`LINES_READ` int(11) DEFAULT NULL,
`LINES_WRITTEN` int(11) DEFAULT NULL,
`LINES_UPDATED` int(11) DEFAULT NULL,
`LINES_INPUT` int(11) DEFAULT NULL,
`LINES_OUTPUT` int(11) DEFAULT NULL,
`LINES_REJECTED` int(11) DEFAULT NULL,
`ERRORS` int(11) DEFAULT NULL,
`LOG_FIELD` blob,
`LOG_DATE` datetime DEFAULT NULL,
PRIMARY KEY (`ID`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
VariableSpace space = new Variables();
//将step日志数据库配置名加入到变量集中
space.setVariable("kettle_log","bjdt");
space.initializeVariablesFrom(null);
StepLogTable stepLogTable = StepLogTable.getDefault(space,transMeta);
//StepLogTable使用的数据库连接名（上面配置的变量名）。
stepLogTable.setConnectionName("bjdt");
//设置Step日志的表名
stepLogTable.setTableName(kettle_log);
//设置TransMeta的StepLogTable
transMeta.setStepLogTable(stepLogTable);
CREATE TABLE `t_lzfx_data_log` (
`ID` bigint(20) N
