如何基于Pentaho从数据库表生成符合REST Client要求的动态JSON

嘿，作为Pentaho初学者，别担心，这个需求其实很容易实现，跟着下面的步骤一步步来就行：

首先打开Pentaho Data Integration（也就是我们常说的Spoon），新建一个转换（Transformation）：

• 添加一个「表输入（Table Input）」组件，配置好你的数据库连接（如果还没建连接，直接在组件里新建就行）。
• 编写SQL查询，把数据库表的列映射成目标JSON需要的键名。比如你的表列名是first_name、last_name这类，就用类似下面的查询：

  SELECT 
      first_name AS firstName,
      last_name AS lastName,
      DATE_FORMAT(birth_date, '%Y-%m-%d') AS birthDate, -- 转成目标要求的日期格式
      email,
      phone_number AS number,
      phone_type AS phoneType
  FROM your_table_name;
  

  注意：如果是其他数据库，日期转换函数要对应调整，比如PostgreSQL用TO_CHAR(birth_date, 'YYYY-MM-DD')。

因为目标JSON里有嵌套的phones数组，我们需要把相同用户的多条电话记录组合成数组，这里推荐用**Nested Output (JSON)**组件，专门处理嵌套结构：

• 添加「Nested Output (JSON)」组件，连接到「表输入」的输出。
• 配置组件：
  1. 先设置主实体（Parent Entity）：添加firstName、lastName、birthDate、email这几个字段，对应表输入里的同名字段。
  2. 点击「添加子实体（Add Child Entity）」，命名为phones，然后设置关联主实体的字段（选firstName、lastName这些能唯一标识用户的字段就行）。
  3. 在子实体里添加number和phoneType两个字段，对应表输入里的字段。
• 这样组件会自动把同一个用户的所有电话记录打包成phones数组，完美匹配目标格式。

如果想先验证JSON格式对不对，可以加一个「文本文件输出（Text File Output）」组件，把生成的JSON输出到本地文件，打开检查是否符合要求。

现在我们要把生成的JSON发送给目标接口：

• 如果是在转换里直接调用，可以添加「REST Client」组件，连接到「Nested Output (JSON)」的输出。
• 配置REST Client：
  • 请求方法选POST（因为是提交数据）。
  • 填入目标REST接口的URL。
  • 在「请求体（Request Body）」里，选择「发送字符串（Send string）」，然后引用生成的JSON内容（如果是用变量传递，可以先加「设置变量（Set Variable）」组件把JSON存到变量，这里直接用组件输出的字符串就行）。
  • 一定要在「请求头（Request Headers）」里添加Content-Type: application/json，不然服务器可能识别不了JSON格式。

• 如果你的数据库里每个用户只有一条电话记录，phones数组也会正常生成（就是只有一个元素的数组），不用额外处理。
• 测试的时候可以先关掉REST Client，用文本输出验证JSON格式，没问题再连接口，避免无效请求。

内容的提问来源于stack exchange，提问作者Himanshi