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

---

VideoSetRepositoryInMonet.h

Go to the documentation of this file.

#ifndef Impala_Persistency_VideoSetRepositoryInMonet_h
#define Impala_Persistency_VideoSetRepositoryInMonet_h

#include "Persistency/RepositoryInMonetDB.h"
#include "Core/VideoSet/VideoSet.h"

namespace Impala
{
namespace Persistency
{


class VideoSetRepositoryInMonet
{
public:

    typedef Link::Monet::Connection Connection;
    typedef Core::VideoSet::VideoSet VideoSet;

    VideoSetRepositoryInMonet()
    {
    }

    VideoSet*
    Get(const Locator& loc)
    {
        Connection* conn = RepMonet().GetConnection(loc);

        String vidSetBase = FileNameBase(loc.GetDataSet());
        String query =
            "select f.filename, f.quid \
             from   file f, video_set vs, video_sets vss \
             where  vss.set_name = '" + vidSetBase + "' and \
                    vs.video_sets_id = vss.video_sets_id and \
                    f.file_id = vs.file_id \
             order by f.quid;";

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

        std::vector<String> fName;
        if (!conn->QueryPartFetchString(hdl, 0, fName))
            return 0;

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

        conn->QueryPartEnd(hdl);

        VideoSet* vidSet = new VideoSet(loc.GetDataSet());
        vidSet->SetProtocolAndHost(loc.GetProtocolAndHost());
        for (int i=0 ; i<fName.size() ; i++)
        {
            int fileId = QuidId(quid[i]);
            vidSet->AddFile(fName[i], fileId);
            if (vidSet->GetQuidVideo(i, true) != quid[i])
                ILOG_ERROR("Quid " << i << " doesn't match");
        }
        delete quid;
        return vidSet;
    }

    void
    Add(const Locator& loc, VideoSet* vidSet)
    {
        Connection* conn = RepMonet().GetConnection(loc);

        String vidSetBase = FileNameBase(loc.GetDataSet());
        for (int i=0 ; i<vidSet->NrFiles() ; i++)
        {
            String file = vidSet->GetAsPath(i);
            Quid quid = vidSet->GetQuidVideo(i, true);
            // todo : get info from video
            //String q = "select i_add_video_file('" + vidSetBase + "', "
            //    + MakeString(quid) + ", '" + file
            //    + "', 352, 288, 25, -1, 'mpeg1', 'bitrate');";
            bool uniqueEvent = false;
            String evName = (uniqueEvent) ? vidSetBase + "_" + MakeString(quid)
                                          : FileNameBase(file);
            String q = "select i_add_video_file_event('" + vidSetBase + "', '"
                + evName + "', 'no description', " + MakeString(quid) + ", '"
                + file + "', 352, 288, true, 25, -1, 'mpeg1', 'bitrate');";
            ILOG_INFO("q = [" + q + "]");
            conn->Query(q, false, false);
        }
    }

private:

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

    ILOG_VAR_DEC;
};

ILOG_VAR_INIT(VideoSetRepositoryInMonet, Impala.Persistency);

} // namespace Persistency
} // namespace Impala

#endif

---