本文介绍如何使用 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 文件中添加以下依赖：
<dependency><groupid>com.octomix</groupid><artifactid>josson</artifactid><version>最新版本</version></dependency>
请将 "最新版本" 替换为 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} map(userid,scripcode,bfqty){userid,scripcode}");
System.out.println(node.toPrettyString());
}
}
代码解释：
- 引入 Josson 库：首先，需要引入 Josson 库的相关类。
- 创建 Jossons 对象：创建一个 Jossons 对象，用于管理 JSON 数据集。
- 反序列化 JSON 数据：使用 Josson.fromJsonString() 方法将 JSON 字符串反序列化为 JsonNode 对象，并使用 jossons.putDataset() 方法将它们添加到 Jossons 对象中，分别命名为 "http" 和 "websocket"。
-
执行 Left Join 操作：使用 jossons.evaluateQuery() 方法执行 Left Join 操作。
- http{userid,scripcode}：指定 "http" 数据集，并选择 userid 和 scripcode 字段作为连接键。
- websocket->map(userid,scripcode,bfqty){userid,scripcode}：指定 "websocket" 数据集，使用 map() 函数选择 userid、scripcode 和 bfqty 字段，并使用 userid 和 scripcode 作为连接键。
- 输出结果：使用 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 库来简化开发流程。
