merge.cpp

Go to the documentation of this file.

#include "joedb/ui/merge.h"
#include "joedb/interpreted/Database.h"
 
/////////////////////////////////////////////////////////////////////////////
void joedb::merge(Database &merged, const Database &db)
/////////////////////////////////////////////////////////////////////////////
{
 std::map<Table_Id, Record_Id> offset;
 
 //
 // First loop over tables to fill the offset map
 //
 for (const auto &[tid, tname]: merged.get_tables())
  offset[tid] = merged.get_size(tid);
 
 //
 // Second loop to copy data, with added offset
 //
 for (const auto &[tid, tname]: merged.get_tables())
 {
  const Record_Id size = db.get_size(tid);
  const Freedom_Keeper &freedom_keeper = db.get_freedom(tid);
 
  if (size == Record_Id{0})
  {
   // do nothing, table is empty
  }
  else if (freedom_keeper.is_dense())
  {
   merged.insert_vector(tid, offset[tid], size_t(size));
 
   for (const auto &[fid, fname]: db.get_fields(tid))
   {
    const Type &type = db.get_field_type(tid, fid);
    size_t capacity;
 
    switch (type.get_type_id())
    {
     case Type::Type_Id::null:
     break;
 
     #define TYPE_MACRO(type, return_type, type_id, R, W)\
     case Type::Type_Id::type_id:\
     {\
      merged.update_vector_##type_id\
      (\
       tid,\
       offset[tid],\
       fid,\
       size_t(size),\
       db.get_own_##type_id##_const_storage(tid, Record_Id(0), fid, capacity)\
      );\
     }\
     break;
     #include "joedb/TYPE_MACRO.h"
    }
 
    if (type.get_type_id() == Type::Type_Id::reference)
    {
     const auto reference_offset = offset[type.get_table_id()];
 
     Record_Id *reference = merged.get_own_reference_storage
     (
      tid,
      offset[tid],
      fid,
      capacity
     );
 
     for (size_t i = 0; i < size_t(size); i++)
      if (reference[i].is_not_null())
       reference[i] = reference[i] + to_underlying(reference_offset);
    }
   }
  }
  else
  {
   for (Record_Id record_id{0}; record_id < size; ++record_id)
   {
    if (freedom_keeper.is_used(record_id))
    {
     const Record_Id merged_record_id = offset[tid] + to_underlying(record_id);
     merged.insert_into(tid, merged_record_id);
 
     for (const auto &[fid, fname]: db.get_fields(tid))
     {
      const Type &type = db.get_field_type(tid, fid);
 
      switch (type.get_type_id())
      {
       case Type::Type_Id::null:
       break;
 
       case Type::Type_Id::reference:
       {
        Record_Id referenced = db.get_reference(tid, record_id, fid);
        if (referenced.is_not_null())
         referenced = referenced + to_underlying(offset[type.get_table_id()]);
        merged.update_reference
        (
         tid,
         merged_record_id,
         fid,
         referenced
        );
       }
       break;
 
       #define TYPE_MACRO(type, return_type, type_id, R, W)\
       case Type::Type_Id::type_id:\
       {\
        merged.update_##type_id\
        (\
         tid,\
         merged_record_id,\
         fid,\
         db.get_##type_id(tid, record_id, fid)\
        );\
       }\
       break;
       #define TYPE_MACRO_NO_REFERENCE
       #include "joedb/TYPE_MACRO.h"
      }
     }
    }
   }
  }
 }
}