[go: up one dir, main page]

CN114138867A - 区块链多项查询方法、计算机设备和存储介质 - Google Patents

区块链多项查询方法、计算机设备和存储介质 Download PDF

Info

Publication number
CN114138867A
CN114138867A CN202111457961.1A CN202111457961A CN114138867A CN 114138867 A CN114138867 A CN 114138867A CN 202111457961 A CN202111457961 A CN 202111457961A CN 114138867 A CN114138867 A CN 114138867A
Authority
CN
China
Prior art keywords
query
item
contract
result
key
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Pending
Application number
CN202111457961.1A
Other languages
English (en)
Inventor
何正军
王志文
吴思进
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Hangzhou Fuzamei Technology Co Ltd
Original Assignee
Hangzhou Fuzamei Technology Co Ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Hangzhou Fuzamei Technology Co Ltd filed Critical Hangzhou Fuzamei Technology Co Ltd
Priority to CN202111457961.1A priority Critical patent/CN114138867A/zh
Publication of CN114138867A publication Critical patent/CN114138867A/zh
Pending legal-status Critical Current

Links

Images

Classifications

    • G—PHYSICS
    • G06—COMPUTING OR CALCULATING; COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
    • G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
    • G06F16/24—Querying
    • G06F16/245—Query processing
    • G06F16/2458—Special types of queries, e.g. statistical queries, fuzzy queries or distributed queries
    • G06F16/2471—Distributed queries
    • G—PHYSICS
    • G06—COMPUTING OR CALCULATING; COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
    • G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
    • G06F16/24—Querying
    • G06F16/248—Presentation of query results
    • G—PHYSICS
    • G06—COMPUTING OR CALCULATING; COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
    • G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
    • G06F16/25—Integrating or interfacing systems involving database management systems
    • G06F16/252—Integrating or interfacing systems involving database management systems between a Database Management System and a front-end application
    • G—PHYSICS
    • G06—COMPUTING OR CALCULATING; COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
    • G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
    • G06F16/27—Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor
    • G—PHYSICS
    • G06—COMPUTING OR CALCULATING; COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F9/00—Arrangements for program control, e.g. control units
    • G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
    • G06F9/46—Multiprogramming arrangements
    • G06F9/54—Interprogram communication
    • G06F9/547—Remote procedure calls [RPC]; Web services

Landscapes

  • Engineering & Computer Science (AREA)
  • Theoretical Computer Science (AREA)
  • Databases & Information Systems (AREA)
  • Physics & Mathematics (AREA)
  • General Engineering & Computer Science (AREA)
  • General Physics & Mathematics (AREA)
  • Data Mining & Analysis (AREA)
  • Software Systems (AREA)
  • Computational Linguistics (AREA)
  • Computing Systems (AREA)
  • Fuzzy Systems (AREA)
  • Mathematical Physics (AREA)
  • Probability & Statistics with Applications (AREA)
  • Information Retrieval, Db Structures And Fs Structures Therefor (AREA)

Abstract

本发明提供一种区块链多项查询方法、计算机设备和存储介质，该方法包括：配置支持一次性查询多项状态的第一查询接口；接收第一查询请求，解析第一查询请求以获得若干第一查询参数组；分别根据各第一查询参数组中的第一合约地址加载对应的第一合约并根据第一查询键进行查询以获得各第一单项查询结果；分别判断各第一单项查询结果的数据格式是否可读格式：否，则进行反序列化以获得第二单项查询结果；将可读格式的各第一单项查询结果和各第二单项查询结果打包生成第一多项查询结果并返回。本发明提升了查询效率，并减少了区块链节点接收的rpc请求次数。

Description

