0

0

高效更新 Java 中 JSON 数组中的对象:使用 Josson 库实现

心靈之曲

心靈之曲

发布时间:2025-07-28 18:34:01

|

285人浏览过

|

来源于php中文网

原创

高效更新 Java 中 JSON 数组中的对象:使用 Josson 库实现

本文旨在介绍如何高效地更新 Java 中 JSON 数组内的对象。当需要根据特定匹配键(如userid和scripcode)将一个 JSON 数组(websocketjsonArray)中的数据更新到另一个 JSON 数组(http)中的对应对象时,传统嵌套循环方法效率低下且易出错。我们将重点探讨如何利用 Josson 库提供的强大查询和连接功能,以简洁、声明式的方式实现这一复杂的数据合并与更新操作,显著提升代码的可读性和执行效率。

1. 问题背景与传统方法的局限性

在数据处理场景中,我们经常会遇到需要同步或合并来自不同数据源的 json 数据。例如,给定两个 jsonarray:http 和 websocketjsonarray,它们都包含一系列 jsonobject。我们的目标是,如果 websocketjsonarray 中的某个对象与 http 数组中的某个对象在 userid 和 scripcode 字段上完全匹配,则将 websocketjsonarray 中该对象的特定字段(如 bfqty)的值更新到 http 数组中对应的对象上。

传统的实现方式通常涉及嵌套循环:遍历 websocketjsonArray,在内部循环遍历 http 数组,然后使用 if 条件判断 userid 和 scripcode 是否匹配。一旦匹配成功,就手动从源对象获取值并更新目标对象。这种方法虽然直观,但存在以下局限性:

  • 效率低下:对于大型 JSON 数组,嵌套循环的时间复杂度为 O(N*M),其中 N 和 M 分别是两个数组的长度,这会导致性能瓶颈。
  • 代码冗余:手动的数据查找、比较和更新逻辑会使代码变得冗长且难以维护。
  • 易出错:在复杂的条件判断和数据类型转换中,容易引入逻辑错误。

2. 引入 Josson 库:高效的 JSON 数据操作利器

为了解决上述问题,我们可以利用 Josson 和 Jossons 库。Josson 是一个强大的 Java JSON 处理器,它提供了一种类似 SQL 的查询语言来操作 JSON 数据,包括数据选择、过滤、转换和连接等。Jossons 则是 Josson 的一个扩展,支持多数据集操作,非常适合我们当前的需求。

2.1 添加 Josson 依赖

在使用 Josson 之前,需要将其添加到项目的 pom.xml(Maven)或 build.gradle(Gradle)文件中。

Maven:

立即学习Java免费学习笔记(深入)”;


    com.github.octomix.josson
    josson
    1.4.1 

Gradle:

implementation 'com.github.octomix.josson:josson:1.4.1' // 请使用最新版本

2.2 数据准备与数据集注册

首先,我们需要将原始的 JSON 字符串解析成 Josson 对象,并通过 Jossons 注册为命名数据集。这使得我们可以在查询中通过名称引用它们。

Metafox企业内容管理系统0.9.1
Metafox企业内容管理系统0.9.1

Metafox 是一个企业内容管理系统,使用一个特别的模板系统,你可通过一些特定的设计和代码来轻松创建 Web 网站,内容存储在 SQL 关系数据库,通过 Web 进行管理,简单、快速而且高效。 Metafox 0.9.1 发布,该版本改用一种更棒的 URL 风格,实现了 RSS 源(可包含远端网站内容到 Metafox 段中),重定向老的访问密钥到新的密钥,增加 RotateAntispam 技

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

public class JsonArrayUpdater {

