csvzall::postgres Namespace Reference

Classes
struct	ConnectionConfig
struct	CopyResult
struct	ExportResult
struct	InferredColumn
struct	InferredSchema
struct	LoadOptions
struct	LogCallbacks
class	PostgresConnection
class	RowLoader
class	SchemaInference

Enumerations
enum class	IfExistsMode { kError , kDrop , kAppend }
enum class	ColumnType {   INTEGER , BIGINT , NUMERIC , TIMESTAMP ,   TEXT }

Functions
IfExistsMode	ParseIfExistsMode (const std::string &mode_str)
void	DumpInferredSchema (const LogCallbacks &logger, const std::string &table_name, const std::vector< InferredColumn > &inferred_columns, const std::size_t observed_rows)
InferredSchema	InferSchema (csv::CSVReader &reader, const std::vector< std::string > &headers, const LogCallbacks &logger)
void	CopyRowsWithPipeline (csv::CSVReader &reader, RowLoader &loader, const LogCallbacks &logger, const std::uint64_t total_rows, const std::size_t chunk_size)
CopyResult	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	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)
std::string	QuoteIdentifier (const std::string &identifier)
bool	TableExists (pqxx::connection &conn, const std::string &table_name)
void	DropTableIfExists (pqxx::connection &conn, const std::string &table_name)
std::string	ColumnTypeToString (ColumnType type)

Enumeration Type Documentation

ColumnType

enum class csvzall::postgres::ColumnType

strong

Enumerator
INTEGER
BIGINT
NUMERIC
TIMESTAMP
TEXT

IfExistsMode

enum class csvzall::postgres::IfExistsMode

strong

Enumerator
kError
kDrop
kAppend

Function Documentation

ColumnTypeToString()

std::string csvzall::postgres::ColumnTypeToString

(

ColumnType

type

)

CopyRowsWithParallelWorkers()

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
	)

CopyRowsWithPipeline()

void csvzall::postgres::CopyRowsWithPipeline	(	csv::CSVReader &	reader,
		RowLoader &	loader,
		const LogCallbacks &	logger,
		const std::uint64_t	total_rows,
		const std::size_t	chunk_size
	)

DropTableIfExists()

void csvzall::postgres::DropTableIfExists	(	pqxx::connection &	conn,
		const std::string &	table_name
	)

DumpInferredSchema()

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

ExportCsvToPostgres()

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
	)

InferSchema()

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

ParseIfExistsMode()

IfExistsMode csvzall::postgres::ParseIfExistsMode

(

const std::string &

mode_str

)

QuoteIdentifier()

std::string csvzall::postgres::QuoteIdentifier

(

const std::string &

identifier

)

TableExists()

bool csvzall::postgres::TableExists	(	pqxx::connection &	conn,
		const std::string &	table_name
	)