区块链多项查询方法、计算机设备和存储介质
技术领域
本申请涉及区块链技术领域，具体涉及一种区块链多项查询方法、计算机设备和存储介质。
背景技术
当前区块链系统中，发送一次查询请求只能查询一项状态数据，当需要查询多项数据时只能通过发送多次查询请求来完成查询，导致区块链节点在查询业务高峰期会接收到非常多的rpc请求、用户的查询效率也比较低。
发明内容
鉴于现有技术中的上述缺陷或不足，期望提供一种提升查询效率并减少区块链节点接收的rpc请求次数的区块链多项查询方法、计算机设备和存储介质。
第一方面，本发明提供一种适用于区块链节点的区块链多项查询方法，包括：
配置支持一次性查询多项状态的第一查询接口；其中，第一查询接口支持包括多项查询参数组的查询请求，查询参数组包括单项查询的合约地址和查询键；
接收第一查询请求，解析第一查询请求以获得若干第一查询参数组；
分别根据各第一查询参数组中的第一合约地址加载对应的第一合约并根据第一查询键进行查询以获得各第一单项查询结果；
分别判断各第一单项查询结果的数据格式是否可读格式：否，则进行反序列化以获得第二单项查询结果；
将可读格式的各第一单项查询结果和各第二单项查询结果打包生成第一多项查询结果并返回。
第二方面，本发明还提供一种计算机设备，包括一个或多个处理器和存储器，其中存储器包含可由该一个或多个处理器执行的指令以使得该一个或多个处理器执行根据本发明各实施例提供的区块链多项查询方法。
第三方面，本发明还提供一种存储有计算机程序的存储介质，该计算机程序使计算机执行根据本发明各实施例提供的区块链多项查询方法。
本发明诸多实施例提供的区块链多项查询方法、计算机设备和存储介质通过为区块链节点配置支持多项查询的查询接口，以及，解析调用该接口所生成的查询请求以获得多组查询参数组并分别根据每一组查询参数组进行查询，最终合并各项查询结果并返回，实现了支持通过一次查询请求完成多项查询，从而提升了查询效率，并减少了区块链节点接收的rpc请求次数。
附图说明
通过阅读参照以下附图所作的对非限制性实施例所作的详细描述，本申请的其它特征、目的和优点将会变得更明显：
图1为本发明一实施例提供的一种区块链多项查询方法的流程图。
图2为图1所示方法的一种优选实施方式的流程图。
图3为本发明一实施例提供的一种计算机设备的结构示意图。
具体实施方式
下面结合附图和实施例对本申请作进一步的详细说明。可以理解的是，此处所描述的具体实施例仅仅用于解释相关发明，而非对该发明的限定。另外还需要说明的是，为了便于描述，附图中仅示出了与发明相关的部分。
需要说明的是，在不冲突的情况下，本申请中的实施例及实施例中的特征可以相互组合。下面将参考附图并结合实施例来详细说明本申请。
图1为本发明一实施例提供的一种区块链多项查询方法的流程图。
如图1所示，在本实施例中，本发明提供一种适用于区块链节点的区块链多项查询方法，包括：
S11：配置支持一次性查询多项状态的第一查询接口；其中，第一查询接口支持包括多项查询参数组的查询请求，查询参数组包括单项查询的合约地址和查询键；
S13：接收第一查询请求，解析第一查询请求以获得若干第一查询参数组；
S15：分别根据各第一查询参数组中的第一合约地址加载对应的第一合约并根据第一查询键进行查询以获得各第一单项查询结果；
S17：分别判断各第一单项查询结果的数据格式是否可读格式：否，则进行反序列化以获得第二单项查询结果；
S19：将可读格式的各第一单项查询结果和各第二单项查询结果打包生成第一多项查询结果并返回。
以下以配置原本不支持多项查询的联盟链A，并在配置后在联盟链A中进行多项查询为例，对上述方法进行示例性的阐述。
首先，根据实际需求为联盟链A的若干节点(可以是一个节点、部分节点或全部节点)配置支持一次性查询多项状态的第一查询接口和执行步骤S13-S19的功能模块。
以节点A1为例，在步骤S11中，节点A1配置了上述第一查询接口和执行步骤S13-S19的功能模块。
具体地，第一查询接口支持包括多项查询参数组query_para_i的查询请求。
其中，i为查询参数组的索引号。
查询参数组query_para_i包括单项查询的两个参数：合约地址Contract_Address和查询键Key。
以用户甲的用户端需要进行10项查询为例，对于原有的联盟链A，用户甲的用户端必须生成10项查询请求并发送10次rpc请求；而对于通过步骤S11配置的联盟链A，用户甲的用户端只需调用第一查询接口生成包括10项查询参数组query_para_0-query_para_9的第一查询请求Q1，并通过1次rpc请求将第一查询请求Q1发送至节点A1。
在步骤S13中，节点A1接收第一查询请求Q1，解析Q1以获得查询参数组query_para_0-query_para_9。
在步骤S15中，节点A1分别根据10项查询参数组query_para_0-query_para_9进行10次单项查询。
例如，根据查询参数组query_para_0中的合约地址addr0加载合约a，并根据query_para_0中的查询键key0进行查询，获得单项查询结果r0；
根据查询参数组query_para_1中的合约地址addr1加载合约b，并根据query_para_1中的查询键key1进行查询，获得单项查询结果r1；
根据查询参数组query_para_2中的合约地址addr1加载合约b，并根据query_para_2中的查询键key2进行查询，获得单项查询结果r2；
……
根据查询参数组query_para_9中的合约地址addr7加载合约g，并根据query_para_9中的查询键key9进行查询，获得单项查询结果r9。
在步骤S17中，节点A1分别判断步骤S15获得的各单项查询结果r0-r9的数据格式是否可读格式。
例如，r0-r3、r5、r8-r9的数据格式是可读格式，而r4、r6、r7的数据格式并非可读格式，则节点A1分别对r4、r6、r7进行反序列化以获得r4’、r6’、r7’。
在步骤S19中，节点A1将可读格式的r0-r3、r4’、r5、r6’、r7’、r8-r9打包生成多项查询结果R1并返回给用户甲的用户端。
优选地，上述单项查询结果还包括查询结果的状态参数(true or false)，状态参数为true即查询成功，状态参数为false即查询失败(即，告知用户端查询失败，可以忽略对应的查询结果)。
上述实施例以区块链A为联盟链、用户甲的用户端需要进行10项查询为例，对图1所示的方法进行了示例性的阐述；在更多实施例中，图1所示的方法同样适用于公链等不同类型的区块链，以及，不同设备进行任意项数的多项查询，可实现相同的技术效果，而不以上述示例为限。
优选地，各第一合约包括go合约，第二单项查询结果的数据格式为proto-buffermessage格式。
图2为图1所示方法的一种优选实施方式的流程图。如图2所示，在一优选实施例中，上述方法还包括：
S10：将若干go合约的查询功能模块重定义为生成proto-buffer message格式的查询结果。
具体地，同样以上述联盟链A为例，当各第一单项查询结果和各第二单项查询结果统一为proto-buffer message格式时，将使得步骤S19的打包更为便利。
在一优选实施例中，各第一合约包括evm合约，上述根据第一查询键进行查询包括：
通过abi.encodeWithSignature对第一查询键进行序列化；
将序列化后的第一查询键输入统一的合约查询入口进行查询。
具体地，在本实施例中，evm合约的查询先通过abi.encodeWithSignature对第一查询键进行序列化，再通过统一的合约查询入口calls[i].target.call(calls[i].callData)]进行查询。
其中，calls[i].target为第i项查询的合约入口地址，calls[i].callData为通过abi.encodeWithSignature序列化后的第一查询键。
图3为本发明一实施例提供的一种计算机设备的结构示意图。
如图3所示，作为另一方面，本申请还提供了一种计算机设备，包括一个或多个中央处理单元(CPU)301，其可以根据存储在只读存储器(ROM)302中的程序或者从存储部分308加载到随机访问存储器(RAM)303中的程序而执行各种适当的动作和处理。在RAM303中，还存储有设备300操作所需的各种程序和数据。CPU301、ROM302以及RAM303通过总线304彼此相连。输入/输出(I/O)接口305也连接至总线304。
以下部件连接至I/O接口305：包括键盘、鼠标等的输入部分306；包括诸如阴极射线管(CRT)、液晶显示器(LCD)等以及扬声器等的输出部分307；包括硬盘等的存储部分308；以及包括诸如LAN卡、调制解调器等的网络接口卡的通信部分309。通信部分309经由诸如因特网的网络执行通信处理。驱动器310也根据需要连接至I/O接口305。可拆卸介质311，诸如磁盘、光盘、磁光盘、半导体存储器等等，根据需要安装在驱动器310上，以便于从其上读出的计算机程序根据需要被安装入存储部分308。
特别地，根据本公开的实施例，上述任一实施例描述的方法可以被实现为计算机软件程序。例如，本公开的实施例包括一种计算机程序产品，其包括有形地包含在机器可读介质上的计算机程序，计算机程序包含用于执行上述任一方法的程序代码。在这样的实施例中，该计算机程序可以通过通信部分309从网络上被下载和安装，和/或从可拆卸介质311被安装。
作为又一方面，本申请还提供了一种计算机可读存储介质，该计算机可读存储介质可以是上述实施例的装置中所包含的计算机可读存储介质；也可以是单独存在，未装配入设备中的计算机可读存储介质。计算机可读存储介质存储有一个或者一个以上程序，该程序被一个或者一个以上的处理器用来执行描述于本申请提供的方法。
附图中的流程图和框图，图示了按照本发明各种实施例的系统、方法和计算机程序产品的可能实现的体系架构、功能和操作。在这点上，流程图或框图中的每个方框可以代表一个模块、程序段、或代码的一部分，该模块、程序段、或代码的一部分包含一个或多个用于实现规定的逻辑功能的可执行指令。也应当注意，在有些作为替换的实现中，方框中所标注的功能也可以以不同于附图中所标注的顺序发生。例如，两个接连地表示的方框实际上可以基本并行地执行，它们有时也可以按相反的顺序执行，这根据所涉及的功能而定。也要注意的是，框图和/或流程图中的每个方框、以及框图和/或流程图中的方框的组合，可以通过执行规定的功能或操作的专用的基于硬件的系统来实现，或者可以通过专用硬件与计算机指令的组合来实现。
描述于本申请实施例中所涉及到的单元或模块可以通过软件的方式实现，也可以通过硬件的方式来实现。所描述的单元或模块也可以设置在处理器中，例如，各单元可以是设置在计算机或移动智能设备中的软件程序，也可以是单独配置的硬件装置。其中，这些单元或模块的名称在某种情况下并不构成对该单元或模块本身的限定。
以上描述仅为本申请的较佳实施例以及对所运用技术原理的说明。本领域技术人员应当理解，本申请中所涉及的发明范围，并不限于上述技术特征的特定组合而成的技术方案，同时也应涵盖在不脱离本申请构思的情况下，由上述技术特征或其等同特征进行任意组合而形成的其它技术方案。例如上述特征与本申请中公开的(但不限于)具有类似功能的技术特征进行互相替换而形成的技术方案。

