使用 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 库聚合 JSON 数组中满足特定条件的键值的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/38384.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
漫蛙Manwa2官网最新链接 漫蛙漫画(网页版)防走失导航
上一篇 2025年11月5日 14:38:38
linux中如何利用shell判断文件或目录是否存在
下一篇 2025年11月5日 14:38:43

相关推荐

  • 三星在电视端首发Perplexity AI应用程序,带来更具创新性AI体验

    10 月 23 日消息,三星电子于美国当地时间 21 日宣布,率先在电视终端推出 perplexity ai 应用程序,为三星电视用户带来更富创新的 ai 使用体验。 借助该应用程序,用户在安排日常生活、查找特定影视内容、创建梦幻体育联赛阵容或策划万圣节活动等场景中,可获得 AI 以卡片式回复框形式…

    2026年9月21日
    000
  • 帕鲁高管回应《幻兽帕鲁:帕鲁农场》疑似碰瓷《宝可梦 pokopia》:乱讲阴谋论

    帕鲁高管回应《幻兽帕鲁:帕鲁农场》疑似碰瓷《宝可梦 pokopia》:乱讲阴谋论帕鲁高管回应《幻兽帕鲁:帕鲁农场》疑似碰瓷《宝可梦 pokopia》:乱讲阴谋论帕鲁高管回应《幻兽帕鲁:帕鲁农场》疑似碰瓷《宝可梦 pokopia》:乱讲阴谋论帕鲁高管回应《幻兽帕鲁:帕鲁农场》疑似碰瓷《宝可梦 pokopia》:乱讲阴谋论

    在不久前的任天堂直面会上,官方公布了一款宝可梦ip的衍生新作——《宝可梦 pokopia》。这款作品让玩家化身一只能够变身成人类训练家的百变怪,主打种田与建造玩法,属于模拟经营类游戏。 视频欣赏: 无独有偶,几天后,《幻兽帕鲁》的开发商PocketPair也正式公布了他们的全新衍生作《幻兽帕鲁:帕鲁…

    2026年9月21日 用户投稿
    000
  • 如何使用mysql设计客户信息管理项目

    答案:设计客户信息管理系统需先明确功能需求,再合理规划数据库结构。1. 根据客户需求划分模块,包括客户基本信息、分类、状态、跟进记录等;2. 创建核心表如customers、company_info、follow_ups和users,确保字段完整且符合业务逻辑;3. 在关键字段上建立索引以提升查询效…

    2026年9月21日
    300
  • VSCode怎么新建ipynb文件_VSCode创建和编辑Jupyter笔记本文件教程

    答案:在VSCode中运行Jupyter笔记本需准备Python环境、安装Python扩展并确保安装ipykernel;通过命令面板或文件菜单新建笔记本,编辑时可添加代码或Markdown单元格,运行代码后结果实时显示;通过右上角内核选择器切换Python环境,推荐为不同项目配置独立虚拟环境以避免依…

    2026年9月21日
    000
  • 夸克Ai搜索如何设置默认_夸克Ai搜索默认引擎更改

    首先在夸克APP中将默认搜索引擎设为AI引擎,再开启相关AI功能开关以启用AI搜索服务。具体步骤:1、打开夸克APP,点击右下角菜单进入设置;2、选择“通用”选项,点击“搜索引擎”;3、选择“AI引擎”或“夸克AI搜索”作为默认服务;4、返回主界面测试搜索关键词,确认AI结果是否展示;5、进入“AI…

    2026年9月21日
    400
  • Linux查看系统日志的常用命令

    答案是查看Linux日志需综合使用journalctl、dmesg、tail、grep等工具。journalctl用于systemd系统集中查询服务及内核日志,支持时间、优先级、字段等多维度过滤;dmesg专注内核启动与硬件问题;tail -f实时监控日志动态;cat、grep、less结合正则和管…

    用户投稿 2026年9月21日
    000
  • Java中设计可扩展类的技巧与经验

    设计可扩展类应优先组合而非继承,通过接口解耦;明确开放protected扩展点并封闭关键逻辑;提供详细文档说明扩展规则;谨慎处理状态与初始化,避免构造器中调用可重写方法;多数场景推荐接口与组合,必要时才允许继承。 在Java中设计可扩展类时,核心目标是让类既能满足当前需求,又便于未来被安全、可控地继…

    2026年9月21日
    100
  • mysql如何实现后台管理系统

    答案:基于MySQL的%ignore_a_1%需设计用户、权限、日志等表结构,通过后端语言实现安全的CRUD接口与JWT认证,前端展示数据并控制权限,确保系统安全稳定。 实现一个基于 MySQL 的后台管理系统,核心是构建一个安全、稳定、可扩展的系统架构,将数据库作为数据存储层,配合后端语言和前端界…

    2026年9月21日
    000
  • Workerman服务启动失败的排查步骤

    workerman服务启动失败的排查步骤如下:1. 检查配置文件,确保无语法错误;2. 查看系统日志,寻找错误线索;3. 检查端口占用情况,确保端口未被占用;4. 调整文件权限,确保workerman有足够权限;5. 检查php环境,确保版本兼容且扩展已安装。 关于Workerman服务启动失败的排…

    2026年9月21日
    200
  • 如何为VSCode设置自定义的代码高亮颜色?

    答案:通过settings.json中的editor.tokenColorCustomizations可自定义VSCode代码高亮颜色,支持全局或特定主题下修改关键字、字符串等元素颜色,结合textMateRules和作用域精确控制,提升代码可读性。 为 VSCode 设置自定义的代码高亮颜色,可以…

    2026年9月21日
    000
  • 百度浏览器自动跳转怎么办 百度浏览器页面跳转广告拦截方法

    百度浏览器自动跳转通常由恶意软件或设置被篡改引起,需检查浏览器设置、清除异常插件、修复快捷方式与注册表,并使用安全软件扫描清理,同时启用广告拦截与隐私保护功能以彻底解决问题。 百度浏览器出现自动跳转,通常不是浏览器本身的问题,而是由恶意软件、插件或设置被篡改导致的。解决这个问题需要从多个方面入手,检…

    2026年9月21日
    100
  • 压力测试(Benchmark)Swoole服务的工具与方法

    进行swoole服务的压力测试是为了确保服务在高负载下稳定运行。1. 选择工具:apache jmeter、wrk、locust。2. 使用方法:jmeter通过脚本配置,wrk通过命令行,locust通过python脚本。3. 注意事项:环境隔离、数据监控、脚本设计。4. 优化点:内存泄漏、连接池…

    2026年9月21日
    000
  • Windows11内存占用率过高怎么解决_Windows11内存占用过高修复方法

    1、通过任务管理器结束高内存占用进程;2、禁用Superfetch(SysMain)服务以降低内存负担;3、优化启动项减少后台负载;4、升级物理内存条提升系统性能。 如果您发现Windows 11系统运行缓慢,并且任务管理器显示内存占用率持续处于高位,这可能是由于后台进程过多、系统服务占用资源或硬件…

    2026年9月21日
    100
  • mysql常用存储引擎有哪些

    InnoDB是现代MySQL应用的首选存储引擎,因其支持事务(ACID)、行级锁、外键约束、崩溃恢复和MVCC,适用于高并发、数据完整性要求高的OLTP场景;MyISAM虽读取快但仅支持表级锁且无事务和外键,适用于读多写少的简单场景,已逐渐被淘汰;Memory引擎将数据存于内存,速度快但易失,适合临…

    2026年9月21日
    000
  • 在Java中多态是如何通过虚方法实现的

    多态通过动态方法调度实现,JVM利用虚方法表(vtable)在运行时根据对象实际类型确定方法调用。Java中除private、static、final方法和构造器外均为虚方法,子类重写方法后其vtable指向新实现,调用时JVM通过对象类型查找vtable定位具体方法。如Animal a = new…

    2026年9月21日
    000
  • 如何配置VSCode来完美支持Vue.js开发?

    安装Volar、TypeScript Vue Plugin、ESLint和Prettier扩展,禁用Vetur,在settings.json中配置vetur.enabled为false,设置ESLint保存时自动修复并指定Prettier为默认格式化工具,关联.vue文件语言,启用TypeScrip…

    2026年9月21日
    000
  • 利用蝴蝶号搭建多账号无人直播系统的完整方案

    利用蝴蝶号搭建多账号无人直播系统的完整方案利用蝴蝶号搭建多账号无人直播系统的完整方案利用蝴蝶号搭建多账号无人直播系统的完整方案利用蝴蝶号搭建多账号无人直播系统的完整方案

    搭建多账号无人直播系统并非一键操作,而是通过“蝴蝶号”实现自动化流程。首先,“蝴蝶号”负责多账号的生命周期管理,包括登录、状态维护、ip代理分配和设备指纹模拟;其次,内容调度系统决定直播内容及播放时间,可为预录视频或动态生成流;再次,推流引擎将内容实时推送至平台,推荐使用ffmpeg结合python…

    2026年9月21日 用户投稿
    100
  • 锚定AI终端存储市场,康盈半导体连发三款新品

    锚定AI终端存储市场,康盈半导体连发三款新品锚定AI终端存储市场,康盈半导体连发三款新品锚定AI终端存储市场,康盈半导体连发三款新品锚定AI终端存储市场,康盈半导体连发三款新品

    ☞☞☞AI 智能聊天, 问答助手, AI 智能搜索, 免费无限量使用 DeepSeek R1 模型☜☜☜ 三款新品聚焦AI存储需求 在最新举行的产品发布会上,康盈半导体正式推出三款专为AI应用场景打造的全新存储解决方案,覆盖嵌入式存储与高性能固态硬盘等多个品类,旨在满足多样化AI终端对高效、紧凑、低…

    2026年9月21日 用户投稿
    100
  • linux内核定时器实验

    linux内核定时器实验linux内核定时器实验linux内核定时器实验linux内核定时器实验

    大家好,又见面了,我是你们的朋友全栈君。 文章目录一、linux时间管理和内核定时器简介1.内核时间管理简介2.内核定时器简介1.init_timer 函数2.add_timer 函数3.del_timer 函数4.del_timer_sync 函数5.mod_timer 函数3.linux内核短延…

    2026年9月21日 用户投稿
    000
  • WordPress插件定制:使用Filter Hook修改邮件通知接收者

    本教程将指导您如何在WordPress中利用Filter Hook定制插件行为,特别是修改第三方插件的邮件通知接收者。我们将详细讲解如何识别目标Filter、理解其参数,并正确编写回调函数来拦截或修改数据,以实现自定义的邮件发送逻辑,避免因参数不匹配导致的错误。 WordPress Hook机制概览…

    2026年9月21日
    100

发表回复

登录后才能评论
关注微信