public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException
{
// First, get a row from the default input hop
//
Object[] r = getRow();
String databasesXML =
"<?xml version=\"1.0\" encoding=\"UTF-8\"?>" +
"<connection>" +
"<name>kettle</name>" +
"<server>127.0.0.1</server>" +
"<type>Oracle</type>" +
"<access>Native</access>" +
"<database>orcl</database>" +
"<port>1521</port>" +
"<username>kscenter20151207</username>" +
"<password>kscenter</password>" +
"</connection>";
org.pentaho.di.core.database.DatabaseMeta dbmeta = new org.pentaho.di.core.database.DatabaseMeta(databasesXML);;
if(dbmeta!=null)
{
org.pentaho.di.core.database.Database db=new org.pentaho.di.core.database.Database(dbmeta);
try
{
db.connect();
String tablename = getVariable("TABLENAME");
logBasic("开始创建表:" + tablename);
if(tablename!=null && tablename.trim().length()>0)
{
org.pentaho.di.core.row.RowMetaInterface outputRowMeta = getInputRowMeta().clone();
logBasic("row:"+outputRowMeta);
String sql = db.getDDL(tablename, data.inputRowMeta);//${TABLENAME}
//String sql = db.getDDL(tablename, outputRowMeta);//${TABLENAME}
db.execStatement(sql.replace(";", ""));
logBasic(sql);
}
}
catch(Exception e)
{
logError("创建表出现异常",e);
}finally{
db.disconnect();
}
}
return false;
}
相关推荐
kettle数据迁移示例。从mysql数据库表迁移到oracle数据库表。
学习记录
Kettle实现多张表数据的定时删除全量抽取,删除旧shuju
该实例主要完成sqlserver数据库表信息到Oracle数据库表的一次数据迁移,用kettle工具(简称水壶)编写好转换文件后保存,最后执行转化,即可完成数据库表的数据迁移。运行该实例你需下载kettle工具,并对实例中的...
XXXKETTLE全量多表数据同步 1 一. 建立资料库 3 1.1 添加资源库 3 二. 前期准备工作 7 2.1 异结构数据传输 7 2.2 数据校验 9 三. 建立转换 10 3.1 创建‘转换’(GET—ORACLE-TABLES) 10 3.1.1 创建数据源 10 3.1.2...
kettle数据迁移工具的文档使用,针对kettle7的使用介绍,包括配置转换与作业等
kettle 设置流程完成数据迁移,该实例用mysql数据库为例
kettle写的循环分页迁移数据的例子,迁移了36w数据,速度飞快,平均cpu使用只有19%。数据库表是运营商号段数据,网上有,比较大就不放上来了。
使用Kettle实现多数据表全量数据抽取,前提是两边表结构一模一样,维护的话请注意月度里面的readMe.md文件
kettle工具,ETL
使用Kettle创建Job流程,完成对整套数据库的迁移操作
kettle数据迁移操作文档
通过kettle循环抽取整库数据至CSV文件,可根据该程序修改抽取至数据至数据库等。
ETL工具,kettle资料库表结构word文档,详细介绍了kettle40多张表结构
kettle是一个优秀的ETL,它的数据库结构是什么样的呢?本文档以Oracle数据库连接为例,讲解每一个表的各个列名的含义,帮助你缕清kettle的架构模式,方便你的二次开发和自主研发ETL。
该方案是将Oracle数据库迁移到MySQL数据库中,也支持Oracle、MySQL等多种数据库的相互迁移
kettle数据清洗抽取,全量对比记录,包含列转行,增加序列,字段拆分,对比记录
kettle实现多表级联,输出一个目标表
使用kettle同步数据库表。网上找教程找了一天。终于弄好了。将两个数据库连接改成你自己的。sql也要改,然后把后面步骤的字段重新获取一下。然后就可以同步数据了。数据来源表增删改都可以同步。参考一下吧
kettle资源库的表说明。