Claims (6)

1.一种区块链多项查询方法，其特征在于，所述方法适用于区块链节点，所述方法包括：
配置支持一次性查询多项状态的第一查询接口；其中，所述第一查询接口支持包括多项查询参数组的查询请求，所述查询参数组包括单项查询的合约地址和查询键；
接收第一查询请求，解析所述第一查询请求以获得若干第一查询参数组；
分别根据各所述第一查询参数组中的第一合约地址加载对应的第一合约并根据第一查询键进行查询以获得各第一单项查询结果；
分别判断各所述第一单项查询结果的数据格式是否可读格式：否，则进行反序列化以获得第二单项查询结果；
将可读格式的各第一单项查询结果和各所述第二单项查询结果打包生成第一多项查询结果并返回。
2.根据权利要求1所述的方法，其特征在于，各所述第一合约包括go合约，所述第二单项查询结果的数据格式为proto-buffer message格式。
3.根据权利要求2所述的方法，其特征在于，所述方法还包括：
将若干go合约的查询功能模块重定义为生成proto-buffer message格式的查询结果。
4.根据权利要求1所述的方法，其特征在于，各所述第一合约包括evm合约，所述根据第一查询键进行查询包括：
通过abi.encodeWithSignature对第一查询键进行序列化；
将序列化后的第一查询键输入统一的合约查询入口进行查询。
5.一种计算机设备，其特征在于，所述设备包括：
一个或多个处理器；
存储器，用于存储一个或多个程序，
当所述一个或多个程序被所述一个或多个处理器执行时，使得所述一个或多个处理器执行如权利要求1-4中任一项所述的方法。
6.一种存储有计算机程序的存储介质，其特征在于，该程序被处理器执行时实现如权利要求1-4中任一项所述的方法。
CN202111457961.1A 2021-12-02 2021-12-02 区块链多项查询方法、计算机设备和存储介质 Pending CN114138867A (zh)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN202111457961.1A CN114138867A (zh) 2021-12-02 2021-12-02 区块链多项查询方法、计算机设备和存储介质

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN202111457961.1A CN114138867A (zh) 2021-12-02 2021-12-02 区块链多项查询方法、计算机设备和存储介质

