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

---

Read.h

Go to the documentation of this file.

#ifndef Impala_Core_Column_Read_h
#define Impala_Core_Column_Read_h

#include <iostream>
#include <fstream>

#include "Util/Database.h"
#include "Core/Geometry/Rectangle.h"
#include "Core/Array/Arrays.h"
#include "Core/Column/ColumnTem.h"
#include "Core/Column/InvalidColumn.h"
#include "Core/Vector/VectorSet.h"
#include "Core/Array/ReadRaw.h"

namespace Impala
{
namespace Core
{
namespace Column
{


inline void
Read(InvalidColumn* col, Util::IOBuffer* buffer)
{
    // ignore: column is empty
}

#ifndef REPOSITORY_USED // Here comes the deprecated stuff
inline void
Read(InvalidColumn* col, String fileName, Util::Database* db)
{
    // ignore: column is empty
}
#endif // REPOSITORY_USED


inline void
Read(ColumnTem<Int32>* col, Util::IOBuffer* buffer)
{
    Array::Array2dScalarInt32* tmp = 0;
    Array::ReadRaw(tmp, buffer);
    if (tmp)
    {
        col->SetData(tmp->CPB(), tmp->CW());
        tmp->mIsWrapper = true;
        delete tmp;
    }
}

#ifndef REPOSITORY_USED // Here comes the deprecated stuff
inline void
Read(ColumnTem<Int32>* col, String fileName, Util::Database* db)
{
    Array::Array2dScalarInt32* tmp = 0;
    Array::ReadRaw(tmp, fileName, db);
    if (tmp)
    {
        col->SetData(tmp->CPB(), tmp->CW());
        tmp->mIsWrapper = true;
        delete tmp;
    }
}
#endif // REPOSITORY_USED


inline void
Read(ColumnTem<UInt64>* col, Util::IOBuffer* buffer)
{
    Array::Array2dScalarUInt64* tmp = 0;
    Array::ReadRaw(tmp, buffer);
    if (tmp)
    {
        col->SetData(tmp->CPB(), tmp->CW()*tmp->CH());
        tmp->mIsWrapper = true;
        delete tmp;
    }
}

#ifndef REPOSITORY_USED // Here comes the deprecated stuff
inline void
Read(ColumnTem<UInt64>* col, String fileName, Util::Database* db)
{
    Array::Array2dScalarUInt64* tmp = 0;
    Array::ReadRaw(tmp, fileName, db);
    if (tmp)
    {
        col->SetData(tmp->CPB(), tmp->CW()*tmp->CH());
        tmp->mIsWrapper = true;
        delete tmp;
    }
}
#endif // REPOSITORY_USED


inline void
Read(ColumnTem<Real64>* col, Util::IOBuffer* buffer)
{
    Array::Array2dScalarReal64* tmp = 0;
    Array::ReadRaw(tmp, buffer);
    if (tmp)
    {
        col->SetData(tmp->CPB(), tmp->CW()*tmp->CH());
        tmp->mIsWrapper = true;
        delete tmp;
    }
}

#ifndef REPOSITORY_USED // Here comes the deprecated stuff
inline void
Read(ColumnTem<Real64>* col, String fileName, Util::Database* db)
{
    Array::Array2dScalarReal64* tmp = 0;
    Array::ReadRaw(tmp, fileName, db);
    if (tmp)
    {
        col->SetData(tmp->CPB(), tmp->CW()*tmp->CH());
        tmp->mIsWrapper = true;
        delete tmp;
    }
}
#endif // REPOSITORY_USED


inline void
Read(ColumnTem<String>* col, Util::IOBuffer* buffer)
{
    if (! (buffer && buffer->Valid()))
    {
        return;
    }
    int nrElem;
    int byteSize;
    //fscanf(f.Fp(), "nr strings : %d\n", &nrElem);
    std::istringstream iss(buffer->ReadLine() + " 0");
    String dummy;
    iss >> dummy >> dummy >> dummy >> nrElem >> byteSize;
    col->Reserve(nrElem, false);
    String* data = col->GetData();
    if(byteSize > 0)
    {
        char* binaryData = new char[byteSize];
        buffer->Read(binaryData, byteSize);
        int j = 0;
        for (int i=0 ; i<nrElem ; i++)
        {
            int start = j;
            while((j<byteSize) && (binaryData[j] != '\n'))
                j++;
            data[i] = String(&(binaryData[start]), j - start);
            j++;
        }
        delete binaryData;
    }
    else
    {
        for (int i=0 ; i<nrElem ; i++)
            data[i] = buffer->ReadLine();
    }
}

#ifndef REPOSITORY_USED // Here comes the deprecated stuff
inline void
Read(ColumnTem<String>* col, String fileName, Util::Database* db)
{
    Util::IOBuffer* buf = db->GetIOBuffer(fileName, true, true, "");
    Read(col, buf);
    delete buf;
}
#endif // REPOSITORY_USED


inline void
Read(ColumnTem<Geometry::Rectangle>* col, Util::IOBuffer* buffer)
{
    String s,nr;
    int nrElem;
    s=buffer->ReadLine();
    String subs=s.substr(0,11);
    if (subs=="nr rects : ")
    {
        nr=s.substr(10);
        std::istringstream iss(nr);
        iss>>nrElem;
        col->Reserve(nrElem, false);
        Geometry::Rectangle* data = col->GetData();
        for (int i=0 ; i<nrElem ; i++)
        {
           buffer->NativeTypeRead(&data[i].mLeft);
           buffer->NativeTypeRead(&data[i].mTop);
           buffer->NativeTypeRead(&data[i].mRight);
           buffer->NativeTypeRead(&data[i].mBottom);
        }
    }
    else
    {
        std::cout << "[Read<column<rectangles>>] parsing error"<< std::endl;
    }
}

#ifndef REPOSITORY_USED // Here comes the deprecated stuff
inline void
Read(ColumnTem<Geometry::Rectangle>* col, String fileName, Util::Database* db)
{
    std::ifstream f(fileName.c_str());
    if (!f.is_open())
        return;
    String s1,s2,s3;
    f >> s1 >> s2 >> s3;
    if (s1 == "nr" && s2 == "rects" && s3 == ":")
    {
        int nrElem;
        f >> nrElem;
        col->Reserve(nrElem, false);
        Geometry::Rectangle* data = col->GetData();
        for (int i=0 ; i<nrElem ; i++)
            f >> data[i];
    }
    else
    {
        std::cout << "[Read<column<rectangles>>] parsing error in " << fileName
                  << std::endl;
    }
    f.close();
}
#endif // REPOSITORY_USED


inline void
Read(Vector::VectorSet<Array::Array2dScalarInt8>* col, Util::IOBuffer* buffer)
{
    // todo: only works for set with constVecSize and is a dirty hack
    Array::Array2dScalarInt8* tmp = 0;
    Array::ReadRaw(tmp, buffer);
    if (tmp)
    {
        col->SetStorage(tmp);
        col->SetSize(tmp->CH());
    }
}

#ifndef REPOSITORY_USED // Here comes the deprecated stuff
inline void
Read(Vector::VectorSet<Array::Array2dScalarInt8>* col, String fileName,
     Util::Database* db)
{
    // todo: only works for set with constVecSize and is a dirty hack
    Array::Array2dScalarInt8* tmp = 0;
    Array::ReadRaw(tmp, fileName, db);
    if (tmp)
    {
        col->SetStorage(tmp);
        col->SetSize(tmp->CH());
    }
}
#endif // REPOSITORY_USED


inline void
Read(Vector::VectorSet<Array::Array2dScalarReal64>* col, Util::IOBuffer* buffer)
{
    // todo: only works for set with constVecSize and is a dirty hack
    Array::Array2dScalarReal64* tmp = 0;
    Array::ReadRaw(tmp, buffer);
    if (tmp)
    {
        col->SetStorage(tmp);
        col->SetSize(tmp->CH());
    }
}

#ifndef REPOSITORY_USED // Here comes the deprecated stuff
inline void
Read(Vector::VectorSet<Array::Array2dScalarReal64>* col, String fileName,
     Util::Database* db)
{
    // todo: only works for set with constVecSize and is a dirty hack
    Array::Array2dScalarReal64* tmp = 0;
    Array::ReadRaw(tmp, fileName, db);
    if (tmp)
    {
        col->SetStorage(tmp);
        col->SetSize(tmp->CH());
    }
}
#endif // REPOSITORY_USED

} // namespace Column
} // namespace Core
} // namespace Impala

#endif

---