如何在corda中实现Queryable状态？

data class MyState(val data: String) : ContractState, QueryableState {
    // 状态属性和构造函数
    // ...
    
    override fun supportedSchemas(): Iterable<MappedSchema> {
        return listOf(MySchemaV1)
    }

    override fun generateMappedObject(schema: MappedSchema): PersistentState {
        return when (schema) {
            is MySchemaV1 -> MySchemaV1.PersistentMyState(data)
            else -> throw IllegalArgumentException("Unrecognized schema $schema")
        }
    }

    override fun supportedQueryNames(): Iterable<String> {
        return listOf("getDataByValue")
    }

    override fun generateMappedObject(schema: MappedSchema, params: QueryCriteria): Iterable<AbstractParty> {
        return when (params) {
            is QueryCriteria.VaultCustomQueryCriteria -> {
                val dataValue = params.constraints.singleOrNull()?.values?.singleOrNull()
                if (dataValue != null) {
                    val results = mutableListOf<AbstractParty>()
                    // 查询数据并返回结果
                    // ...
                    return results
                } else {
                    throw IllegalArgumentException("Invalid query criteria: $params")
                }
            }
            else -> throw IllegalArgumentException("Unrecognized query criteria $params")
        }
    }
}

object MySchemaV1 : MappedSchema(schemaFamily = MySchema.javaClass, version = 1, mappedTypes = listOf(PersistentMyState::class.java)) {
    @Entity
    @Table(name = "my_states")
    class PersistentMyState(
        @Column(name = "data")
        var data: String
    ) : PersistentState() {
        // 模式属性和构造函数
        // ...
    }
}

database {
    # ...
    transactionIsolationLevel: READ_COMMITTED
    schema: [
        {
            name: "my_schema",
            tables: [
                "my_states"
            ]
        }
    ]
}

override fun generateMappedObject(schema: MappedSchema, params: QueryCriteria): Iterable<AbstractParty> {
    return when (params) {
        is QueryCriteria.VaultCustomQueryCriteria -> {
            val dataValue = params.constraints.singleOrNull()?.values?.singleOrNull()
            if (dataValue != null) {
                val results = mutableListOf<AbstractParty>()
                // 查询数据并返回结果
                // ...
                return results
            } else {
                throw IllegalArgumentException("Invalid query criteria: $params")
            }
        }
        else -> throw IllegalArgumentException("Unrecognized query criteria $params")
    }
}

val queryCriteria = QueryCriteria.VaultCustomQueryCriteria(builder.equal(MySchemaV1.PersistentMyState::data, "someValue"))
val results = serviceHub.vaultService.queryBy<MyState>(queryCriteria).states