Kettle练习：文本文件数据入库

Kettle练习：文本文件数据入库

1. 数据准备

1.1 建表

CREATE TABLE ACC_REPAYSCHEDULE
(
  contractno      VARCHAR(30),
  duebillno       VARCHAR(30) NOT NULL,
  currentno       VARCHAR(30) NOT NULL,
  STATUS          VARCHAR(2),
  maturedate      DATE,
  currentsum      DECIMAL(16,2),
  currentinterest DECIMAL(16,2),
  paysum          DECIMAL(16,2),
  payinterest     DECIMAL(16,2),
  closedate       DATE,
  currency        VARCHAR(2)
)

1.2 建文本文档

JY01011604280016|JY010116042800160019|1|1|2017-04-27|1000000.00|121666.66|1000000.00|121666.66|          |01 |
JY01011604280022|JY010116042800220025|1|1|2017-04-27|1000000.00|121666.66|1000000.00|121666.66|          |01 |
WT01011607040001|WT010116070400010002|1|1|2016-08-04|12000.00|51.67|12000.00|51.67|          |01 |
JY01011602020103|JY010116020201030004|2|2|2016-06-20|0.00|28933.33|0.00|28933.33|          |01 |
JY01011602020103|JY010116020201030004|3|1|2016-08-01|2000000.00|19600.00|2000000.00|19600.00|          |01 |
LD01011607160101|LD010116071601010002|1|1|2016-08-23|16.67|0.94|16.67|0.94|          |01 |
LD01011607160104|LD010116071601040004|1|1|2016-08-23|83.33|4.71|83.33|4.71|          |01 |
JY02011607310101|JY020116073101010002|1|1|2016-08-01|233980.65|2391.67|233980.65|2391.67|          |01 |
JY02011607310001|JY020116073100010002|1|1|2016-08-01|166830.63|3000.00|166830.63|3000.00|          |01 |
LD01011607160101|LD010116071601010002|1|1|2016-08-23|16.67|0.94|16.67|0.94|          |01 |
LD01011607160104|LD010116071601040004|1|1|2016-08-23|83.33|4.71|83.33|4.71|          |01 |
LD01011607160101|LD010116071601010002|1|1|2016-08-23|16.67|0.94|16.67|0.94|          |01 |
LD01011607160104|LD010116071601040004|1|1|2016-08-23|83.33|4.71|83.33|4.71|          |01 |
JY01011604280016|JY010116042800160019|1|1|2017-04-27|1000000.00|121666.66|1000000.00|121666.66|          |01 |
JY01011604280022|JY010116042800220025|1|1|2017-04-27|1000000.00|121666.66|1000000.00|121666.66|          |01 |
WT01011607040001|WT010116070400010002|1|1|2016-08-04|12000.00|51.67|12000.00|51.67|          |01 |
JY01011602020103|JY010116020201030004|2|2|2016-06-20|0.00|28933.33|0.00|28933.33|          |01 |
JY01011602020103|JY010116020201030004|3|1|2016-08-01|2000000.00|19600.00|2000000.00|19600.00|          |01 |
JY01011604280016|JY010116042800160019|1|1|2017-04-27|1000000.00|121666.66|1000000.00|121666.66|          |01 |
JY01011604280022|JY010116042800220025|1|1|2017-04-27|1000000.00|121666.66|1000000.00|121666.66|          |01 |
WT01011607040001|WT010116070400010002|1|1|2016-08-04|12000.00|51.67|12000.00|51.67|          |01 |
JY01011602020103|JY010116020201030004|2|2|2016-06-20|0.00|28933.33|0.00|28933.33|          |01 |
JY01011602020103|JY010116020201030004|3|1|2016-08-01|2000000.00|19600.00|2000000.00|19600.00|          |01 |

2. 文本文件输入

核心对象-> 输入->文本文件输入

2.1 找到需要输入的文本文件，进行增加

2.2 字段

需要和数据库一致，否则不能进行插入

3. 表输出

核心对象 -> 输出 -> 表输出

并且需要和文本文件进行连接

3.1 基本选项

找到需要进行导入的那张表，数据库连接为自己在新建转换任务时连接的数据库

3.2 数据库字段

如果文本文件输入和表输出连接正确，可以通过输入字段映射快速获取数据库字段

4. 运行和结果

4.1 运行

通过三角按钮进行运行操作，如果下面是两个绿色的图标，证明之前的操作无误

4.2 结果

可以发现数据库成功导入数据