Publications (1)

Publication Number Publication Date
CN114138867A true CN114138867A (zh) 2022-03-04

Family

ID=80386942

Family Applications (1)

Application Number Title Priority Date Filing Date
CN202111457961.1A Pending CN114138867A (zh) 2021-12-02 2021-12-02 区块链多项查询方法、计算机设备和存储介质

Country Status (1)

Country Link
CN (1) CN114138867A (zh)

Citations (9)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN109710859A (zh) * 2019-01-21 2019-05-03 北京字节跳动网络技术有限公司 数据查询方法和装置
CN110609679A (zh) * 2019-09-17 2019-12-24 腾讯科技（深圳）有限公司 数据处理方法、装置、计算机可读存储介质和计算机设备
CN110943911A (zh) * 2019-12-19 2020-03-31 北京轻元科技有限公司 基于protobuf的物联网高效数据传输方法
US20200133949A1 (en) * 2018-10-26 2020-04-30 Alibaba Group Holding Limited Data processing method, apparatus, and device
CN111259044A (zh) * 2020-01-15 2020-06-09 网易（杭州）网络有限公司 一种数据查询方法、装置、设备及介质
CN111782647A (zh) * 2020-05-29 2020-10-16 易联众信息技术股份有限公司 一种eos网络的区块数据存储方法、系统、介质及设备
CN112613866A (zh) * 2020-12-17 2021-04-06 中国工商银行股份有限公司 应用于区块链的数据访问方法和装置
WO2021129062A1 (zh) * 2019-12-27 2021-07-01 中国银联股份有限公司 数据查询方法、装置、设备、系统及介质
CN113094395A (zh) * 2021-03-19 2021-07-09 杭州复杂美科技有限公司 数据查询方法、计算机设备和存储介质

