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

富查询的使用

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

认识第一个富查询语句

富查询语句是一种特定的json格式，以下所示：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.")
	}
}

测试使用了couchDB的链码

MockStub测试不能支持使用了couchDB的链码，所以若是须要测试富查询的相关函数是否正确，须要模拟搭建一套fabric网络，peer使用dev调试模式，对链码进行实时调式并测试。相关说明请见
Hyperledger Fabric学习（十）智能合约（链码）devplat工具测试
app

使用devplat搭建fabric平台，并安装实例化部署好first_cc链码
调用UserQueryByCoin方法查询结果