Client.h

Go to the documentation of this file.

/////////////////////////////////////////////////////////////////////////////
//
// This code was automatically generated by the joedb compiler
// https://www.joedb.org/
//
// Path to compiler: /home/rcoulom/repos/joedb/compcmake/gcc_debug/joedbc
// Version: 10.2.1
// joedbc compilation time: Sep 15 2025 20:22:33
// Generation of this file: 2025-09-15 18:23:01 GMT
//
/////////////////////////////////////////////////////////////////////////////
#ifndef tutorial_rpc_population_Client_declared
#define tutorial_rpc_population_Client_declared
 
#include "Writable_Database.h"
#include "joedb/concurrency/Writable_Client.h"
 
namespace tutorial::rpc::population
{
 namespace detail
 {
  ///////////////////////////////////////////////////////////////////////////
  class Client_Data
  ///////////////////////////////////////////////////////////////////////////
  {
   protected:
    Writable_Database db;
 
    Client_Data
    (
     joedb::Abstract_File &file,
     joedb::Recovery recovery
    ):
     db(file, recovery, false)
    {
    }
  };
 }
 
 /// Handle concurrent access to a @ref joedb::Abstract_File using a @ref joedb::Connection
 class Client:
  protected detail::Client_Data,
  public joedb::Writable_Client
 {
  friend class Client_Lock;
 
  private:
   int64_t schema_checkpoint;
 
  protected:
   void read_journal() override
   {
    db.play_journal();
    if (schema_checkpoint)
    {
     if (db.schema_journal.get_checkpoint() > schema_checkpoint)
      Database::throw_exception("Can't upgrade schema during pull");
     db.check_single_row();
    }
   }
 
  public:
   Client
   (
    joedb::Abstract_File &file,
    joedb::Connection &connection = joedb::Connection::dummy,
    joedb::Content_Check content_check = joedb::Content_Check::fast,
    joedb::Recovery recovery = joedb::Recovery::none
   ):
    detail::Client_Data(file, recovery),
    joedb::Writable_Client(db.journal, connection, content_check),
    schema_checkpoint(0)
   {
    if (get_checkpoint_difference() > 0)
     push_unlock();
 
    db.play_journal(); // makes transaction shorter if db is big
    joedb::Writable_Client::transaction([this](){
     db.initialize();
    });
 
    schema_checkpoint = db.schema_journal.get_checkpoint();
   }
 
   const Database &get_database() const
   {
    return db;
   }
 
   /// Execute a write transaction
   ///
   /// This function can be called with a lambda like this:
   /// @code
   /// client.transaction([](Writable_Database &db)
   /// {
   ///  db.write_comment("Hello");
   /// });
   /// @endcode
   /// The transaction function locks and pulls the connection before
   /// executing the lambda, pushes and unlocks it after.
   template<typename F> auto transaction
   (
    F transaction
   )
   {
    return joedb::Writable_Client::transaction([&]()
    {
     return transaction(db);
    });
   }
 };
 
 /// For more flexibility than the transaction lambda
 ///
 /// See joedb::Client_Lock for more information
 ///
 /// @include client_lock.cpp
 class Client_Lock: public joedb::Client_Lock
 {
  public:
   Client_Lock(Client &client): joedb::Client_Lock(client)
   {
   }
 
   Writable_Database &get_database()
   {
    JOEDB_DEBUG_ASSERT(locked);
    return static_cast<Client &>(client).db;
   }
 };
}
 
#endif