|| || || || || ||

---

AnnotationTableSetRepository.h

Go to the documentation of this file.

#ifndef Impala_Persistency_AnnotationTableSetRepository_h
#define Impala_Persistency_AnnotationTableSetRepository_h

#include "Persistency/RepositoryDispatcher.h"
#include "Persistency/RepositoryStub.h"
#include "Core/Table/AnnotationTableSet.h"
#include "Persistency/AnnotationTableSetLocator.h"
#include "Persistency/KeywordListRepository.h"
#include "Persistency/AnnotationTableRepository.h"

namespace Impala
{
namespace Persistency
{


class AnnotationTableSetRepository
    : public RepositoryDispatcher<AnnotationTableSetLocator,
                                  Core::Table::AnnotationTableSet,
                                  RepositoryStub,
                                  RepositoryStub>
{
public:

    typedef Core::Table::AnnotationTableSet AnnotationTableSet;
    typedef Core::Table::AnnotationTable AnnotationTable;
    typedef Core::Table::KeywordList KeywordList;

    bool
    Exists(const AnnotationTableSetLocator& loc)
    {
        KeywordListLocator keyListLoc(loc, loc.GetConceptSet());
        if (!KeywordListRepository().Exists(keyListLoc))
            return false;
        KeywordList keyList = *(KeywordListRepository().Get(keyListLoc));

        int nrFound = 0;
        AnnotationTableLocator tabLoc(loc, loc.GetQuidClass(),
                                      loc.GetConceptSet(), "dummy");
        for (int i=0 ; i<keyList.size() ; i++)
        {
            tabLoc.SetKeyword(keyList[i]);
            if (AnnotationTableRepository().Exists(tabLoc))
                nrFound++;
        }
        if (nrFound == 0)
            return false;
        return true;
    }

    AnnotationTableSet*
    Get(const AnnotationTableSetLocator& loc)
    {
        KeywordListLocator keyListLoc(loc, loc.GetConceptSet());
        KeywordList keyList = *(KeywordListRepository().Get(keyListLoc));
        if (keyList.size() == 0)
        {
            ILOG_ERROR("Could find keywords");
            return 0;
        }

        AnnotationTableSet* res = new AnnotationTableSet();
        int nrFound = 0;
        AnnotationTableLocator tabLoc(loc, loc.GetQuidClass(),
                                      loc.GetConceptSet(), "dummy");
        for (int i=0 ; i<keyList.size() ; i++)
        {
            tabLoc.SetKeyword(keyList[i]);
            AnnotationTable* table = 0;
            if (AnnotationTableRepository().Exists(tabLoc))
                table = AnnotationTableRepository().Get(tabLoc);
            else
                ILOG_WARN("Table for " << keyList[i] << " doesn't exist");
            if (table)
                nrFound++;
            else
                table = new AnnotationTable(keyList[i], 0);
            res->Add(table);
        }
        if (nrFound == 0)
            ILOG_ERROR("No tables found");
        return res;
    }

    void
    Add(const AnnotationTableSetLocator& loc, AnnotationTableSet* tSet)
    {
        KeywordListLocator keyListLoc(loc, loc.GetConceptSet());
        if (!KeywordListRepository().Exists(keyListLoc))
        {
            KeywordList keys = tSet->GetLabels();
            KeywordListRepository().Add(keyListLoc, &keys);
        }
        for (int i=0 ; i<tSet->Size() ; i++)
        {
            AnnotationTable* tab = tSet->GetTable(i);
            if (tab->Size() == 0)
                continue;
            //int qClass = tab->GetQuidClass();
            int qClass = loc.GetQuidClass();
            if (qClass == QUID_CLASS_UNKNOWN)
                qClass = tab->GetQuidClass();
            if (qClass != tab->GetQuidClass())
                ILOG_WARN("Locator and Table have different QuidClass");
            AnnotationTableLocator tabLoc(loc, qClass, loc.GetConceptSet(),
                                          tab->GetLabel());
            AnnotationTableRepository().Add(tabLoc, tab);
        }
    }

    void
    Delete(const AnnotationTableSetLocator& loc)
    {
        KeywordListLocator keyListLoc(loc, loc.GetConceptSet());
        if (!KeywordListRepository().Exists(keyListLoc))
            return;

        KeywordList keyList = *(KeywordListRepository().Get(keyListLoc));
        AnnotationTableLocator tabLoc(loc, loc.GetQuidClass(),
                                      loc.GetConceptSet(), "dummy");
        for (int i=0 ; i<keyList.size() ; i++)
        {
            tabLoc.SetKeyword(keyList[i]);
            AnnotationTableRepository().Delete(tabLoc);
        }
        KeywordListRepository().Delete(keyListLoc);
    }

    void
    Sync(const AnnotationTableSetLocator& loc, AnnotationTableSet* tSet)
    {
        if (!Exists(loc)) // Todo: add a check in timestamp etc.
            Add(loc, tSet);
    }

    void
    Replace(const AnnotationTableSetLocator& loc, AnnotationTableSet* tSet)
    {
        Delete(loc);
        Add(loc, tSet);
    }

private:

    ILOG_VAR_DEC;

};

ILOG_VAR_INIT(AnnotationTableSetRepository, Impala.Persistency);

} // namespace Persistency
} // namespace Impala

#endif

---