Josson提取符合条件的键值方法
**Josson 聚合符合条件的键值方法:快速高效处理 JSON 数据** 在处理 JSON 数据时,根据特定条件对数据进行聚合是常见的需求。本文详细介绍了如何利用强大的 JSON 处理库 Josson,针对 JSON 数组中符合条件的键值进行聚合,例如根据 userid、groupname 等字段进行分组,并对数值类型的键进行求和。通过代码示例,深入解析 Josson 库的使用方法,助您轻松实现 JSON 数据的分组、聚合,提升数据处理效率。了解 Josson 库的强大功能,简化您的 JSON 数据处理流程。

本文介绍了如何使用 Josson 库,根据特定条件(如 userid、groupname、segment 等字段相同)对 JSON 数组中的数据进行聚合,并对数值类型的键进行求和操作,最终生成新的 JSON 数组。通过详细的代码示例和步骤说明,帮助读者理解 Josson 库的使用方法,并能灵活应用于实际的数据处理场景。
在处理 JSON 数据时,经常会遇到需要根据某些字段的值进行分组,然后对其他字段进行聚合计算的需求。 例如,在金融数据分析中,可能需要根据用户ID、交易品种等信息,统计用户的总交易量、总交易额等。 手动编写代码实现这些功能比较繁琐,容易出错。 Josson 库提供了一种简洁高效的方式来完成这类任务。
Josson 简介
Josson 是一个强大的 JSON 处理库,它提供了一种简洁的语法,可以通过链式调用完成复杂的 JSON 数据转换和查询操作。 它特别擅长于处理嵌套的 JSON 数据结构,并支持各种聚合函数,例如 sum(), count(), avg() 等。
使用 Josson 进行 JSON 数据聚合
下面将通过一个具体的例子,演示如何使用 Josson 库对 JSON 数组进行聚合操作。
1. 引入 Josson 库
首先,需要在项目中引入 Josson 库。 如果使用 Maven,可以在 pom.xml 文件中添加以下依赖:
com.octomix josson 最新版本
请将 "最新版本" 替换为 Josson 库的最新版本号。
2. JSON 数据准备
假设有如下 JSON 数组,需要根据 userid、groupname、segment、accountcode、symbol、exchange 和 expirydate 字段进行分组,并对 bfqty、bfrate、bfamt、buyqty、sellqty、netqty、cfqty、cfamt、ltp、grossmtm、brokerageamt 和 netmtm 字段进行求和:
[
{
"userid": "CNAF01",
"groupname": "Abhay",
"segment": "CosCLFIN",
"accountcode": "66CN-063CC",
"symbol": "INX22",
"exchange": "SGXFO",
"expirydate": "24NOV2022",
"scripcode": "7536847",
"securitytype": "FUT",
"strikeprice": 0,
"opttype": "XX",
"bfqty": -107,
"bfrate": 18462.05,
"bfamt": 3950878.6999999997,
"buyqty": 21,
"sellqty": 59,
"netqty": -38,
"cfqty": -145,
"cfamt": 5358027.699999999,
"ltp": "18433.5",
"grossmtm": 0,
"brokerageamt": 48,
"netmtm": 0,
"currency": "USD",
"usdrate": 81.33,
"clientsharing": 50,
"broksharing": 0,
"comsharing": 50,
"multiplier": 2
},
{
"userid": "CNAF01",
"groupname": "Abhay",
"segment": "CosCLFIN",
"accountcode": "CW05",
"symbol": "NIFTY",
"exchange": "NSEFO",
"expirydate": "24NOV2022",
"scripcode": "61349",
"securitytype": "OPT",
"strikeprice": 17800,
"opttype": "CE",
"bfqty": 4050,
"bfrate": 673.3,
"bfamt": -2726865,
"buyqty": 1650,
"sellqty": 300,
"netqty": 1350,
"cfqty": 5400,
"cfamt": -3677257.5,
"ltp": "657.0",
"grossmtm": 0,
"brokerageamt": 1038.81126525,
"netmtm": 0,
"currency": "INR",
"usdrate": 1,
"clientsharing": 0,
"broksharing": 0,
"comsharing": 100,
"multiplier": 1
},
{
"userid": "CNAF01",
"groupname": "Abhay",
"segment": "CosCLFIN",
"accountcode": "CW05",
"symbol": "NIFTY",
"exchange": "NSEFO",
"expirydate": "24NOV2022",
"scripcode": "61350",
"securitytype": "OPT",
"strikeprice": 17800,
"opttype": "PE",
"bfqty": -4050,
"bfrate": 14.7,
"bfamt": 59535,
"buyqty": 300,
"sellqty": 1650,
"netqty": -1350,
"cfqty": -5400,
"cfamt": 78900,
"ltp": "13.6",
"grossmtm": 0,
"brokerageamt": 31.850901,
"netmtm": 0,
"currency": "INR",
"usdrate": 1,
"clientsharing": 0,
"broksharing": 0,
"comsharing": 100,
"multiplier": 1
}
]3. 使用 Josson 进行转换
import com.octomix.josson.Josson;
import com.octomix.josson.JsonNode;
import javax.json.JsonString;
public class JossonAggregation {
public static void main(String[] args) {
String jsonString = "[{\"userid\":\"CNAF01\",\"groupname\":\"Abhay\",\"segment\":\"CosCLFIN\",\"accountcode\":\"66CN-063CC\",\"symbol\":\"INX22\",\"exchange\":\"SGXFO\",\"expirydate\":\"24NOV2022\"," +
"\"scripcode\":\"7536847\",\"securitytype\":\"FUT\",\"strikeprice\":0,\"opttype\":\"XX\",\"bfqty\":-107,\"bfrate\":18462.05,\"bfamt\":3950878.6999999997,\"buyqty\":21,\"sellqty\":59,\"netqty\":-38," +
"\"cfqty\":-145,\"cfamt\":5358027.699999999,\"ltp\":\"18433.5\",\"grossmtm\":0,\"brokerageamt\":48,\"netmtm\":0,\"currency\":\"USD\",\"usdrate\":81.33,\"clientsharing\":50,\"broksharing\":0," +
"\"comsharing\":50,\"multiplier\":2}," +
"{\"userid\":\"CNAF01\",\"groupname\":\"Abhay\",\"segment\":\"CosCLFIN\",\"accountcode\":\"CW05\",\"symbol\":\"NIFTY\",\"exchange\":\"NSEFO\"," +
"\"expirydate\":\"24NOV2022\",\"scripcode\":\"61349\",\"securitytype\":\"OPT\",\"strikeprice\":17800,\"opttype\":\"CE\",\"bfqty\":4050,\"bfrate\":673.3,\"bfamt\":-2726865,\"buyqty\":1650," +
"\"sellqty\":300,\"netqty\":1350,\"cfqty\":5400,\"cfamt\":-3677257.5,\"ltp\":\"657.0\",\"grossmtm\":0,\"brokerageamt\":1038.81126525,\"netmtm\":0,\"currency\":\"INR\",\"usdrate\":1,\"clientsharing\":0," +
"\"broksharing\":0,\"comsharing\":100,\"multiplier\":1}," +
"{\"userid\":\"CNAF01\",\"groupname\":\"Abhay\",\"segment\":\"CosCLFIN\",\"accountcode\":\"CW05\",\"symbol\":\"NIFTY\",\"exchange\":\"NSEFO\"," +
"\"expirydate\":\"24NOV2022\",\"scripcode\":\"61350\",\"securitytype\":\"OPT\",\"strikeprice\":17800,\"opttype\":\"PE\",\"bfqty\":-4050,\"bfrate\":14.7,\"bfamt\":59535,\"buyqty\":300,\"sellqty\":1650," +
"\"netqty\":-1350,\"cfqty\":-5400,\"cfamt\":78900,\"ltp\":\"13.6\",\"grossmtm\":0,\"brokerageamt\":31.850901,\"netmtm\":0,\"currency\":\"INR\",\"usdrate\":1,\"clientsharing\":0,\"broksharing\":0," +
"\"comsharing\":100,\"multiplier\":1}]";
Josson josson = Josson.fromJsonString(jsonString);
JsonNode node = josson.getNode(
"group(map(userid,groupname,segment,accountcode,symbol,exchange,expirydate," +
" currency,usdrate,clientsharing,broksharing,comsharing,multiplier))" +
".map(key.userid," +
" key.groupname," +
" key.segment," +
" key.accountcode," +
" key.symbol," +
" key.exchange," +
" key.expirydate," +
" key.currency," +
" key.usdrate," +
" key.clientsharing," +
" key.broksharing," +
" key.comsharing," +
" key.multiplier," +
" elements.bfqty.sum()," +
" elements.bfrate.sum()," +
" elements.bfamt.sum()," +
" elements.buyqty.sum()," +
" elements.sellqty.sum()," +
" elements.netqty.sum()," +
" elements.cfqty.sum()," +
" elements.cfamt.sum()," +
" elements.ltp.sum()," +
" elements.grossmtm.sum()," +
" elements.brokerageamt.sum()," +
" elements.netmtm.sum())");
System.out.println(node.toPrettyString());
}
}代码解释:
- Josson.fromJsonString(jsonString): 将 JSON 字符串解析为 Josson 对象。
- group(map(userid,groupname,segment,accountcode,symbol,exchange,expirydate,currency,usdrate,clientsharing,broksharing,comsharing,multiplier)): 这部分代码定义了分组的依据。 group() 函数根据 map() 函数中指定的字段进行分组。 map() 函数用于提取每个 JSON 对象中指定的字段,并将它们组合成一个键。
- .map(key.userid, key.groupname, ...): 这部分代码定义了输出结果的结构。 key.userid 表示使用分组键中的 userid 字段作为输出结果中的 userid 字段的值。 elements.bfqty.sum() 表示对每个分组中的 bfqty 字段进行求和,并将结果作为输出结果中的 bfqty 字段的值。
4. 输出结果
运行上述代码,将得到以下输出结果:
[ {
"userid" : "CNAF01",
"groupname" : "Abhay",
"segment" : "CosCLFIN",
"accountcode" : "66CN-063CC",
"symbol" : "INX22",
"exchange" : "SGXFO",
"expirydate" : "24NOV2022",
"currency" : "USD",
"usdrate" : 81.33,
"clientsharing" : 50,
"broksharing" : 0,
"comsharing" : 50,
"multiplier" : 2,
"bfqty" : -107.0,
"bfrate" : 18462.05,
"bfamt" : 3950878.6999999997,
"buyqty" : 21.0,
"sellqty" : 59.0,
"netqty" : -38.0,
"cfqty" : -145.0,
"cfamt" : 5358027.699999999,
"ltp" : 18433.5,
"grossmtm" : 0.0,
"brokerageamt" : 48.0,
"netmtm" : 0.0
}, {
"userid" : "CNAF01",
"groupname" : "Abhay",
"segment" : "CosCLFIN",
"accountcode" : "CW05",
"symbol" : "NIFTY",
"exchange" : "NSEFO",
"expirydate" : "24NOV2022",
"currency" : "INR",
"usdrate" : 1,
"clientsharing" : 0,
"broksharing" : 0,
"comsharing" : 100,
"multiplier" : 1,
"bfqty" : 0.0,
"bfrate" : 688.0,
"bfamt" : -2667330.0,
"buyqty" : 1950.0,
"sellqty" : 1950.0,
"netqty" : 0.0,
"cfqty" : 0.0,
"cfamt" : -3598357.5,
"ltp" : 670.6,
"grossmtm" : 0.0,
"brokerageamt" : 1070.66216625,
"netmtm" : 0.0
} ]可以看到,Josson 库成功地根据指定的字段对 JSON 数组进行了分组,并对数值类型的字段进行了求和操作。
注意事项
- Josson 库的语法比较灵活,可以根据实际需求进行调整。
- 在进行聚合操作时,需要确保参与计算的字段都是数值类型。
- 如果 JSON 数据中包含 null 值,可能会导致聚合结果不正确,需要进行特殊处理。
- ltp 字段被当做字符串处理,如果需要正确计算,需要先转换为数值类型,可以使用 elements.ltp.number().sum()。
总结
本文介绍了如何使用 Josson 库对 JSON 数组进行分组和聚合操作。 Josson 库提供了一种简洁高效的方式来处理 JSON 数据,可以大大简化代码的编写,提高开发效率。 通过学习本文,读者可以掌握 Josson 库的基本用法,并能灵活应用于实际的数据处理场景。
以上就是《Josson提取符合条件的键值方法》的详细内容,更多关于的资料请关注golang学习网公众号!
Windows沙盒开启教程及使用方法
- 上一篇
- Windows沙盒开启教程及使用方法
- 下一篇
- HTML数据解析方法与网页分析技巧
-
- 文章 · java教程 | 1天前 | Java · sealed · 模式匹配 · Java 21 · 类型系统 · pattern switch · 穷尽性检查 Java 21 Java pattern switch sealed 类型 when 守卫 dominance
- Java pattern switch用 switch 覆盖 sealed 类型分支的实现方法
- 448浏览 收藏
-
- 文章 · java教程 | 1天前 | 虚拟线程 · 任务取消 · Java并发 · 结构化并发 · JDK预览特性 · Java StructuredTaskScope Java结构化并发 Java子任务取消 StructuredTaskScope结果汇总 Java虚拟线程并发
- Java StructuredTaskScope组织子任务取消与结果汇总的实现方法
- 117浏览 收藏
-
- 文章 · java教程 | 1天前 |
- Java virtual thread定位 synchronized 导致的固定载体线程的实现方法
- 149浏览 收藏
-
- 文章 · java教程 | 1天前 | Java教程 · 性能调优 · G1垃圾收集器 · GC日志 · 内存排障 · java GC G1 humongous allocation Humongous regions Full GC
- Java GC 日志出现 humongous allocation 时怎么判断
- 184浏览 收藏
-
- 文章 · java教程 | 1天前 | Java · jdbc · 数据库异常处理 · java jdbc SQLException SQLSTATE vendorCode
- Java SQLException SQLState 和 vendorCode 如何分层
- 229浏览 收藏
-
- 文章 · java教程 | 2天前 | Java · module-info · requires transitive ·
- Java module requires transitive 如何影响下游编译
- 257浏览 收藏
-
- 文章 · java教程 | 2天前 | Java · 模块系统 · ServiceLoader · java ServiceLoader JPMS 模块路径
- Java ServiceLoader 在模块路径下为何找不到 provider
- 455浏览 收藏
-
- 文章 · java教程 | 2天前 | Java · 异常处理 · 异步编程 · java completablefuture whenComplete
- Java CompletableFuture whenComplete 如何记录异常而不改变结果
- 439浏览 收藏
-
- 文章 · java教程 | 2天前 |
- Java HttpClient BodyHandlers.ofPublisher 如何处理 Publisher 取消
- 385浏览 收藏
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 543次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 516次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 500次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 485次学习
-
- PubMedQA
- 深入了解PubMedQA生物医学问答数据集,涵盖其核心功能、使用方法及在临床决策、药物研发等场景的应用,助力提升NLP模型性能。
- 77次使用
-
- H2O EvalGPT
- H2O EvalGPT是H2O.ai推出的开源LLM评估平台,提供详细的大模型性能排行榜、行业特定基准测试及A/B测试功能,助您快速选择最适合项目的高性能大语言模型。
- 161次使用
-
- LMArena
- LMArena是加州大学伯克利分校推出的AI模型匿名评测平台。通过盲测投票机制,用户可对比不同大模型回答并生成实时排行榜,助力开发者优化模型及用户选择最佳AI工具。
- 101次使用
-
- HELM
- 深入了解斯坦福推出的HELM(Holistic Evaluation of Language Models)大模型评测体系。本文解析其核心功能、安装配置步骤及应用场景,涵盖准确性、公平性、鲁棒性等多维度指标,助力开发者全面优化语言模型性能。
- 76次使用
-
- CMMLU
- 深入了解CMMLU中文评估基准,涵盖67个学科主题,提供数据集下载、Zero-shot/Five-shot评估方法及排行榜,助力优化中文语言模型性能。
- 55次使用
-
- Java try-with-resources 多个资源关闭顺序是什么
- 2026-09-10 501浏览
-
- 矩阵主副对角线快速定位技巧
- 2026-05-31 501浏览
-
- Java多态优化流程代码与行为分发改进
- 2026-05-26 501浏览
-
- JVM 类元数据双亲委派链表深度解析
- 2026-05-21 501浏览
-
- 反射异常处理:InvocationTargetException解析与应用
- 2026-05-16 501浏览

