Golang小白一枚，正在不断学习积累知识，现将学习到的知识记录一下，也是将我的所得分享给大家！而今天这篇文章《安装链码后尝试查询状态数据库时出现 Hyperledger 错误》带大家来了解一下##content_title##，希望对大家的知识积累有所帮助，从而弥补自己的不足，助力实战开发！

这只是我的 chaincod 包的摘录，但我使用函数 listdoctorpermissions 来查询资产后的状态数据库，在我的例子中是具有以下结构的权限：

type permission struct {
    permissionid    string `json:"permissionid"`
    datacategory    string `json:"datacategory"`
    patientid       string `json:"patientid"`
    doctorid        string `json:"doctorid"`
    right           string `json:"right"`
    from            string `json:"from"`
    to              string `json:"to"`
}

在部署链代码的过程中，我在最后运行查询来测试链代码，但出现错误：

error: endorsement failure during query. response: status:500 message:"error handling success response. value did not match schema:\n1. return: invalid type. expected: array, given: string"

这就是我调用链代码的方式：

peer chaincode query -c mychannel -n permissions -c '{"args":["listdoctorpermissions", "doctor1"]}'

在运行查询之前，我在状态数据库中创建了一个权限，其中 doctorid 为“doctor1”，因此在数据库（couchdb）中查找复合密钥和条目应该不会有问题。

// List all Permissions given to a doctor
func (s *SmartContract) ListDoctorPermissions(ctx contractapi.TransactionContextInterface, doctorId string) ([]byte, error) {
    doctorIterator, err := ctx.GetStub().GetStateByPartialCompositeKey("permissionId", []string{doctorId})
    if err != nil {
        return nil, err
    }
    fmt.Printf("the doctor Iterator is: %s", doctorIterator)

    defer doctorIterator.Close()

    var dataCategory string
    var patientId string
    var permissionId string

    var permissions []byte
    bArrayPermissionAlreadyWritten := false

    for doctorIterator.HasNext() {
        responseRange, err := doctorIterator.Next()
        if err != nil {
            return nil, err
        }

        objectType, compositeKeyParts, err := ctx.GetStub().SplitCompositeKey(responseRange.Key)
        if err != nil {
            return nil, err
        }
        fmt.Printf("the objectType is: %s", objectType)

        dataCategory = compositeKeyParts[1]
        patientId = compositeKeyParts[2]
        permissionId = doctorId + dataCategory + patientId
        fmt.Printf("the compositeKeyParts are: %s", compositeKeyParts[0], compositeKeyParts[1], compositeKeyParts[2])

        permissionAsBytes, err := ctx.GetStub().GetState(permissionId)
        if err != nil {
            return nil, err
        }

        if bArrayPermissionAlreadyWritten == true {
            newBytes := append([]byte(","), permissionAsBytes...)
            permissions = append(permissions, newBytes...)
        } else {
            permissions = append(permissions, permissionAsBytes...)
            fmt.Print(permissions)
        }

        fmt.Printf("Found a asset for index : %s asset id : ", objectType, compositeKeyParts[0], compositeKeyParts[1], compositeKeyParts[2])
        bArrayPermissionAlreadyWritten = true

    }

    permissions = append(permissions, []byte("]")...)
    fmt.Print(permissions)
    return permissions, nil
}

解决方案

我已经运行了上面提供的代码，您的评论是正确的，问题似乎源于使用 []byte 作为返回类型。我不完全确定为什么会发生这种情况，因为这应该是有效的返回类型。我会进一步研究这个问题，因为它可能是一个错误。

通过将返回类型转换为 string 并返回 string(permissions) ，我能够正确返回数据

我在这样做时注意到，您的代码正在基于 getstate 字节构建一个字节数组。因此，另一个选择是将 json.unmarshal 来自 get 状态的字节调用到 permission 结构中，并将其附加到数组中。然后，您可以将返回类型设置为 []permission。

我现在建议您采用字符串或权限数组方法，因为我将不得不研究使用 []byte 作为返回类型时发生的情况。

示例：

字符串：

// list all permissions given to a doctor
func (s *smartcontract) listdoctorpermissions(ctx contractapi.transactioncontextinterface, doctorid string) (string, error) {
    doctoriterator, err := ctx.getstub().getstatebypartialcompositekey("permissionid", []string{doctorid})
    if err != nil {
        return "", err
    }
    fmt.printf("the doctor iterator is: %s", doctoriterator)

    defer doctoriterator.close()

    var datacategory string
    var patientid string
    var permissionid string

    var permissions []byte
    barraypermissionalreadywritten := false

    for doctoriterator.hasnext() {
        responserange, err := doctoriterator.next()
        if err != nil {
            return "", err
        }

        objecttype, compositekeyparts, err := ctx.getstub().splitcompositekey(responserange.key)
        if err != nil {
            return "", err
        }
        fmt.printf("the objecttype is: %s", objecttype)

        datacategory = compositekeyparts[1]
        patientid = compositekeyparts[2]
        permissionid = doctorid + datacategory + patientid
        fmt.printf("the compositekeyparts are: %s", compositekeyparts[0], compositekeyparts[1], compositekeyparts[2])

        permissionasbytes, err := ctx.getstub().getstate(permissionid)
        if err != nil {
            return "", err
        }

        if barraypermissionalreadywritten == true {
            newbytes := append([]byte(","), permissionasbytes...)
            permissions = append(permissions, newbytes...)
        } else {
            permissions = append(permissions, permissionasbytes...)
            fmt.print(permissions)
        }

        fmt.printf("found a asset for index : %s asset id : ", objecttype, compositekeyparts[0], compositekeyparts[1], compositekeyparts[2])
        barraypermissionalreadywritten = true

    }

    permissions = append(permissions, []byte("]")...)
    fmt.print(permissions)
    return string(permissions), nil
}

[]权限：

// List all Permissions given to a doctor
func (s *SmartContract) ListDoctorPermissions(ctx contractapi.TransactionContextInterface, doctorId string) ([]Permission, error) {
    doctorIterator, err := ctx.GetStub().GetStateByPartialCompositeKey("permissionId", []string{doctorId})
    if err != nil {
        return nil, err
    }
    fmt.Printf("the doctor Iterator is: %s", doctorIterator)

    defer doctorIterator.Close()

    var dataCategory string
    var patientId string
    var permissionId string

    var permissions []Permission

    for doctorIterator.HasNext() {
        responseRange, err := doctorIterator.Next()
        if err != nil {
            return nil, err
        }

        objectType, compositeKeyParts, err := ctx.GetStub().SplitCompositeKey(responseRange.Key)
        if err != nil {
            return nil, err
        }
        fmt.Printf("the objectType is: %s", objectType)

        dataCategory = compositeKeyParts[1]
        patientId = compositeKeyParts[2]
        permissionId = doctorId + dataCategory + patientId
        fmt.Printf("the compositeKeyParts are: %s", compositeKeyParts[0], compositeKeyParts[1], compositeKeyParts[2])

        permissionAsBytes, err := ctx.GetStub().GetState(permissionId)
        if err != nil {
            return nil, err
        }

        foundPermission := new(Permission)

        err = json.Unmarshal(permissionAsBytes, foundPermission)

        if err != nil {
            return nil, err
        }

        permissions = append(permissions, *foundPermission)
    }

    fmt.Printf("Permissions %v", permissions)

    return permissions, nil
}

今天关于《安装链码后尝试查询状态数据库时出现 Hyperledger 错误》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！