Method averageOnRecordsTest

unittests/uqi.cpp:1177–1206

  }

  void averageOnRecordsTest() {
    double sum = 0;
    double pred = 0;
    int i = 0;

    // insert a few keys
    for (double d = 0; d < 10000; d++, i++) {
      ups_key_t key = ups_make_key(&d, sizeof(d));
      ups_record_t record = ups_make_record(&i, sizeof(i));
      REQUIRE(0 == ups_db_insert(db, 0, &key, &record, 0));
      sum += i;
      if (i < 5000)
        pred += i;
    }

    ResultProxy rp;
    REQUIRE(0 == uqi_select(env, "AVERAGE($record) from database 1",
                            &rp.result));
    rp.require("AVERAGE", UPS_TYPE_REAL64, sum / 10000.0)
      .close();

    uqi_plugin_t record_plugin = {0};
    record_plugin.name = "record_pred";
    record_plugin.type = UQI_PLUGIN_PREDICATE;
    record_plugin.pred = record_predicate;
    REQUIRE(0 == uqi_register_plugin(&record_plugin));
    REQUIRE(0 == uqi_select(env, "AVERAGE($record) from database 1 where "
                            "record_pred($record)", &rp.result));
    rp.require("AVERAGE", UPS_TYPE_REAL64, pred / 5000.0);
  }

  void pluginOnRecordsTest() {
    uint64_t sum = 0;