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

---

Write.h

Go to the documentation of this file.

#ifndef Impala_Core_Column_Write_h
#define Impala_Core_Column_Write_h

#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/WriteRaw.h"

namespace Impala
{
namespace Core
{
namespace Column
{


inline void
Write(InvalidColumn* col, int nrElem, Util::IOBuffer* buf, bool binary)
{
    // ignore: column is empty
}

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


inline void
Write(ColumnTem<Int32>* col, int nrElem, Util::IOBuffer* buf, bool binary)
{
    Array::Array2dScalarInt32 wrapper(nrElem, 1, 0, 0, col->GetData(), true);
    Array::WriteRaw(&wrapper, buf, binary);
}

#ifndef REPOSITORY_USED // Here comes the deprecated stuff
inline void
Write(ColumnTem<Int32>* col, int nrElem, String fileName, Util::Database* db,
      bool binary)
{
    Array::Array2dScalarInt32 wrapper(nrElem, 1, 0, 0, col->GetData(), true);
    Array::WriteRaw(&wrapper, fileName, db, binary);
}
#endif // REPOSITORY_USED


inline void
Write(ColumnTem<UInt64>* col, int nrElem, Util::IOBuffer* buf, bool binary)
{
    Array::Array2dScalarUInt64 wrapper(nrElem, 1, 0, 0, col->GetData(), true);
    Array::WriteRaw(&wrapper, buf, binary);
}

#ifndef REPOSITORY_USED // Here comes the deprecated stuff
inline void
Write(ColumnTem<UInt64>* col, int nrElem, String fileName, Util::Database* db,
      bool binary)
{
    Array::Array2dScalarUInt64 wrapper(nrElem, 1, 0, 0, col->GetData(), true);
    Array::WriteRaw(&wrapper, fileName, db, binary);
}
#endif // REPOSITORY_USED


inline void
Write(ColumnTem<Real64>* col, int nrElem, Util::IOBuffer* buf, bool binary)
{
    Array::Array2dScalarReal64 wrapper(nrElem, 1, 0, 0, col->GetData(), true);
    Array::WriteRaw(&wrapper, buf, binary);
}

#ifndef REPOSITORY_USED // Here comes the deprecated stuff
inline void
Write(ColumnTem<Real64>* col, int nrElem, String fileName, Util::Database* db,
      bool binary)
{
    Array::Array2dScalarReal64 wrapper(nrElem, 1, 0, 0, col->GetData(), true);
    Array::WriteRaw(&wrapper, fileName, db, binary);
}
#endif // REPOSITORY_USED


inline void
Write(ColumnTem<String>* col, int nrElem, Util::IOBuffer* buf, bool binary)
{
    if (! (buf && buf->Valid()))
    {
        return;
    }
    String* data = col->GetData();
    int byteSize = nrElem;  // count newlines
    for (int i=0 ; i<nrElem ; i++) byteSize += data[i].size();
    buf->Puts("nr strings : " + MakeString(nrElem) + " " + 
                                MakeString(byteSize));
    for (int i=0 ; i<nrElem ; i++)
        //fprintf(f.Fp(), "%s\n", data[i].c_str());
        buf->Puts(data[i]);
}

#ifndef REPOSITORY_USED // Here comes the deprecated stuff
inline void
Write(ColumnTem<String>* col, int nrElem, String fileName, Util::Database* db,
      bool binary)
{
    Util::IOBuffer* buf = db->GetIOBuffer(fileName, false, false, "tmp");
    if (! buf)
    {
        delete buf;
        return;
    }    
    Write(col, nrElem, buf, binary);
    delete buf;
}
#endif // REPOSITORY_USED


inline void
Write(ColumnTem<Geometry::Rectangle>* col, int nrElem, Util::IOBuffer* buf,
      bool binary)
{
    if (! (buf && buf->Valid()))
    {
        return;
    }
    
    buf->Write("nr rects : ",11);
    buf->NativeTypeWrite(nrElem);
    buf->Puts("");
    Geometry::Rectangle* data = col->GetData();
    for (int i=0 ; i<nrElem ; i++)
    {
        buf->NativeTypeWrite(data[i].mLeft);
        buf->NativeTypeWrite(data[i].mTop);
        buf->NativeTypeWrite(data[i].mRight);
        buf->NativeTypeWrite(data[i].mBottom);
        buf->Puts("");
    }
}

#ifndef REPOSITORY_USED // Here comes the deprecated stuff
inline void
Write(ColumnTem<Geometry::Rectangle>* col, int nrElem, String fileName,
      Util::Database* db, bool binary)
{
    std::ofstream f(fileName.c_str());
    if (!f.is_open())
        return;
    f << "nr rects : " << nrElem << "\n";
    Geometry::Rectangle* data = col->GetData();
    for (int i=0 ; i<nrElem ; i++)
        f << data[i] << "\n";
    f.close();
}
#endif // REPOSITORY_USED


inline void
Write(Vector::VectorSet<Array::Array2dScalarInt8>* col, int nrElem,
      Util::IOBuffer* buf, bool binary)
{
    // todo: only works for set with constVecSize
    Array::Array2dScalarInt8* data = col->GetStorage();
    Array::Array2dScalarInt8 wrapper(data->CW(), nrElem, 0, 0, data->PB(),
                                     true);
    Array::WriteRaw(&wrapper, buf, binary);
}

#ifndef REPOSITORY_USED // Here comes the deprecated stuff
inline void
Write(Vector::VectorSet<Array::Array2dScalarInt8>* col, int nrElem,
      String fileName, Util::Database* db, bool binary)
{
    // todo: only works for set with constVecSize
    Array::Array2dScalarInt8* data = col->GetStorage();
    Array::Array2dScalarInt8 wrapper(data->CW(), nrElem, 0, 0, data->PB(),
                                     true);
    Array::WriteRaw(&wrapper, fileName, db, binary);
}
#endif // REPOSITORY_USED


inline void
Write(Vector::VectorSet<Array::Array2dScalarReal64>* col, int nrElem,
      Util::IOBuffer* buf, bool binary)
{
    // todo: only works for set with constVecSize
    Array::Array2dScalarReal64* data = col->GetStorage();
    Array::Array2dScalarReal64 wrapper(data->CW(), nrElem, 0, 0, data->PB(),
                                       true);
    Array::WriteRaw(&wrapper, buf, binary);
}

#ifndef REPOSITORY_USED // Here comes the deprecated stuff
inline void
Write(Vector::VectorSet<Array::Array2dScalarReal64>* col, int nrElem,
      String fileName, Util::Database* db, bool binary)
{
    // todo: only works for set with constVecSize
    Array::Array2dScalarReal64* data = col->GetStorage();
    Array::Array2dScalarReal64 wrapper(data->CW(), nrElem, 0, 0, data->PB(),
                                       true);
    Array::WriteRaw(&wrapper, fileName, db, binary);
}
#endif // REPOSITORY_USED


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

#endif

---