//-< TESTIREF.CPP >--------------------------------------------------*--------*// FastDB                    Version 1.0         (c) 1999  GARRET    *     ?  *// (Main Memory Database Management System)                          *   /\|  *//                                                                   *  /  \  *//                          Created:     12-Jan-99    K.A. Knizhnik  * / [] \ *//                          Last update: 14-Jan-99    K.A. Knizhnik  * GARRET *//-------------------------------------------------------------------*--------*// Test of reference integrity. temporary strings allocation and// index insert/remove operations//-------------------------------------------------------------------*--------*#include <stdio.h>#include "fastdb.h"USE_FASTDB_NAMESPACEconst int nRecords = 16*1024;const int nInsertedRecords = 20000;class Record {   public:    nat8 key;    nat8 ikey;    char const* value;    dbReference<Record>            ref;    dbArray< dbReference<Record> > iref;    dbArray< dbReference<Record> > refs;    dbArray< dbReference<Record> > irefs;    TYPE_DESCRIPTOR((KEY(key, HASHED|INDEXED),                      FIELD(ikey),                      FIELD(value),                      RELATION(ref, iref),                     RELATION(refs, irefs),                     RELATION(iref, ref),                     RELATION(irefs, refs)));};REGISTER(Record);int main() {    dbDatabase db;    dbReference<Record>* refs = new dbReference<Record>[nRecords];    if (db.open("testiref")) {         db.setConcurrency(0);        db_int8 inskey = 1999;        db_int8 remkey = 1999;        dbReference<Record> ref;        dbQuery q;        dbQuery q2;        Record rec;        char buf[256];        dbCursor<Record> cursor(dbCursorForUpdate);        q="key=",remkey,          "and (ref is null or ref.key=ikey and current in ref.iref)"          "and not exists i:(current not in refs[i].irefs)";        q2="ref=",ref,"or",ref,"in refs or",ref,"in iref or",ref,"in irefs or"           " lower(value) <> string(key)+'.'";        time_t start = time(NULL);        int i, n = 1, p = 0, j, k, l, m = 0;        sprintf(buf, INT8_FORMAT ".", inskey);        rec.ikey = rec.key = inskey;            rec.value = buf;        ref = insert(rec);        cursor.at(ref);        cursor->ref = ref;        cursor->iref.resize(1);        cursor->iref.putat(0, ref);        refs[p++] = ref;        cursor.update();        for (i = 0; i < nInsertedRecords; i++) {             if (n == nRecords) {                int s = cursor.select(q);                assert(s == 1);                assert(refs[p] == cursor.currentId());                ref = cursor.currentId();                cursor.remove();                remkey = (3141592621u*nat8(remkey) + 2718281829u) % 1000000007u;                s = cursor.select(q2);                assert(s == 0);                refs[p] = null;            }            inskey = (3141592621u*nat8(inskey) + 2718281829u) % 1000000007u;            rec.key = inskey;            sprintf(buf, INT8_FORMAT ".", inskey);            ref = refs[nat8(inskey) % n];            if (ref != null) {                 rec.ikey = cursor.at(ref)->key;                rec.ref = ref;            }            j = (int(inskey) >> 16) & 0xF;            k = 0;            rec.refs.resize(0);            while (--j >= 0) {                 ref = refs[nat8(inskey >> j) % n];                if (ref != null) {                     for (l = 0; l < k && rec.refs[l] != ref; l++);                    if (l == k) {                         rec.refs.resize(++k);                        rec.refs.putat(l, ref);                    }                }            }            refs[p++] = insert(rec);            p &= nRecords - 1;            if (n < nRecords) {                n += 1;            }            if (i >= m) {                 printf("Proceed %d records...\r", i);                fflush(stdout);                m = i + 100;            }        }        printf("Elapsed time for %d record: %d seconds\n",                nInsertedRecords, int(time(NULL) - start));        db.close();        return EXIT_SUCCESS;    } else {         printf("Failed to open database\n");        return EXIT_FAILURE;    }}