Writable_Database_h.cpp

Go to the documentation of this file.

#include "joedb/compiler/generator/Writable_Database_h.h"
#include "joedb/compiler/nested_namespace.h"
#include "joedb/ui/type_io.h"
 
namespace joedb::generator
{
 ////////////////////////////////////////////////////////////////////////////
 Writable_Database_h::Writable_Database_h
 ////////////////////////////////////////////////////////////////////////////
 (
  const Compiler_Options &options
 ):
  Generator(".", "Writable_Database.h", options)
 {
 }
 
 ////////////////////////////////////////////////////////////////////////////
 void Writable_Database_h::write(std::ostream &out)
 ////////////////////////////////////////////////////////////////////////////
 {
  const Database &db = options.get_db();
  auto tables = db.get_tables();
 
  namespace_include_guard_open(out, "Writable_Database", options.get_name_space());
 
  if (options.has_multi_row())
   out << "\n#include \"joedb/Span.h\"\n";
 
  out << R"RRR(
#include "Database_Writable.h"
 
#include <utility>
 
)RRR";
 
  namespace_open(out, options.get_name_space());
 
  //
  // Writable_Database
  //
  out << R"RRR(
 namespace detail
 {
  class Client_Data;
 }
 
 class Client;
 class Multiplexer;
 class Memory_Database;
 
 /// A @ref Database that contains a @ref joedb::Writable_Journal and keeps them in sync
 class Writable_Database: public Database_Writable
 {
  friend class detail::Client_Data;
  friend class Client;
  friend class Multiplexer;
  friend class Memory_Database;
 
  private:
   joedb::Writable_Journal journal;
   bool ready_to_write;
 
   void play_journal();
   void auto_upgrade();
   void check_single_row();
   void initialize();
)RRR";
 
 
  if (!options.get_custom_names().empty())
  {
   out << R"RRR(
   void custom(const std::string &name) override
   {
    Database_Writable::custom(name);
 
    if (upgrading_schema)
    {
)RRR";
   for (const auto &name: options.get_custom_names())
   {
    out << "     if (name == \"" << name << "\")\n";
    out << "      " << name << "(*this);\n";
   }
   out << "    }\n";
   out << "   }\n";
 
   out << '\n';
   out << "  public:\n";
   for (const auto &name: options.get_custom_names())
    out << "   static void " << name << "(Writable_Database &db);\n";
   out << "\n  private:";
  }
 
  if (db_has_values())
  {
   out << R"RRR(
   void add_field
   (
    Table_Id table_id,
    const std::string &name,
    joedb::Type type
   ) override;
)RRR";
  }
 
  if (options.has_single_row())
  {
   out <<"\n   void create_table(const std::string &name) override;\n";
  }
 
  out << R"RRR(
   Writable_Database
   (
    joedb::Abstract_File &file,
    joedb::Recovery recovery,
    bool perform_initialization
   );
 
  public:
   Writable_Database(joedb::Abstract_File &file);
 
   Writable_Database
   (
    joedb::Abstract_File &file,
    joedb::Recovery recovery
   );
 
   const joedb::Readonly_Journal &get_journal() const {return journal;}
 
   std::string read_blob(joedb::Blob blob) const
   {
    return journal.get_file().read_blob(blob);
   }
 
   joedb::Blob write_blob(std::string_view data) override
   {
    return journal.write_blob(data);
   }
 
   int64_t ahead_of_checkpoint() const
   {
    return journal.ahead_of_checkpoint();
   }
 
   void soft_checkpoint() override
   {
    journal.soft_checkpoint();
   }
 
   void hard_checkpoint() override
   {
    journal.hard_checkpoint();
   }
 