    public static void main(String[] args) {
        try {
            // 原始 HTTP 数据
            String httpJsonString = "[{\"userid\":\"CNRM04\",\"groupname\":\"Rohit\",\"segment\":\"CosPROFIN\",\"accountcode\":\"OWN\",\"symbol\":\"NIFTY\",\"exchange\":\"NSEFO\",\"expirydate\":\"03NOV2022\",\"scripcode\":\"38021\",\"securitytype\":\"OPT\",\"strikeprice\":17700,\"opttype\":\"PE\",\"bfqty\":-1500,\"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\":0,\"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}]";

            // WebSocket 更新数据
            String websocketJsonString = "[{\"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}]]";

            Jossons jossons = new Jossons();
            jossons.putDataset("http", Josson.fromJsonString(httpJsonString));
            jossons.putDataset("websocket", Josson.fromJsonString(websocketJsonString));

            System.out.println("原始 http 数据:\n" + jossons.getDataset("http").toPrettyString());
            System.out.println("原始 websocket 数据:\n" + jossons.getDataset("websocket").toPrettyString());

            // ... 后续执行查询
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

2.3 执行数据合并与更新(左连接操作)

Josson 提供了强大的查询语法来实现数据连接和更新。在本例中,我们将使用左连接(

核心查询语句是: http{userid,scripcode} map(userid,scripcode,bfqty){userid,scripcode}

让我们分解这个查询:

  • http{userid,scripcode}: 指定左侧数据集为 http,并且定义用于匹配的键是 userid 和 scripcode。
  • websocket->map(userid,scripcode,bfqty){userid,scripcode}:
    • websocket: 指定右侧数据集为 websocket。
    • ->map(userid,scripcode,bfqty): 这是一个映射(map)操作,它从 websocket 数据集中为每个对象选择 userid, scripcode, bfqty 这三个字段。这意味着只有这些字段会被考虑用于更新。
    • {userid,scripcode}: 指定右侧数据集用于匹配的键也是 userid 和 scripcode。

当查询执行时,Josson 会根据 userid 和 scripcode 将 http 中的对象与 websocket 中映射后的对象进行匹配。如果找到匹配,websocket 中 map 操作选取的字段(即 bfqty)的值将覆盖 http 中对应对象的 bfqty 值。

完整代码示例:

import com.fasterxml.jackson.databind.JsonNode;
import com.octomix.josson.Josson;
import com.octomix.josson.Jossons;
import org.json.JSONArray; // 引入 org.json.JSONArray 以匹配原始问题中的数据结构

public class JsonArrayUpdateExample {

    // 假设这是您的Activity或主类
    public static void main(String[] args) {
        try {
            // 原始 HTTP 数据,使用 org.json.JSONArray 兼容原始问题
            JSONArray http = new JSONArray("[{\"userid\":\"CNRM04\",\"groupname\":\"Rohit\",\"segment\":\"CosPROFIN\",\"accountcode\":\"OWN\",\"symbol\":\"NIFTY\",\"exchange\":\"NSEFO\",\"expirydate\":\"03NOV2022\",\"scripcode\":\"38021\",\"securitytype\":\"OPT\",\"strikeprice\":17700,\"opttype\":\"PE\",\"bfqty\":-1500,\"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\":0,\"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}]");

            // WebSocket 更新数据,使用 org.json.JSONArray 兼容原始问题
            JSONArray websocketjsonArray = new JSONArray("[{\"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}]]");

            // 初始化 Jossons 实例
            Jossons jossons = new Jossons();

            // 将 JSONArray 转换为 Josson 对象并注册为数据集
            // 注意:Josson.fromJsonString 接受 JSON 字符串,而不是 org.json.JSONArray 对象
            jossons.putDataset("http", Josson.fromJsonString(http.toString()));
            jossons.putDataset("websocket", Josson.fromJsonString(websocketjsonArray.toString()));

            System.out.println("--- 原始数据 ---");
            System.out.println("http:\n" + jossons.getDataset("http").toPrettyString());
            System.out.println("websocket:\n" + jossons.getDataset("websocket").toPrettyString());

            // 执行左连接更新操作
            JsonNode updatedHttpNode = jossons.evaluateQuery(
                    "http{userid,scripcode} <=< websocket->map(userid,scripcode,bfqty){userid,scripcode}");

            System.out.println("\n--- 更新后的数据 ---");
            System.out.println(updatedHttpNode.toPrettyString());

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

2.4 预期输出

运行上述代码,您将看到 http 数组中 bfqty 字段的值根据 websocket 数组中的匹配项进行了更新:

[ {
  "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" : "

相关专题

更多
java
java

Java是一个通用术语,用于表示Java软件及其组件,包括“Java运行时环境 (JRE)”、“Java虚拟机 (JVM)”以及“插件”。php中文网还为大家带了Java相关下载资源、相关课程以及相关文章等内容,供大家免费下载使用。

825

2023.06.15

java正则表达式语法
java正则表达式语法

java正则表达式语法是一种模式匹配工具,它非常有用,可以在处理文本和字符串时快速地查找、替换、验证和提取特定的模式和数据。本专题提供java正则表达式语法的相关文章、下载和专题,供大家免费下载体验。

724

2023.07.05

java自学难吗
java自学难吗

Java自学并不难。Java语言相对于其他一些编程语言而言,有着较为简洁和易读的语法,本专题为大家提供java自学难吗相关的文章,大家可以免费体验。

731

2023.07.31

java配置jdk环境变量
java配置jdk环境变量

Java是一种广泛使用的高级编程语言,用于开发各种类型的应用程序。为了能够在计算机上正确运行和编译Java代码,需要正确配置Java Development Kit(JDK)环境变量。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

396

2023.08.01

java保留两位小数
java保留两位小数

Java是一种广泛应用于编程领域的高级编程语言。在Java中,保留两位小数是指在进行数值计算或输出时,限制小数部分只有两位有效数字,并将多余的位数进行四舍五入或截取。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

398

2023.08.02

java基本数据类型
java基本数据类型

java基本数据类型有:1、byte;2、short;3、int;4、long;5、float;6、double;7、char;8、boolean。本专题为大家提供java基本数据类型的相关的文章、下载、课程内容,供大家免费下载体验。

445

2023.08.02

java有什么用
java有什么用

java可以开发应用程序、移动应用、Web应用、企业级应用、嵌入式系统等方面。本专题为大家提供java有什么用的相关的文章、下载、课程内容,供大家免费下载体验。

429

2023.08.02

java在线网站
java在线网站

Java在线网站是指提供Java编程学习、实践和交流平台的网络服务。近年来,随着Java语言在软件开发领域的广泛应用,越来越多的人对Java编程感兴趣,并希望能够通过在线网站来学习和提高自己的Java编程技能。php中文网给大家带来了相关的视频、教程以及文章,欢迎大家前来学习阅读和下载。

16881

2023.08.03

php源码安装教程大全
php源码安装教程大全

本专题整合了php源码安装教程,阅读专题下面的文章了解更多详细内容。

74

2025.12.31

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Git 教程
Git 教程

共21课时 | 2.3万人学习

Git版本控制工具
Git版本控制工具

共8课时 | 1.5万人学习

Git中文开发手册
Git中文开发手册

共0课时 | 0人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号