#include "exporter.hpp"
#include <condition_variable>
#include <deque>
#include <exception>
#include <mutex>
#include <sstream>
#include <stdexcept>
#include <thread>
#include <utility>

Namespaces
namespace	csvzall

namespace	csvzall::postgres

Functions
IfExistsMode	csvzall::postgres::ParseIfExistsMode (const std::string &mode_str)

void	csvzall::postgres::DumpInferredSchema (const LogCallbacks &logger, const std::string &table_name, const std::vector< InferredColumn > &inferred_columns, const std::size_t observed_rows)

InferredSchema	csvzall::postgres::InferSchema (csv::CSVReader &reader, const std::vector< std::string > &headers, const LogCallbacks &logger)

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)

Namespaces

Functions