Hyperledger Fabric学习（十二）智能合约（链码）使用富查询

富查询的使用

链码中的数据存储都是基于K-V键值对的形式，一般来说，是保存在LevelDB中。但是目前Fabric支持链码使用couchDB进行存储数据、通过编写富查询的方式查询数据。

认识第一个富查询语句

富查询语句是一种特定的json格式，如下所示：

{
  "selector": {
    "coin": 100 
  }
}

selector对应一个列表，列表包含多个单元，每个单元匹配一个字段，譬如上述中匹配的是满足余额为100的User数据

在链码中实现富查询

在first_cc目录下，创建couchDB索引目录和索引文件

创建索引目录

mkdir -p META-INF/statedb/couchdb/indexes

创建基于coin字段的索引文件

touch META-INF/statedb/couchdb/indexes/indexCoin.json
给索引文件indexCoin.json添加如下内容

{ "index": { "fields": [ "coin" ] }, "ddoc": "indexCoinDoc", "name": "indexCoin", "type": "json" }
在first_cc.go文件中实现基于coin值进行富查询的UserQueryByCoin函数

// 基于coin值进行用户查询 func UserQueryByCoin(stub shim.ChaincodeStubInterface, args []string) pb.Response { // 判断参数个数 if len(args) != 1 { return shim.Error("args must be one") } // 编写富查询语句，根据coin值进行匹配查询 var queryString = fmt.Sprintf({"selector":{"coin": %v}}, args[0]) // 查询结果的变量定义 var users = make([]User, 0) // 富查询操作，返回一个迭代器 iterator, err := stub.GetQueryResult(queryString) if err != nil { fmt.Println(err.Error()) return shim.Error("data get failed: " + err.Error()) } // defer后面的操作是函数执行退出之前的会进行的操作，这里是关闭迭代器 defer iterator.Close()

// 循环获取迭代器中的值 for ; iterator.HasNext(); { resp, err := iterator.Next() if err != nil { fmt.Println(err.Error()) return shim.Error("data get failed: " + err.Error()) } // 将迭代器的值取出反序列化，存入查询结果中 var user User if err := json.Unmarshal(resp.Value, &user); err != nil { fmt.Println(err.Error()) return shim.Error("data unmarshal failed: " + err.Error()) } users = append(users, user) }

// 将查询结果序列化 data, err := json.Marshal(users) if err != nil { fmt.Println(err.Error()) return shim.Error("data marshal failed: " + err.Error()) } fmt.Println(string(data))

return shim.Success(data) }
在Invoke中添加函数调用

// 修改之前实现的Invoke()方法 func (t FirstChainCode) Invoke(stub shim.ChaincodeStubInterface) pb.Response { / 获取参数，分解为调用方法名，以及传入的参数列表然后根据具体的function，调用对应的之前写过的函数 */ function, args := stub.GetFunctionAndParameters() switch function { case "UserRegister": return UserRegister(stub, args) case "UserQuery": return UserQuery(stub, args) case "UserQueryByCoin": return UserQueryByCoin(stub, args) default: return shim.Error("no this function name.") } }