时间戳

首页 > 解决方案 > 在corda中检索特定状态

blockchain - 在corda中检索特定状态

问题描述

在我的 Corda 项目中，我需要根据状态类的某些特定字段检索特定状态，我为每个状态设置了唯一字段。如何在 Corda 中做到这一点？状态的实现如下：

@BelongsToContract(OfferContract.class)
public class OfferState implements LinearState {
    private final UniqueIdentifier linearID;
    private AnonymousParty sender;
    private AnonymousParty receiver;
    private final String policyID;
    private final double faceValue;
    private double offeredAmount;

    private boolean isActive;

    public OfferState(UniqueIdentifier linearID, AnonymousParty sender, AnonymousParty receiver, String policyID, double faceValue, double offeredAmount, boolean isActive) {
        this.linearID = linearID;
        this.sender = sender;
        this.receiver = receiver;
        this.policyID = policyID;
        this.faceValue = faceValue;
        this.offeredAmount = offeredAmount;
        this.isActive = isActive;
    }

    public UniqueIdentifier getLinearID() {
        return linearID;
    }

    public AnonymousParty getSender() {
        return sender;
    }

    public AnonymousParty getReceiver() {
        return receiver;
    }

    public String getPolicyID() {
        return policyID;
    }

    public double getFaceValue() {
        return faceValue;
    }

    public double getOfferedAmount() {
        return offeredAmount;
    }

    public boolean isActive() {
        return isActive;
    }

    @NotNull
    @Override
    public UniqueIdentifier getLinearId() {
        return linearID;
    }

    @NotNull
    @Override
    public List<AbstractParty> getParticipants() {
        return Arrays.asList(sender,receiver);
    }

    @Override
    public String toString() {
        return super.toString();
    }
}

我正在使用以下代码在 API 中查询，但是，在邮递员输出中显示空括号，如 []。

@GetMapping(value = "/getOfferWithID",headers = "Content-Type=application/x-www-form-urlencoded")
    private List<StateAndRef<OfferState>> getOfferWithID(HttpServletRequest request) throws IllegalArgumentException {
        String s  = request.getParameter("PolicyID");
        return proxy.vaultQuery(OfferState.class).getStates().stream().filter(it->it.getState().getData().getPolicyID().equalsIgnoreCase(s)).collect(Collectors.toList());
    }

你能告诉我，我如何在查询时过滤状态，这里出了什么问题？是否有任何直接查询方法以便我可以在 rpc 调用本身中对其进行过滤，或者我真的需要为它编写一个流程吗？

标签： blockchaincorda

解决方案

为了能够通过其属性之一查询您的状态，您必须：

  • 为您的状态创建自定义架构，请参见此处和此处获取示例。
  • 用于VaultCustomQueryCriteria查询您的属性policyId。VaultCustomQueryCriteria 在此处阅读（搜索该术语并查找示例代码）。

您当前的方法（使用.filter(it->it.getState().getData().getPolicyID().equalsIgnoreCase(s))）非常糟糕，本质上是您带来了所有状态的列表，然后过滤该列表。
当你的查询返回 1000,000 个状态时，你会怎么做？！您正在创建一个包含 1000,000 个条目的列表，然后遍历该列表以找到具有您的policyId!!! 这只会耗尽您的 Java 堆，减慢您的应用程序并使其崩溃。

始终通过在 Corda 中构建查询然后在数据库中运行它（使用我已经概述的方法）将搜索/查询委托给数据库，您当前正在做的是制作select * from some_table然后循环遍历所有结果，我的方法crafts select * from some_table where policyId = xxx，将返回一排。

推荐阅读