怎么通过kettle 删除mysql数据

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了怎么通过kettle 删除mysql数据相关的知识,希望对你有一定的参考价值。

参考技术A 一、准备工作
源数据库ORACLE 目标数据库MongoDB,在源数据库添加删除、更新触发器
二、操作步骤
添加表输入组件,连接ORACLE触发器记录表
添加JAVA代码组件,进行步骤跳转,根据输入的数据判断是删除或者更新,如果是删除,则跳转至MongoDB Delete步骤中,如果是更新的话,跳转至字段选择步骤中。JAVA代码中的详细信息如下:
import java.util.List;

import org.pentaho.di.core.exception.KettleException;
import org.pentaho.di.core.row.RowDataUtil;
import org.pentaho.di.core.row.RowMeta;
import org.pentaho.di.core.row.RowMetaInterface;
import org.pentaho.di.core.row.ValueMeta;
import org.pentaho.di.trans.Trans;
import org.pentaho.di.trans.TransMeta;

private Object[] previousRow;//上一行
private RowSet t1 = null;//业务表步骤
private RowSet t2 = null;//删除步骤

public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException

Object[] r = getRow(); //获取输入行

if ( first )
if ( getInputRowMeta() == null )
setOutputDone();//设置输出完成
return false;
本回答被提问者采纳

以上是关于怎么通过kettle 删除mysql数据的主要内容,如果未能解决你的问题,请参考以下文章

使用kettle向mysql插入数据~ 每秒10条...应该是mysql的问题。怎么能提高效率么~

kettle从文本文件输入时怎么拆分字段

kettle执行sql脚本删除数据

kettle之行转列,删除多余连接符

kettle能同步二进制数据吗

mysql怎么自动删除超过3天的数据