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

---

KeywordListRepositoryInMonet.h

Go to the documentation of this file.

#ifndef Impala_Persistency_KeywordListRepositoryInMonet_h
#define Impala_Persistency_KeywordListRepositoryInMonet_h

#include "Persistency/RepositoryInMonetDB.h"
#include "Persistency/RepositoryInFileSystem.h"
#include "Core/Table/KeywordList.h"
#include "Persistency/KeywordListLocator.h"

namespace Impala
{
namespace Persistency
{


class KeywordListRepositoryInMonet
{
public:

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

    KeywordListRepositoryInMonet()
    {
    }

    KeywordList*
    Get(const KeywordListLocator& loc)
    {
        Connection* conn = RepMonet().GetConnection(loc);

        String vidSetBase = FileNameBase(loc.GetDataSet());
        String conceptSetBase = FileNameBase(loc.GetConceptSet());
        String query =
            "select k.keyword_name \
             from   keyword k, keyword_set ks, keyword_sets kss, video_sets vss \
             where  vss.set_name = '" + vidSetBase + "' and \
                    kss.video_sets_id = vss.video_sets_id and \
                    kss.set_name = '" + conceptSetBase + "' and \
                    ks.keyword_sets_id = kss.keyword_sets_id and \
                    k.keyword_id = ks.keyword_id \
             order by k.keyword_id;";

        KeywordList* concepts = new KeywordList();
        MapiHdl hdl = conn->QueryPartStart(query);
        if (hdl == 0)
            return concepts;

        if (!conn->QueryPartFetchString(hdl, 0, *concepts))
            return concepts;

        conn->QueryPartEnd(hdl);

        return concepts;
    }

    void
    Add(const KeywordListLocator& loc, KeywordList* keyList)
    {
        Connection* conn = RepMonet().GetConnection(loc);

        String vidSetBase = FileNameBase(loc.GetDataSet());
        String conceptSetBase = FileNameBase(loc.GetConceptSet());
        for (int i=0 ; i<keyList->size() ; i++)
        {
            String q = "select i_add_keyword('" + vidSetBase + "', '" +
                conceptSetBase + "', '" + (*keyList)[i] + "');";
            ILOG_INFO("q = [" + q + "]");
            conn->Query(q, false, false);
        }
    }

private:

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

    ILOG_VAR_DEC;
};

ILOG_VAR_INIT(KeywordListRepositoryInMonet, Impala.Persistency);

} // namespace Persistency
} // namespace Impala

#endif

---