17370845950

使用 Josson 库更新 JSON 数组中具有相同键的 JSON 对象

本文将介绍如何使用 Josson 库,通过两个不同的 JSON 数组中相同的键,来更新 JSON 数组中的 JSON 对象。通过 Josson 的数据集连接操作,可以高效地实现数据的合并和更新,避免了复杂的嵌套循环和条件判断,从而简化了代码并提高了可读性。

Josson 库简介

Josson 是一个强大的 JSON 处理库,它提供了一系列便捷的方法来查询、转换和操作 JSON 数据。其中,数据集连接操作是 Josson 的一个重要特性,它允许用户基于指定的键,将多个 JSON 数组连接起来,从而实现数据的合并和更新。

示例代码

以下代码演示了如何使用 Josson 库来更新 JSON 数组中具有相同键的 JSON 对象:

import com.fasterxml.jackson.databind.JsonNode;
import net.octomix.josson.Josson;
import net.octomix.josson.JossonException;
import net.octomix.josson.Jossons;

public class JsonUpdateExample {

    public static void main(String[] args) {
        try {
            Jossons jossons = new Jossons();

            // Deserialization
            jossons.putDataset("http",
                    Josson.fromJsonString("[{\"userid\":\"CNRM04\",\"groupname\":\"Rohit\",\n" +
                            "\"segment\":\"CosPROFIN\",\"accountcode\":\"OWN\",\"symbol\":\"NIFTY\",\"exchange\":\"NSEFO\",\n" +
                            "\"expirydate\":\"03NOV2025\",\"scripcode\":\"38021\",\"securitytype\":\"OPT\",\n" +
                            "\"strikeprice\":17700,\"opttype\":\"PE\",\"bfqty\":-1500,\"bfrate\":122.35,\n" +
                            "\"bfamt\":18352.5,\"buyqty\":0,\"sellqty\":0,\"netqty\":0,\"cfqty\":-150,\n" +
                            "\"cfamt\":18352.5,\"ltp\":0,\"grossmtm\":0,\"brokerageamt\":0,\"netmtm\":0,\n" +
                            "\"currency\":\"INR\",\"usdrate\":1,\"clientsharing\":0,\"broksharing\":0,\n" +
                            "\"comsharing\":100,\"multiplier\":1},{\"userid\":\"CNRM04\",\"groupname\":\"Rohit\",\n" +
                            "\"segment\":\"CosPROFIN\",\"accountcode\":\"OWN\",\"symbol\":\"NIFTY\",\n" +
                            "\"exchange\":\"NSEFO\",\"expirydate\":\"03NOV2025\",\"scripcode\":\"38026\",\n" +
                            "\"securitytype\":\"OPT\",\"strikeprice\":17800,\"opttype\":\"PE\",\"bfqty\":0,\n" +
                            "\"bfrate\":0,\"bfamt\":0,\"buyqty\":10800,\"sellqty\":15000,\"netqty\":-4200,\n" +
                            "\"cfqty\":-4200,\"cfamt\":590729.9999999998,\"ltp\":0,\"grossmtm\":0,\n" +
                            "\"brokerageamt\":3400.2888479999992,\"netmtm\":0,\"currency\":\"INR\",\n" +
                            "\"usdrate\":1,\"clientsharing\":0,\"broksharing\":0,\"comsharing\":100,\n" +
                            "\"multiplier\":11},{\"userid\":\"CNC01\",\"groupname\":\"abhishek\",\n" +
                            "\"segment\":\"Cosmic\",\"accountcode\":\"APP\",\"symbol\":\"NIFTY\",\n" +
                            "\"exchange\":\"NSEFO\",\"expirydate\":\"03NOV2025\",\"scripcode\":\"40034\",\n" +
                            "\"securitytype\":\"OPT\",\"strikeprice\":1200,\"opttype\":\"PE\",\"bfqty\":12,\n" +
                            "\"bfrate\":2,\"bfamt\":0,\"buyqty\":100,\"sellqty\":121,\"netqty\":200,\n" +
                            "\"cfqty\":11,\"cfamt\":78,\"ltp\":9,\"grossmtm\":0,\"brokerageamt\":12222,\n" +
                            "\"netmtm\":45,\"currency\":\"INR\",\"usdrate\":2,\"clientsharing\":0,\"broksharing\":0,\"comsharing\":0,\n" +
                            "\"multiplier\":99}]"));
            jossons.putDataset("websocket",
                    Josson.fromJsonString("[{\"userid\":\"CNRM04\",\"groupname\":\"Rohit\",\"segment\":\"CosPROFIN\",\"accountcode\":\"OWN\",\"symbol\":\"NIFTY\",\"exchange\":\"NSEFO\",\"expirydate\":\"03NOV2025\",\"scripcode\":\"38021\",\"securitytype\":\"OPT\",\"strikeprice\":17700,\"opttype\":\"PE\",\"bfqty\":20,\"bfrate\":122.35,\"bfamt\":18352.5,\"buyqty\":0,\"sellqty\":0,\"netqty\":0,\"cfqty\":-150,\"cfamt\":18352.5,\"ltp\":0,\"grossmtm\":0,\"brokerageamt\":0,\"netmtm\":0,\"currency\":\"INR\",\"usdrate\":1,\"clientsharing\":0,\"broksharing\":0,\"comsharing\":100,\"multiplier\":1},{\"userid\":\"CNRM04\",\"groupname\":\"Rohit\",\"segment\":\"CosPROFIN\",\"accountcode\":\"OWN\",\"symbol\":\"NIFTY\",\"exchange\":\"NSEFO\",\"expirydate\":\"03NOV2025\",\"scripcode\":\"38026\",\"securitytype\":\"OPT\",\"strikeprice\":17800,\"opttype\":\"PE\",\"bfqty\":30,\"bfrate\":0,\"bfamt\":0,\"buyqty\":10800,\"sellqty\":15000,\"netqty\":-4200,\"cfqty\":-4200,\"cfamt\":590729.9999999998,\"ltp\":0,\"grossmtm\":0,\"brokerageamt\":3400.2888479999992,\"netmtm\":0,\"currency\":\"INR\",\"usdrate\":1,\"clientsharing\":0,\"broksharing\":0,\"comsharing\":100,\"multiplier\":1}]]"));

            // Left Join operation
            JsonNode node = jossons.evaluateQuery(
                    "http{userid,scripcode} <=< websocket->map(userid,scripcode,bfqty){userid,scripcode}");
            System.out.println(node.toPrettyString());

        } catch (JossonException e) {
            e.printStackTrace();
        }
    }
}

