SPL 实践:解析并过滤来自 RESTful 的多层 JSON

## 实践背景
通过 RESTful 交换数据很方便,但接收数据后如何继续计算会有点麻烦。SPL 提供了 HTTP 接口,可以直接读取 RESTful 的数据后进行计算。
如下例,电商业务中订单数据的访问被封装成 REST 接口供其他业务访问。
访问地址:
http://111.198.29.168:8503/getOrdershttp://111.198.29.168:8503/getOrders/bDate/eDate
其中:bDate 与 eDate 为路径参数,直接在 URL 中拼接即可,参数代表查询的起始和结束日期。
接口返回的 JSON 格式数据如下:

[
  {
    "order_id": "AMZ123001",
    "order_date": "2023-11-11 18:00:17",
    "order_status": "processing",
    "user_info": {
      "user_id": "USR001",
      "username": "john_doe",
      "email": "john_doe@example.com",
      "country": "USA",
      "city": "New York"
    },
    "payment_info": {
      "payment_method": "credit_card",
      "total_amount": 0
    },
    "order_details": [
      {
        "product_id": "PD001",
        "product_name": "Smartphone",
        "price": 599.99,
        "quantity": 1
      },
      {
        "product_id": "PD002",
        "product_name": "Laptop",
        "price": 1299.99,
        "quantity": 1
      }
    ]
  },

…
]

现在分析 2023 年的订单,从所有未取消的订单中找出本年购买金额最多的前 5 名客户,以便为其发放礼品奖励。

实践过程

编辑脚本

打开 SPL IDE 编写脚本:


A

1

=httpfile("http://111.198.29.168:8503/login4get?nameOrEmail=tom&userPassword="+md5("mypass")+"rememberLogin=true“:"UTF-8" ).read()

2

=A1.property("Set-Cookie")

3

=httpfile("http://111.198.29.168:8503/getOrders"+"/"+bDate+"/"+eDate:"UTF-8";"Cookie":A2).read()

4

=json(A3)

5

=A4.select(order_status!="canceled")

6

=A5.groups(user_info.user_id;sum(order_details.price*order_details.quantity):amt)

7

=A6.top(-5;amt)

8

return json(A7)

A1-A2:RESTful 访问鉴权
A3:访问数据接口,根据起止日期获取本年订单数据,其中 bDate、eDate 为脚本参数

A4:结构化 JSON 串,转换为多层序表

User_info 的下一层:

A5:过滤数据,返回所有未取消订单
A6:按照用户分组汇总订单金额。这里通过 user_info.user_id 的方式访问多层序表中各个层次的数据(有了多层序表就能天然适应 JSON 的多层结构)

A7:获得金额最大的前 5 名用户(包括用户名和金额)

A8:结果以 JSON 格式返回

Java 调用

参考 Java 如何调用 SPL 脚本 ,将 esproc-bin-xxxx.jar 和 icu4j-60.3.jar,以及配置文件 raqsoftConfig.xml 引入到项目后,通过 JDBC 调用 SPL 脚本或执行 SPL 语句。

像调用存储过程一样执行 SPL 脚本文件:

Class.forName("com.esproc.jdbc.InternalDriver");
Connection conn= DriverManager.getConnection("jdbc:esproc:local://");
PreparedStatement st = conn.prepareCall("call restJsonParse (?,?)");
st.setObject(1, "2023-01-01");
st.setObject(2, "2023-12-31");
st.execute();
ResultSet rs = st.getResultSet();

或者直接执行 SPL 语句,将 IDE 中的脚本选中并复制粘贴到 Java 字符串中,就可以得到这样的串:

String spl = "==httpfile(\"http://111.198.29.168:8503/login4get?nameOrEmail=tom&userPassword=\"+md5(\"mypass\")+\"rememberLogin=true“:\"UTF-8\" ).read()\n" +
        "=A1.property(\"Set-Cookie\")\n" +
        "=httpfile(\"http://111.198.29.168:8503/getOrders\"+\"/\"+bDate+\"/\"+eDate:\"UTF-8\";\"Cookie\":A2).read() \n" +
        "=json(A3)\n" +
        "=A4.select(order_status!=\"canceled\")\n" +
        "=A5.groups(user_info.user_id;sum(order_details.price*order_details.quantity):amt)\n" +
        "=A6.top(-5;amt)\n" +
        "return json(A7)";

需要注意的是,脚本串要以双等(==)号开头。

下面执行脚本:

Class.forName("com.esproc.jdbc.InternalDriver");
Connection conn= DriverManager.getConnection("jdbc:esproc:local://");
Statement st = conn.createStatement();
ResultSet rs = st.executeQuery(spl);

输出结果集得到如下 JSON 串:

[{"user_id":"USR001","amt":2399.96},{"user_id":"USR008","amt":1079.8799999999999},{"user_id":"USR005","amt":999.96},{"user_id":"USR010","amt":879.92},{"user_id":"USR007","amt":799.96}]

这样就完成了 RESTful 解析和计算,计算结果可以直接返回或传递给其他程序继续使用。

附件:
orders.json
restJsonParse.splx
RestfulJsonParse.java

以下是广告时间

对润乾产品感兴趣的小伙伴,一定要知道软件还能这样卖哟性价比还不过瘾? 欢迎加入好多乾计划。
这里可以低价购买软件产品,让已经亲民的价格更加便宜!
这里可以销售产品获取佣金,赚满钱包成为土豪不再是梦!
这里还可以推荐分享抢红包,每次都是好几块钱的巨款哟!
来吧,现在就加入,拿起手机扫码,开始乾包之旅



嗯,还不太了解好多乾?
猛戳这里
玩转好多乾