Состояние Corda persiste с использованием файла конфигурации - PullRequest
Новая
       7

Состояние Corda persiste с использованием файла конфигурации

0 голосов
/ 19 ноября 2018

Я использую приведенный ниже код для хранения объекта IOU в базе данных. 

return when (schema) {
    is IOUSchemaV1 -> IOUSchemaV1.PersistentIOU(
        this.lender.name.toString(),
        this.borrower.name.toString(),
        this.value,
        this.externalRef,
        this.linearId.id
)

Я хотел бы знать, возможно ли определить логику постоянства в файле конфигурации (аналогично JPA с использованием несколькихсхемы базы данных ), так что мне легко определить постоянную логику для нескольких объектов / таблиц.

1 Ответ

0 голосов
/ 20 ноября 2018

Действительно возможно определить постоянную логику внутри CorDapp. Состояние, которое вы хотите сохранить, должно реализовывать интерфейс Queryable State, для которого потребуются два метода: supportSchemas () и generateMappedObject ().

Методы supportSchemas будут определять, какие классы схемы следует передавать в метод generateMappedObject. Затем метод generateMappedObject (из которого вы включили фрагмент) создаст представление данных для сохранения. 

   @Override
    public Iterable<MappedSchema> supportedSchemas() {
        return ImmutableList.of(new TokenSchemaV1());
    }

    @Override
    public PersistentState generateMappedObject(MappedSchema schema) {
        if (schema instanceof TokenSchemaV1) {
            return new TokenSchemaV1.PersistentToken(
                    this.getOwner().getName().toString(),
                    this.getIssuer().getName().toString(),
                    this.getAmount(),
                    this.linearId.getId(),
                    this.getListOfPersistentChildTokens()
            );
        } else {
            throw new IllegalArgumentException("Unrecognised schema $schema");
        }
    }

Представление, созданное с помощью метода generateMappedObject, передается в ORM и сохраняется в базе данных, как указано в аннотациях JPA в схеме. См. Фрагмент кода ниже для примера класса схемы в Java. Фрагмент также демонстрирует, как можно создать несколько таблиц для коллекций и вложенных коллекций. 

/**
 * An IOUState schema.
 */

@CordaSerializable
public class TokenSchemaV1 extends MappedSchema {

    public TokenSchemaV1() {
        super(TokenSchema.class, 1, ImmutableList.of(PersistentToken.class, PersistentChildToken.class, PersistentGrandChildToken.class));
    }

    @Entity
    @Table(name = "token_states")
    public static class PersistentToken extends PersistentState {
        @Column(name = "owner") private final String owner;
        @Column(name = "issuer") private final String issuer;
        @Column(name = "amount") private final int amount;
        @Column(name = "linear_id") public final UUID linearId;
        @OneToMany(cascade = CascadeType.PERSIST)
        @JoinColumns({
                @JoinColumn(name = "output_index", referencedColumnName = "output_index"),
                @JoinColumn(name = "transaction_id", referencedColumnName = "transaction_id"),
        })
        private final List<PersistentChildToken> listOfPersistentChildTokens;

        public PersistentToken(String owner, String issuer, int amount, UUID linearId, List<PersistentChildToken> listOfPersistentChildTokens) {
            this.owner = owner;
            this.issuer = issuer;
            this.amount = amount;
            this.linearId = linearId;
            this.listOfPersistentChildTokens = listOfPersistentChildTokens;
        }

        // Default constructor required by hibernate.
        public PersistentToken() {
            this.owner = "";
            this.issuer = "";
            this.amount = 0;
            this.linearId = UUID.randomUUID();
            this.listOfPersistentChildTokens = null;
        }

        public String getOwner() {
            return owner;
        }

        public String getIssuer() {
            return issuer;
        }

        public int getAmount() {
            return amount;
        }

        public UUID getLinearId() {
            return linearId;
        }

        public List<PersistentChildToken> getChildTokens() { return listOfPersistentChildTokens; }
    }

    @Entity
    @CordaSerializable
    @Table(name = "token_child_states")
    public static class PersistentChildToken {
        @Id
        private final UUID Id;
        @Column(name = "owner")
        private final String owner;
        @Column(name = "issuer")
        private final String issuer;
        @Column(name = "amount")
        private final int amount;
        @Column(name = "child_proof")
        private final String childProof;
        @ManyToOne(targetEntity = PersistentToken.class)
        private final TokenState persistentToken;
        @OneToMany(cascade = CascadeType.PERSIST)
        @JoinColumn(name = "parent_linear_id", referencedColumnName = "Id")
        private final List<PersistentGrandChildToken> listOfPersistentGrandChildTokens;


        public PersistentChildToken(String owner, String issuer, int amount, List<PersistentGrandChildToken> listOfPersistentGrandChildTokens) {
            this.Id = UUID.randomUUID();
            this.owner = owner;
            this.issuer = issuer;
            this.amount = amount;
            this.persistentToken = null;
            this.childProof = "I am a child";
            this.listOfPersistentGrandChildTokens = listOfPersistentGrandChildTokens;
        }

        // Default constructor required by hibernate.
        public PersistentChildToken() {
            this.Id = UUID.randomUUID();
            this.owner = "";
            this.issuer = "";
            this.amount = 0;
            this.persistentToken = null;
            this.childProof = "I am a child";
            this.listOfPersistentGrandChildTokens = null;
        }

        public UUID getId() {
            return Id;
        }

        public String getOwner() {
            return owner;
        }

        public String getIssuer() {
            return issuer;
        }

        public int getAmount() {
            return amount;
        }

        public TokenState getPersistentToken() {
            return persistentToken;
        }



    }

    @Entity
    @CordaSerializable
    @Table(name = "token_grand_child_states")
    public static class PersistentGrandChildToken {
        @Id
        private final UUID Id;
        @Column(name = "owner")
        private final String owner;
        @Column(name = "issuer")
        private final String issuer;
        @Column(name = "amount")
        private final int amount;
        @Column(name = "child_proof")
        private final String childProof;
        @ManyToOne(targetEntity = PersistentChildToken.class)
        private final TokenSchemaV1.PersistentChildToken persistentChildToken;

        public PersistentGrandChildToken(String owner, String issuer, int amount) {
            this.Id = UUID.randomUUID();
            this.owner = owner;
            this.issuer = issuer;
            this.amount = amount;
            this.persistentChildToken = null;
            this.childProof = "I am a child";
        }

        // Default constructor required by hibernate.
        public PersistentGrandChildToken() {
            this.Id = UUID.randomUUID();
            this.owner = "";
            this.issuer = "";
            this.amount = 0;
            this.persistentChildToken = null;
            this.childProof = "I am a child";
        }

        public UUID getId() {
            return Id;
        }

        public String getOwner() {
            return owner;
        }

        public String getIssuer() {
            return issuer;
        }

        public int getAmount() {
            return amount;
        }

        public TokenSchemaV1.PersistentChildToken getPersistentChildToken() {
            return persistentChildToken;
        }
    }

}
...