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/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