Josson库快速更新JSON数组对象方法

本文介绍如何使用 Josson 库，通过键值匹配的方式，将一个 JSON 数组中的数据更新到另一个 JSON 数组中。这种方法避免了繁琐的嵌套循环，提高了代码的可读性和执行效率。通过 Josson 提供的 dataset join 操作，可以轻松实现 JSON 数据的关联和更新。

简介

在处理 JSON 数据时，经常会遇到需要根据某些共同的键，将一个 JSON 数组中的数据更新到另一个 JSON 数组中的情况。传统的做法是使用嵌套循环来遍历两个数组，然后进行比较和更新。但是，这种方法效率较低，代码也比较冗长。

Josson 库提供了一种更简洁、高效的方法来实现这个目标，它通过 dataset join 操作，可以根据指定的键，将两个 JSON 数组关联起来，并更新相应的数据。

Josson 库简介

Josson 是一个用于处理 JSON 数据的 Java 库，它提供了一组强大的 API，可以方便地进行 JSON 数据的查询、转换和更新。Josson 的主要特点包括：

• 简洁的语法：使用类似于 SQL 的语法来操作 JSON 数据。
• 高性能：通过优化的算法，提高了 JSON 数据的处理效率。
• 丰富的功能：支持 JSON 数据的查询、转换、更新、聚合等操作。

安装 Josson 库

要使用 Josson 库，首先需要在项目中添加 Josson 的依赖。如果使用 Maven，可以在 pom.xml 文件中添加以下依赖：

    com.octomix
    josson
    最新版本

请将 "最新版本" 替换为 Josson 库的最新版本号。

示例代码

以下是一个使用 Josson 库来更新 JSON 数组的示例代码：

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

public class JsonUpdateExample {

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

        // 模拟两个 JSON 数组
        String httpJson = "[{\"userid\":\"CNRM04\",\"groupname\":\"Rohit\",\n" +
                "\"segment\":\"CosPROFIN\",\"accountcode\":\"OWN\",\"symbol\":\"NIFTY\",\"exchange\":\"NSEFO\",\n" +
                "\"expirydate\":\"03NOV2022\",\"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\":\"03NOV2022\",\"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\":\"03NOV2022\",\"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}]";

        String websocketJson = "[{\"userid\":\"CNRM04\",\"groupname\":\"Rohit\",\"segment\":\"CosPROFIN\",\"accountcode\":\"OWN\",\"symbol\":\"NIFTY\",\"exchange\":\"NSEFO\",\"expirydate\":\"03NOV2022\",\"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\":\"03NOV2022\",\"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}]";

        // Deserialization
        jossons.putDataset("http", Josson.fromJsonString(httpJson));
        jossons.putDataset("websocket", Josson.fromJsonString(websocketJson));

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

        System.out.println(node.toPrettyString());
    }
}

代码解释：

1. 引入 Josson 库：首先，需要引入 Josson 库的相关类。
2. 创建 Jossons 对象：创建一个 Jossons 对象，用于管理 JSON 数据集。
3. 反序列化 JSON 数据：使用 Josson.fromJsonString() 方法将 JSON 字符串反序列化为 JsonNode 对象，并使用 jossons.putDataset() 方法将它们添加到 Jossons 对象中，分别命名为 "http" 和 "websocket"。
4. 执行 Left Join 操作：使用 jossons.evaluateQuery() 方法执行 Left Join 操作。
   • http{userid,scripcode}：指定 "http" 数据集，并选择 userid 和 scripcode 字段作为连接键。
   • <=<：表示 Left Join 操作。
   • websocket->map(userid,scripcode,bfqty){userid,scripcode}：指定 "websocket" 数据集，使用 map() 函数选择 userid、scripcode 和 bfqty 字段，并使用 userid 和 scripcode 作为连接键。
5. 输出结果：使用 node.toPrettyString() 方法将结果格式化输出。

输出结果：

[ {
  "userid" : "CNRM04",
  "groupname" : "Rohit",
  "segment" : "CosPROFIN",
  "accountcode" : "OWN",
  "symbol" : "NIFTY",
  "exchange" : "NSEFO",
  "expirydate" : "03NOV2022",
  "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" : "03NOV2022",
  "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" : "03NOV2022",
  "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" 数组中的 bfqty 字段已经根据 "websocket" 数组中的值进行了更新。

注意事项

• 确保两个 JSON 数组中用于连接的键的名称和类型一致。
• 如果 "websocket" 数组中没有与 "http" 数组中的记录匹配的记录，则 "http" 数组中的相应字段将保持不变。
• Josson 库还支持其他类型的 Join 操作，例如 Inner Join、Right Join 等，可以根据实际需求选择合适的 Join 类型。

总结

Josson 库提供了一种简洁、高效的方法来更新 JSON 数组中的数据。通过 dataset join 操作，可以避免繁琐的嵌套循环，提高代码的可读性和执行效率。在处理 JSON 数据时，可以考虑使用 Josson 库来简化开发流程。