Tanl Linguistic Pipeline

search/ixe/Common/DynamicTable.cpp

/*
**      IXE
**      Common/DynamicTable.cpp: generic database tables
** ----------------------------------------------------------------------
**      Copyright (c) 2000  Ideare SpA. All rights reserved.
**      Copyright (c) 2000  Giuseppe Attardi (attardi@di.unipi.it).
** ----------------------------------------------------------------------
**
**  This file is part of IXE.
**
**  IXE is free software; you can redistribute it and/or modify it
**  under the terms of the GNU General Public License, version 3,
**  as published by the Free Software Foundation.
**
**  IXE is distributed in the hope that it will be useful,
**  but WITHOUT ANY WARRANTY; without even the implied warranty of
**  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
**  GNU General Public License for more details.
**
**  You should have received a copy of the GNU General Public License
**  along with this program.  If not, see <http://www.gnu.org/licenses/>.
**  ----------------------------------------------------------------------
*/

//local
#include "Common/table.h"
#include "include/error.h"

namespace IXE {
using namespace std;

bool DynamicTable::insert(AnyObject* obj)
{
  Size recordSize = metaClass->recordSize(obj);
  if (realloc_record(row, recordSize))
    throw MemoryError("Out of memory");
  DocID docID = noDocID;

  // prepare record
  byte* field = (byte*)row.data;
  Field* fd;
  vector<Item*>::const_iterator item = obj->values.begin();
  for (fd = metaClass->fields(); fd; fd = fd->next) {
    byte* src = (*item++)->value();
    field = fd->store(field, src);
    // save key in key.data
    if (fd->indexType == Field::primary) {// FIXME: handle Field::autoincrement
      docID = *(DocID*)src;
#     ifndef noBIGENDIAN_KEYS
      key.size = fd->storeKey((byte*)key.data, (byte*)&docID);
#     else
      byte* keyField = (byte*)key.data;
      keyField = fd->store(keyField, src);
      key.size = keyField - (byte*)key.data;
#     endif
    }
  }
  row.size = (Size)(field - (byte*)row.data);

  // We must ensure locking while we remove the old object and insert the
  // new one.
  if (!tcbdbtranbegin(primary))
    return false;

  // prepare key
  key.size = primaryField->storeKey((byte*)key.data,
                                    FieldOf(&obj, primaryField));
  int sp;
  byte* oldData = (byte*)tcbdbget3(primary, key.data, key.size, &sp);
  if (oldData) {
    AnyObject old;
    fetch((byte*)&old, oldData);
    if ((old == *obj) ||
        // inserting object with same key, when indexing fulltext and not
        // in incremental mode would produce wrong posting lists.
        (nFulltext && isNew)) {
      free(oldData);
      // clear object, to avoid problems with its destructor
      old._clear();
      return true;
    }
    removeSecondary(old);       // key set earlier
    free(oldData);
    nRows--;
    // clear object, to avoid problems with its destructor
    old._clear();
  }

  if (fulltextIndexer && fulltextIndexer->isUpdated(docID)) {
    // already scheduled for replacement
    tcbdbtrancommit(primary);
    return true;
  }

  // handle fulltext fields: readers may fill some fields in obj
  if (fulltextIndexer) {        // merge() sets this to 0
    // use obj->metaClass() to allow for objects having specialized MetaClass
    for (Field* fd = obj->metaClass()->fields(); fd != 0; fd = fd->next)
      if (fd->indexType == Field::fulltext)
        fulltextIndexer->add((byte*)obj, fd);
    // now add index for merged fields
    for (Field* fd = obj->metaClass()->fields(); fd != 0; fd = fd->next)
      if (fd->indexType == Field::fulltextMerged)
        fulltextIndexer->add((byte*)obj, fd);
  }
  insertRow(obj);
  nRows++;
  tcbdbtrancommit(primary);
  return oldData != 0;
}

} // namespace IXE

 

Copyright © 2005-2011 G. Attardi. Generated on 3 Mar 2011 by doxygen 1.6.1.