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);