代码解释:

  1. 导入 Josson 库: 引入必要的 Josson 库。
  2. 创建 Jossons 对象: 创建一个 Jossons 对象,用于管理数据集。
  3. 加载 JSON 数据: 使用 putDataset 方法将两个 JSON 数组分别加载到名为 "http" 和 "websocket" 的数据集中。Josson.fromJsonString 方法用于将 JSON 字符串转换为 Josson 可以处理的格式。
  4. 执行 Left Join 操作: 使用 evaluateQuery 方法执行 Left Join 操作。
    • http{userid,scripcode}: 指定 "http" 数据集,并选择 userid 和 scripcode 作为连接键。
    • websocket->map(userid,scripcode,bfqty){userid,scripcode}: 指定 "websocket" 数据集,使用 map 函数选择 userid, scripcode 和 bfqty 字段,并选择 userid 和 scripcode 作为连接键。
  5. 输出结果: 使用 toPrettyString 方法将结果 JSON 节点格式化并输出到控制台。

输出结果:

[ {
  "userid" : "CNRM04",
  "groupname" : "Rohit",
  "segment" : "CosPROFIN",
  "accountcode" : "OWN",
  "symbol" : "NIFTY",
  "exchange" : "NSEFO",
  "expirydate" : "03NOV2025",
  "scripcode" : "38021",
  "securitytype" : "OPT",
  "strikeprice" : 17700,
  "opttype" : "PE",
  "bfqty" : 20,
  "bfrate" : 122.35,
  "bfamt" : 18352.5,
  "buyqty" : 0,
  "sellqty" : 0,
  "netqty" : 0,
  "cfqty" : -150,
  "cfamt" : 18352.5,
  "ltp" : 0,
  "grossmtm" : 0,
  "brokerageamt" : 0,
  "netmtm" : 0,
  "currency" : "INR",
  "usdrate" : 1,
  "clientsharing" : 0,
  "broksharing" : 0,
  "comsharing" : 100,
  "multiplier" : 1
}, {
  "userid" : "CNRM04",
  "groupname" : "Rohit",
  "segment" : "CosPROFIN",
  "accountcode" : "OWN",
  "symbol" : "NIFTY",
  "exchange" : "NSEFO",
  "expirydate" : "03NOV2025",
  "scripcode" : "38026",
  "securitytype" : "OPT",
  "strikeprice" : 17800,
  "opttype" : "PE",
  "bfqty" : 30,
  "bfrate" : 0,
  "bfamt" : 0,
  "buyqty" : 10800,
  "sellqty" : 15000,
  "netqty" : -4200,
  "cfqty" : -4200,
  "cfamt" : 590729.9999999998,
  "ltp" : 0,
  "grossmtm" : 0,
  "brokerageamt" : 3400.2888479999992,
  "netmtm" : 0,
  "currency" : "INR",
  "usdrate" : 1,
  "clientsharing" : 0,
  "broksharing" : 0,
  "comsharing" : 100,
  "multiplier" : 11
}, {
  "userid" : "CNC01",
  "groupname" : "abhishek",
  "segment" : "Cosmic",
  "accountcode" : "APP",
  "symbol" : "NIFTY",
  "exchange" : "NSEFO",
  "expirydate" : "03NOV2025",
  "scripcode" : "40034",
  "securitytype" : "OPT",
  "strikeprice" : 1200,
  "opttype" : "PE",
  "bfqty" : 12,
  "bfrate" : 2,
  "bfamt" : 0,
  "buyqty" : 100,
  "sellqty" : 121,
  "netqty" : 200,
  "cfqty" : 11,
  "cfamt" : 78,
  "ltp" : 9,
  "grossmtm" : 0,
  "brokerageamt" : 12222,
  "netmtm" : 45,
  "currency" : "INR",
  "usdrate" : 2,
  "clientsharing" : 0,
  "broksharing" : 0,
  "comsharing" : 0,
  "multiplier" : 99
} ]

可以看到,http 数组中 userid 和 scripcode 与 websocket 数组匹配的对象的 bfqty 字段已成功更新。

注意事项

  • 确保 Josson 库已添加到项目的依赖项中。可以使用 Maven 或 Gradle 等构建工具来管理依赖项。
  • 理解 Left Join 操作的含义。Left Join 会保留左侧数据集的所有记录,并将右侧数据集匹配的记录合并到左侧。如果右侧数据集中没有匹配的记录,则右侧数据集的字段将为 null。
  • 根据实际需求调整连接键和需要更新的字段。

总结

使用 Josson 库可以方便地实现 JSON 数组中对象的更新操作。通过数据集连接操作,可以避免复杂的循环和条件判断,从而简化代码并提高可读性。在处理 JSON 数据时,Josson 库是一个强大的工具,值得学习和掌握。