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

---

AnnotationTableRepositoryInMonet.h

Go to the documentation of this file.

#ifndef Impala_Persistency_AnnotationTableRepositoryInMonet_h
#define Impala_Persistency_AnnotationTableRepositoryInMonet_h

#include "Persistency/VideoSetRepository.h"
#include "Persistency/RepositoryInMonetDB.h"
#include "Core/Table/AnnotationTable.h"
#include "Persistency/AnnotationTableLocator.h"

namespace Impala
{
namespace Persistency
{


class AnnotationTableRepositoryInMonet
{
public:

    typedef Link::Monet::Connection Connection;
    typedef Core::Table::AnnotationTable AnnotationTable;

    AnnotationTableRepositoryInMonet()
    {
        mAnnotator = "fabchannel";
    }

    AnnotationTable*
    Get(const AnnotationTableLocator& loc)
    {
        if (loc.GetQuidClass() != QUID_CLASS_FRAME)
        {
            ILOG_ERROR("Only implemented for Frames");
            return 0;
        }

        Connection* conn = RepMonet().GetConnection(loc);

        String vidSetBase = FileNameBase(loc.GetDataSet());
        String query =
            "select f.quid, fr.fragment_start, a.relevance \
             from   fragment fr, file f, video_set vs, video_sets vss, \
                    keyword_sets kss, keyword_set ks, keyword k, annotator a, \
                    annotation a \
             where  vss.set_name = '" + vidSetBase + "' and \
                    vs.video_sets_id = vss.video_sets_id and \
                    f.file_id = vs.file_id and \
                    fr.media_id = f.media_id and \
                    fr.fragment_length = 1 and \
                    fr.keyframe = false and \
                    kss.set_name = '" + FileNameBase(loc.GetConceptSet()) + "' and \
                    kss.video_sets_id = vss.video_sets_id and \
                    ks.keyword_sets_id = kss.keyword_sets_id and \
                    ks.keyword_id = k.keyword_id and \
                    k.keyword_name = '" + loc.GetKeyword() + "' and \
                    a.annotator_name = '" + mAnnotator + "' and \
                    a.fragment_id = fr.fragment_id and \
                    a.keyword_id = k.keyword_id and \
                    a.approved = true \
             order by f.quid, fr.fragment_start;";

        MapiHdl hdl = conn->QueryPartStart(query);
        if (hdl == 0)
            return 0;

        Quid* quid = 0;
        int quidSize = 0;
        if (!conn->QueryPartFetchULL(hdl, 0, quid, quidSize))
            return 0;

        int* start = 0;
        int startSize = 0;
        if (!conn->QueryPartFetchInt(hdl, 1, start, startSize))
            return 0;

        double* rel = 0;
        int relSize;
        if (!conn->QueryPartFetchDouble(hdl, 2, rel, relSize))
            return 0;

        conn->QueryPartEnd(hdl);

        Core::VideoSet::VideoSet* vidSet = VideoSetRepository().Get(loc);
        AnnotationTable* anno = new AnnotationTable(loc.GetKeyword(), quidSize);
        for (int i=0 ; i<quidSize ; i++)
        {
            int vidId = QuidId(quid[i]);
            Quid q = vidSet->GetQuidFrame(vidId, start[i], false);
            if (rel[i] == 1.0)
                anno->AddPositive(q);
            else if (rel[i] == 0.0)
                anno->AddNegative(q);
            else
                anno->AddSkip(q);
        }

        delete quid;
        delete start;
        delete rel;
        return anno;
    }

    void
    Add(const AnnotationTableLocator& loc, AnnotationTable* tab)
    {
        if (loc.GetQuidClass() != QUID_CLASS_FRAME)
        {
            ILOG_ERROR("Only implemented for Frames");
            return;
        }

        Connection* conn = RepMonet().GetConnection(loc);

        String vidSetBase = FileNameBase(loc.GetDataSet());
        Core::VideoSet::VideoSet* vidSet = VideoSetRepository().Get(loc);

        conn->Query("select i_add_annotator('+" + mAnnotator + "', 'the boss', true);",
                    false, false);

        conn->Query("delete from i_bulk_annotation;", false, false);
        Timer timer;
        String keyword = loc.GetKeyword();
        ILOG_INFO("keyword " << keyword << " has " << tab->Size() << " annos");
        String date("2007/08/22-11:00:00");
        int nr = tab->Size();
        String q = "copy " + MakeString(nr) +
            " records into i_bulk_annotation from stdin using delimiters ' ';\n";
        for (int i=0 ; i<nr ; i++)
        {
            Quid frameQuid = tab->Get1(i);
            int vidId = QuidObject(frameQuid);
            Quid vidQuid = vidSet->GetQuidVideo(vidId, false);
            int frameNr = QuidId(frameQuid);
            Real64 relevance = 0.5; // skip, using Mpeg7 convention
            if (tab->IsPositive(i))
                relevance = 1.0;
            else if (tab->IsNegative(i))
                relevance = 0.0;
            Real64 confidence = 1.0;
            q += keyword + " " + MakeString(vidQuid) + " " + MakeString(frameNr)
                + " " + MakeString(relevance) + " " + MakeString(confidence)
                + " " + date + "\n";
        }
        conn->Query(q, false, false);
        ILOG_INFO("Did bulk in " << timer.SplitTime());
        conn->Query("insert into annotation (fragment_id, keyword_id, \
                                             annotator_id, \
                                             relevance, confidence, \
                                             annotation_date, approved) \
                     select fr.fragment_id, k.keyword_id, a.annotator_id, \
                            ba.relevance, ba.confidence, ba.annotation_date, \
                            a.approved \
                     from i_bulk_annotation ba, media m, fragment fr, \
                          video_sets vss,  keyword_sets kss, keyword_set ks, \
                          keyword k, annotator a \
                     where ba.quid = m.quid and \
                           m.media_id = fr.media_id and \
                           fr.fragment_start = ba.fragment_start and \
                           fr.fragment_length = 1 and \
                           fr.keyframe = false and \
                           vss.set_name = '" + vidSetBase + "' and \
                           kss.set_name = '" + FileNameBase(loc.GetConceptSet()) + "' and \
                           kss.video_sets_id = vss.video_sets_id and \
                           ks.keyword_sets_id = kss.keyword_sets_id and \
                           ks.keyword_id = k.keyword_id and \
                           k.keyword_name = ba.keyword_name and \
                           a.annotator_name = '" + mAnnotator + "' \
                     order by ba.quid, ba.fragment_start;", false, false);
        conn->Query("delete from i_bulk_annotation;", false, false);
    }

private:

    RepositoryInMonetDB&
    RepMonet()
    {
        return RepositoryInMonetDB::GetInstance();
    }

    String mAnnotator;

    ILOG_VAR_DEC;
};

ILOG_VAR_INIT(AnnotationTableRepositoryInMonet, Impala.Persistency);

} // namespace Persistency
} // namespace Impala

#endif

---