kettle7.0数据库迁移(MySQL迁移到Postgresql，迁移过程中自动创建表结构)

亦凉 2022-01-27 00:57 644阅读 0赞

转自： [https://www.cnblogs.com/ysit/p/10590573.html][https_www.cnblogs.com_ysit_p_10590573.html]

[https://www.cnblogs.com/ysit/p/10590573.html][https_www.cnblogs.com_ysit_p_10590573.html]

# [kettle7.0数据库迁移(MySQL迁移到Postgresql，迁移过程中自动创建表结构)][https_www.cnblogs.com_ysit_p_10590573.html] #

### 一、说明 ###

*  > 最近做的系统中需要把各种数据库迁移到Postgresql数据库上，使用kettle来进行数据库迁移。
 *  > 安装完kettle软件，需要将需要的数据库驱动放入在安装包的lib包下。
 *  > 整套流程分为：2个job，4个trans。

### 二、所需软件 ###

*  kettle7.0
 *  JDK1.8
 *  mysql-connector-java-5.1.43

### 三、具体实现 ###

3.1 数据库迁移-主任务

![1232644-20190324220432791-871409937.png][]

3.2 获取变量-数据同步

![1232644-20190324220445845-1751607483.png][]

### 3.3 获取全量表名 ###

![1232644-20190324220459652-344875538.png][]

3.3.1 获取表名

![1232644-20190324220513987-1394434639.png][]

3.3.2 字段选择

![1232644-20190324220527953-975622461.png][]

3.3.3 复制记录到结果

![1232644-20190324220542844-2141754902.png][]

### 3.4 获取变量 ###

![1232644-20190324220622232-496406449.png][]

3.4.1 从结果获取记录

![1232644-20190324220639618-781739450.png][]

3.4.2 设置变量

![1232644-20190324220654660-1008852101.png][]

### 3.5 新建数据库表结构 ###

![1232644-20190324220713099-1629972750.png][]

3.5.1 获取表名

![1232644-20190324220726308-1273268825.png][]

3.5.2 新建数据库表结构

![1232644-20190324220736599-54856555.png][]

*  > 根据不同的数据库设置建表语句

public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException{
    // First, get a row from the default input hop
    Object[] r = getRow();
    
    //本地连接
    
    org.pentaho.di.core.database.DatabaseMeta dbmeta = getTransMeta().findDatabase("kettle_postgres");
    
    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)
            {
                String sql = db.getDDLCreationTable(tablename, data.inputRowMeta);//${TABLENAME}
                
                sql = sql.replace("TABLE", "TABLE public.");
    
                db.execStatement(sql.replace(";", ""));
    
                logBasic(sql);
            }
        }
        catch(Exception e)
        {
            logError("创建表出现异常",e);
    
        }finally{
            db.disconnect();
        }
    }
    return false;
    }

### 3.6 数据抽取 ###

![1232644-20190324220755618-2059077782.png][]

3.6.1 新建数据库表结构

![1232644-20190324220819149-1569110285.png][]

3.6.2 新建数据库表结构

![1232644-20190324220829128-2045997991.png][]

### 四、迁移成功 ###

![1232644-20190324220847078-2040038672.png][]

[https_www.cnblogs.com_ysit_p_10590573.html]: https://www.cnblogs.com/ysit/p/10590573.html
[1232644-20190324220432791-871409937.png]: /images/20220127/aa0528f2adbb4617be08b39e46cb088b.png
[1232644-20190324220445845-1751607483.png]: /images/20220127/179f963885e04e0693846c62bb7b879c.png
[1232644-20190324220459652-344875538.png]: /images/20220127/8040104bee1e44749ec17e7d95807ed6.png
[1232644-20190324220513987-1394434639.png]: /images/20220127/b33b73f99e7c43d09f519ad828b54bcf.png
[1232644-20190324220527953-975622461.png]: /images/20220127/c301d8c117114582b787163132d3e9c8.png
[1232644-20190324220542844-2141754902.png]: /images/20220127/7248b910897a4638a7a80e0247eecf17.png
[1232644-20190324220622232-496406449.png]: /images/20220127/3c08f0b608bb46bc9805f64d640bc19c.png
[1232644-20190324220639618-781739450.png]: /images/20220127/648f1926b84c47499a3911bee99221c3.png
[1232644-20190324220654660-1008852101.png]: /images/20220127/45431caecfe64ae78174165034caa767.png
[1232644-20190324220713099-1629972750.png]: /images/20220127/7b3f6b04e300455ab9d275c1cee90b82.png
[1232644-20190324220726308-1273268825.png]: /images/20220127/a144d7a14c5842f7a80b7f63b8c1350b.png
[1232644-20190324220736599-54856555.png]: /images/20220127/43c247157cc245cc9be00c4fed113491.png
[1232644-20190324220755618-2059077782.png]: /images/20220127/3625ae7a33b043419271d85bff6f0518.png
[1232644-20190324220819149-1569110285.png]: /images/20220127/4d74776d61374c5fb33cafa69379bb86.png
[1232644-20190324220829128-2045997991.png]: /images/20220127/179b1e1951ff4a8e823d3433c67c4fa7.png
[1232644-20190324220847078-2040038672.png]: /images/20220127/2b9c082937534001af2798930f197aa8.png