Patent Citations (9)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20200133949A1 (en) * 2018-10-26 2020-04-30 Alibaba Group Holding Limited Data processing method, apparatus, and device
CN109710859A (zh) * 2019-01-21 2019-05-03 北京字节跳动网络技术有限公司 数据查询方法和装置
CN110609679A (zh) * 2019-09-17 2019-12-24 腾讯科技（深圳）有限公司 数据处理方法、装置、计算机可读存储介质和计算机设备
CN110943911A (zh) * 2019-12-19 2020-03-31 北京轻元科技有限公司 基于protobuf的物联网高效数据传输方法
WO2021129062A1 (zh) * 2019-12-27 2021-07-01 中国银联股份有限公司 数据查询方法、装置、设备、系统及介质
CN111259044A (zh) * 2020-01-15 2020-06-09 网易（杭州）网络有限公司 一种数据查询方法、装置、设备及介质
CN111782647A (zh) * 2020-05-29 2020-10-16 易联众信息技术股份有限公司 一种eos网络的区块数据存储方法、系统、介质及设备
CN112613866A (zh) * 2020-12-17 2021-04-06 中国工商银行股份有限公司 应用于区块链的数据访问方法和装置
CN113094395A (zh) * 2021-03-19 2021-07-09 杭州复杂美科技有限公司 数据查询方法、计算机设备和存储介质

Similar Documents

Publication Publication Date Title
US9934276B2 (en) Systems and methods for fault tolerant, adaptive execution of arbitrary queries at low latency
CN110019080B (zh) 数据访问方法和装置
CN111061680B (zh) 一种数据检索的方法和装置
CN106202441A (zh) 基于关系型数据库的数据处理方法、装置和系统
US11243921B2 (en) Database expansion system, equipment, and method of expanding database
CN111538605B (zh) 一种分布式数据访问层中间件及命令执行方法和装置
WO2018035799A1 (zh) 数据查询方法、应用和数据库服务器、中间件及系统
CN108363741B (zh) 大数据统一接口方法、装置、设备及存储介质
CN111752939A (zh) 用于多个系统的数据处理方法、装置、计算机系统、介质
CN115617795A (zh) 一种数据库表的通用查询方法、装置及存储介质
CN114840520A (zh) 数据存储方法及装置
CN113094395B (zh) 数据查询方法、计算机设备和存储介质
CN113297274B (zh) 一种签收数据查询方法和系统
CN114138867A (zh) 区块链多项查询方法、计算机设备和存储介质
CN109062929A (zh) 一种查询任务通信方法及系统
CN110705935B (zh) 一种物流单据的处理方法和装置
CN113535768A (zh) 生产监控方法和装置
US8498957B2 (en) Optimal multi-factor evaluation in computing systems
CN114168634B (zh) 一种异构平台下分页并行查询方法及系统
CN113495747B (zh) 一种灰度发布方法和装置
CN115809176A (zh) 日志管理方法、装置、电子设备、介质和程序产品
CN114840372B (zh) 接口测试方法、装置、电子设备及计算机可读存储介质
CN114090626B (zh) 一种获取数据库数据的方法及装置
CN115048411B (zh) 数据处理方法、装置、系统、介质及程序产品
CN117827848B (zh) 哈希连接方法、装置、电子设备及存储介质

Legal Events

Date Code Title Description
PB01 Publication
PB01 Publication
SE01 Entry into force of request for substantive examination
SE01 Entry into force of request for substantive examination
WD01 Invention patent application deemed withdrawn after publication

Application publication date: 20220304

WD01 Invention patent application deemed withdrawn after publication