exporter.hpp File Reference

#include "postgres_connection.hpp"
#include "row_loader.hpp"
#include "schema_inference.hpp"
#include <csv.hpp>
#include <cstddef>
#include <cstdint>
#include <functional>
#include <string>
#include <vector>

Go to the source code of this file.

Classes
struct	csvzall::postgres::LogCallbacks
struct	csvzall::postgres::LoadOptions
struct	csvzall::postgres::CopyResult
struct	csvzall::postgres::InferredSchema
struct	csvzall::postgres::ExportResult

Namespaces
namespace	csvzall
namespace	csvzall::postgres
namespace	csvzall::pipeline

Enumerations
enum class	csvzall::postgres::IfExistsMode { csvzall::postgres::kError , csvzall::postgres::kDrop , csvzall::postgres::kAppend }

Functions
IfExistsMode	csvzall::postgres::ParseIfExistsMode (const std::string &mode_str)
InferredSchema	csvzall::postgres::InferSchema (csv::CSVReader &reader, const std::vector< std::string > &headers, const LogCallbacks &logger)
void	csvzall::postgres::DumpInferredSchema (const LogCallbacks &logger, const std::string &table_name, const std::vector< InferredColumn > &inferred_columns, const std::size_t observed_rows)
void	csvzall::postgres::CopyRowsWithPipeline (csv::CSVReader &reader, RowLoader &loader, const LogCallbacks &logger, const std::uint64_t total_rows, const std::size_t chunk_size)
CopyResult	csvzall::postgres::CopyRowsWithParallelWorkers (csv::CSVReader &reader, const ConnectionConfig &pg_config, const std::string &table_name, const std::vector< InferredColumn > &columns, const LogCallbacks &logger, const std::uint64_t total_rows, const std::size_t chunk_size, const std::size_t worker_count)
ExportResult	csvzall::postgres::ExportCsvToPostgres (csv::CSVReader &reader, const std::vector< std::string > &headers, const std::function< int()> &reset_reader, const ConnectionConfig &pg_config, const std::string &table_name, const IfExistsMode if_exists_mode, const LoadOptions &options, const LogCallbacks &logger)