Inserter.hpp

Go to the documentation of this file.

 
#ifndef TABLEAU_HYPER_INSERTER_HPP
#define TABLEAU_HYPER_INSERTER_HPP
 
#include <hyperapi/Connection.hpp>
#include <hyperapi/TableDefinition.hpp>
#include <hyperapi/Time.hpp>
#include <hyperapi/optional.hpp>
#include <hyperapi/hyperapi.h>
 
#include <string>
#include <vector>
 
namespace hyperapi {
 
class Inserter final {
   public:
   class ColumnMapping final {
      public:
      const Name& getColumnName() const noexcept { return name; }
 
      optional<std::string> getExpression() const noexcept { return expression; }
 
      ColumnMapping(Name name);
 
      ColumnMapping(Name name, std::string expression);
 
      private:
      const Name name;
      const optional<std::string> expression;
      std::string asSelectListExpression() const;
 
      friend class Inserter;
   };
 
   Inserter(Connection& connection, const TableName& name);
 
   Inserter(Connection& connection, const TableName& name, std::vector<std::string> columns);
 
   Inserter(Connection& connection, hyperapi::TableDefinition tableDefinition);
 
   Inserter(Connection& connection, const hyperapi::TableDefinition& tableDefinition, std::vector<std::string> columns);
 
   Inserter(Connection& connection, const hyperapi::TableDefinition& tableDefinition, std::vector<Inserter::ColumnMapping> columnMappings, std::vector<TableDefinition::Column> inserterDefinition);
 
   Inserter(Connection& connection, const TableName& name, std::vector<Inserter::ColumnMapping> columnMappings, std::vector<TableDefinition::Column> inserterDefinition);
 
   Inserter() : tableDefinition(TableName({})), streamDefinition(TableName({})) {}
 
   ~Inserter() noexcept;
 
   Inserter(Inserter&& other) noexcept;
 
   Inserter& operator=(Inserter&& other) noexcept;
 
   Inserter(const Inserter&) = delete;
   Inserter& operator=(const Inserter&) = delete;
 
   template <typename ValueType>
   Inserter& add(ValueType value);
 
   template <typename... ValueTypes>
   Inserter& addRow(ValueTypes... values);
 
   Inserter& endRow();
 
   bool isOpen() const noexcept;
 
   void execute();
 
   void close() noexcept;
 
   private:
   void newChunk() noexcept;
 
   void sendChunk();
 
   private:
   hyperapi::TableDefinition tableDefinition;
   internal::HyperTableDefinition tableDefinitionHandle;
   hyperapi::TableDefinition streamDefinition;
   internal::HyperTableDefinition streamDefinitionHandle;
   hyper_inserter_t* inserter = nullptr;
   std::vector<uint8_t> currentChunk;
   size_t chunkOffset = 0;
   size_t headerSize = 0;
   hyper_field_index_t currentField = 0;
   std::string selectList;
 
   friend class InserterTest;
   friend struct internal::ValueInserter;
};
}
 
#include <hyperapi/impl/Inserter.impl.hpp>
 
#endif