   void write_comment(const std::string &comment);
   void write_timestamp();
   void write_timestamp(int64_t timestamp);
   void write_valid_data();
   void flush() override {journal.flush();}
)RRR";
 
  for (const auto &[tid, tname]: tables)
  {
   out << '\n';
   const bool single_row = options.get_table_options(tid).single_row;
 
   //
   // Erase all elements of the table
   //
   if (!single_row)
   {
    out << "   void clear_" << tname << "_table();\n";
    out << '\n';
   }
 
   if (single_row)
    out << "  private:\n";
 
   //
   // Uninitialized new
   //
   out << "   id_of_" << tname << " new_" << tname << "()\n";
   out << "   {\n";
 
   out << "    id_of_" << tname << " result(Record_Id(storage_of_" << tname << ".freedom_keeper.get_free_record()));\n";
   out << "    storage_of_" << tname << ".resize(storage_of_" << tname << ".freedom_keeper.size());\n";
   out << "    internal_insert_" << tname << "(result.get_record_id());\n\n";
   out << "    journal.insert_into(Table_Id(" << tid << "), result.get_record_id());\n";
   out << "    return result;\n";
   out << "   }\n\n";
 
   out << "   void insert_" << tname << "(id_of_" << tname << " id)\n";
   out << "   {\n";
   out << "    if (id.get_record_id() >= Record_Id(storage_of_" << tname << ".size()))\n";
   out << "     storage_of_" << tname << ".resize(id.get_id() + 1);\n";
   out << "    internal_insert_" << tname << "(id.get_record_id());\n";
   out << "    journal.insert_into(Table_Id(" << tid << "), id.get_record_id());\n";
   out << "   }\n\n";
 
   //
   // new uninitialized vector
   //
   if (!single_row)
   {
    out << "   id_of_" << tname << " new_vector_of_" << tname << "(size_t size)\n";
    out << "   {\n";
    out << "    id_of_" << tname << " result(Record_Id(storage_of_" << tname;
    out << ".size()));\n";
    out << "    storage_of_" << tname << ".resize(storage_of_";
    out << tname << ".size() + size);\n";
    out << "    internal_vector_insert_" << tname << "(result.get_record_id(), size);\n";
    out << "    journal.insert_vector(Table_Id(" << tid;
    out << "), result.get_record_id(), size);\n";
    out << "    return result;\n";
    out << "   }\n";
    out << '\n';
   }
 
   //
   // new with all fields
   //
   if (!db.get_fields(tid).empty())
   {
    out << "   id_of_" << tname << " new_" << tname << '\n';
    out << "   (\n    ";
    {
     bool first = true;
 
     for (const auto &[fid, fname]: db.get_fields(tid))
     {
      if (first)
       first = false;
      else
       out << ",\n    ";
 
      const Type &type = db.get_field_type(tid, fid);
      write_type(out, type, Type_Usage::setter_value);
      out << " field_value_of_" << fname;
     }
 
     out << '\n';
    }
    out << "   )\n";
    out << "   {\n";
    out << "    auto result = new_" << tname << "();\n";
 
    for (const auto &[fid, fname]: db.get_fields(tid))
    {
     const bool is_string = db.get_field_type(tid, fid).get_type_id() == Type::Type_Id::string;
     out << "    set_" << fname << "(result, ";
     if (is_string)
      out << "std::move(";
     out << "field_value_of_" << fname;
     if (is_string)
      out << ')';
     out << ");\n";
    }
 
    out << "    return result;\n";
    out << "   }\n\n";
   }
 
   if (single_row)
    out << "  public:\n";
 
   //
   // Delete
   //
   if (!single_row)
   {
    out << "   void delete_" << tname << "(id_of_" << tname << " record)\n";
    out << "   {\n";
    out << "    internal_delete_" << tname << "(record.get_record_id());\n";
    out << "    journal.delete_from(Table_Id(" << tid << "), record.get_record_id());\n";
    out << "   }\n\n";
 
    out << "   void delete_vector_of_" << tname << "(id_of_" << tname << " v, size_t size)\n";
    out << "   {\n";
    out << "    for (size_t i = size; i > 0;)\n";
    out << "     internal_delete_" << tname << "(v[--i].get_record_id());\n";
    out << "    journal.delete_vector(Table_Id(" << tid << "), v.get_record_id(), size);\n";
    out << "   }\n\n";
   }
 
   //
   // Loop over fields
   //
   for (const auto &[fid, fname]: db.get_fields(tid))
   {
    const Type &type = db.get_field_type(tid, fid);
 
    //
    // Setter
    //
    out << "   void set_" << fname;
    out << "(id_of_" << tname << " record, ";
    write_type(out, type, Type_Usage::setter_value);
    out << " field_value_of_" << fname << ")\n";
    out << "   {\n";
    out << "    internal_update_" << tname << "__" << fname;
 
    out <<  "(record.get_record_id(), ";
    if (type.get_type_id() == Type::Type_Id::string)
     out << "std::move(";
    out << "field_value_of_" << fname;
    if (type.get_type_id() == Type::Type_Id::string)
     out << ')';
    out << ");\n";
    out << "    journal.update_";
    out << get_type_string(type);
    out << "(Table_Id(" << tid << "), record.get_record_id(), Field_Id(" << fid << "), ";
    if (type.get_type_id() == Type::Type_Id::string)
     out << "get_" << fname << "(record)";
    else
     out << "field_value_of_" << fname;
    if (type.get_type_id() == Type::Type_Id::reference)
     out << ".get_record_id()";
    out << ");\n";
    out << "   }\n\n";
 
    if (single_row && options.is_unique_field_name(fname))
    {
     out << "   void set_" << fname;
     out << "(";
     write_type(out, type, Type_Usage::setter_value);
     out << " field_value_of_" << fname << ")\n";
     out << "   {\n";
     out << "    set_" << fname << "(the_" << tname;
     out << "(), ";
     if (type.get_type_id() == Type::Type_Id::string)
      out << "std::move(";
     out << "field_value_of_" << fname;
     if (type.get_type_id() == Type::Type_Id::string)
      out << ')';
     out << ");\n";
     out << "   }\n\n";
    }
 
    //
    // Vector update
    //
    if (!single_row)
    {
     out << "   template<typename F> void update_vector_of_" << fname;
     out << "(id_of_" << tname << " record, size_t size, F f)\n";
     out << "   {\n";
     out << "    JOEDB_DEBUG_ASSERT(storage_of_" << tname << ".freedom_keeper.is_used_vector(record.get_record_id(), size));\n";
     out << "    joedb::Span<";
     write_type(out, type, Type_Usage::storage);
     out << "> span(&storage_of_" << tname;
     out << ".field_value_of_" << fname << ".data()[record.get_id()], size);\n";
     out << "    f(span);\n";
     out << "    internal_update_vector_" << tname << "__" << fname << "(record.get_record_id(), size, span.begin());\n";
     out << "    journal.update_vector_" << get_type_string(type) << "(Table_Id(" << tid << "), record.get_record_id(), Field_Id(" << fid << "), size, ";
 
     if (type.get_type_id() == Type::Type_Id::reference)
      out << "reinterpret_cast<Record_Id *>";
 
     out << "(span.begin()));\n";
     out << "   }\n\n";
    }
   }
  }
 
  out << "\n };";
 
  namespace_close(out, options.get_name_space());
  namespace_include_guard_close(out);
 }
}