Method multiDbInsertFindTest

unittests/env.cpp:312–358

  }

  void multiDbInsertFindTest() {
    const int MAX_DB = 5;
    const int MAX_ITEMS = 300;
    ups_db_t *db[MAX_DB];

    BaseFixture bf;
    bf.create_env(m_flags);

    for (int i = 0; i < MAX_DB; i++) {
      REQUIRE(0 == ups_env_create_db(bf.env, &db[i], (uint16_t)i + 1, 0, 0));

      for (int j = 0; j < MAX_ITEMS; j++) {
        int value = j * (i + 1);
        ups_key_t key = ups_make_key(&value, sizeof(value));
        ups_record_t rec = ups_make_record(&value, sizeof(value));
        REQUIRE(0 == ups_db_insert(db[i], 0, &key, &rec, 0));
      }
    }

    for (int i = 0; i < MAX_DB; i++) {
      for (int j = 0; j < MAX_ITEMS; j++) {
        int value = j * (i + 1);
        ups_key_t key = ups_make_key(&value, sizeof(value));
        ups_record_t rec = {0};

        REQUIRE(0 == ups_db_find(db[i], 0, &key, &rec, 0));
        REQUIRE(value == *(int *)rec.data);
        REQUIRE((uint16_t)sizeof(value) == rec.size);
      }
    }

    if (NOTSET(m_flags, UPS_IN_MEMORY)) {
      for (int i = 0; i < MAX_DB; i++) {
        REQUIRE(0 == ups_db_close(db[i], 0));
        REQUIRE(0 == ups_env_open_db(bf.env, &db[i], (uint16_t)i + 1, 0, 0));
        for (int j = 0; j < MAX_ITEMS; j++) {
          int value = j * (i + 1);
          ups_key_t key = ups_make_key(&value, sizeof(value));
          ups_record_t rec = {0};

          REQUIRE(0 == ups_db_find(db[i], 0, &key, &rec, 0));
          REQUIRE(value == *(int *)rec.data);
          REQUIRE((uint16_t)sizeof(value) == rec.size);
        }
      }
    }
  }

  void multiDbInsertFindExtendedTest() {
    const int MAX_DB = 5;