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

---

ImageArchiveRepositoryInMonet.h

Go to the documentation of this file.

#ifndef Impala_Persistency_ImageArchiveRepositoryInMonet_h
#define Impala_Persistency_ImageArchiveRepositoryInMonet_h

#include "Persistency/RepositoryInMonetDB.h"
#include "Core/Array/ImageArchiveMapi.h"
#include "Persistency/ImageArchiveLocator.h"

namespace Impala
{
namespace Persistency
{


class ImageArchiveRepositoryInMonet
{
public:

    typedef Link::Monet::Connection Connection;
    typedef Core::Array::ImageArchive ImageArchive;
    typedef Core::Array::ImageArchiveMapi ImageArchiveMapi;
    typedef Core::Array::Array2dVec3UInt8 Array2dVec3UInt8;

    ImageArchiveRepositoryInMonet()
    {
    }

    ImageArchive*
    Get(const ImageArchiveLocator& loc)
    {
        if (!loc.GetFrames())
        {
            ILOG_ERROR("Only implemented for frames");
            return 0;
        }

        Connection* conn = RepMonet().GetConnection(loc);
        ImageArchive* res = new ImageArchiveMapi(loc.GetQuid(), conn);
        return res;
    }

    void
    Add(const ImageArchiveLocator& loc, ImageArchive* archive)
    {
        if (!loc.GetFrames())
        {
            ILOG_ERROR("Only implemented for frames");
            return;
        }
        if (loc.GetName() != "images_jpg.raw")
        {
            ILOG_ERROR("Only implemented for jpg's of all frames");
            return;
        }

        Connection* conn = RepMonet().GetConnection(loc);
        Quid vidQuid = loc.GetQuid();

        conn->Query("delete from i_bulk_frame_image;", false, false);
        int totalSize = archive->NrImages();
        int bulkSize = 4000;
        Timer timer;

        for (int i=0 ; i<totalSize ; i+=bulkSize)
        {
            int left = totalSize - i;
            int nr = (left > bulkSize) ? bulkSize : left;
            String q = "copy " + MakeString(nr) +
                " records into i_bulk_frame_image from stdin" +
                " using delimiters ' ';\n";
            for (int j=i ; j<i+nr ; j++)
            {
                Array2dVec3UInt8* im = archive->ReadImage(j);
                size_t dataSize = 0;
                UInt8* data = archive->GetImageData(j, dataSize);
                String hexData = Util::Bin2Hex(data, dataSize);
                delete data;
                String name = "frame" + MakeString(j);
                String width = MakeString(im->CW());
                String height = MakeString(im->CH());
                q += MakeString(vidQuid) + " " + MakeString(j) + " " + name + " "
                    + hexData + " " + width + " " + height + " image/jpg \n";
                delete im;
            }
            conn->Query(q, false, false);
            ILOG_INFO("Did bulk " << i << " at " << timer.SplitTime());

            conn->Query("insert into frame_image (fragment_id, image, width, \
                                                  height, mime_type) \
                         select fr.fragment_id, bf.image, bf.width, bf.height, \
                                bf.mime_type \
                         from i_bulk_frame_image bf, file f, fragment fr \
                         where bf.quid = f.quid and \
                               f.media_id = fr.media_id and \
                               fr.fragment_start = bf.fragment_start and \
                               fr.fragment_length = 1 and \
                               fr.keyframe = false \
                         order by bf.quid, bf.fragment_start;", false, false);
            ILOG_INFO("Did insert select at " << timer.SplitTime());
            conn->Query("delete from i_bulk_frame_image;", false, false);
        }
    }

private:

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

    ILOG_VAR_DEC;
};

ILOG_VAR_INIT(ImageArchiveRepositoryInMonet, Impala.Persistency);

} // namespace Persistency
} // namespace Impala

#endif

---