load

Documentation

Index

• func AddTickerColumn(csvData []byte, ticker string) ([]byte, error)
• type DuckDB
  • func NewDuckDB(config *config.Config, logger *slog.Logger) (*DuckDB, error)
  • func (db *DuckDB) Close()
  • func (db *DuckDB) GetQueryResults(query string) (map[string][]string, error)
  • func (db *DuckDB) GetQueryResultsFromFile(path string) (map[string][]string, error)
  • func (db *DuckDB) LoadCSV(csv []byte, table string, insert bool) error
  • func (db *DuckDB) RunQuery(query string) error
  • func (db *DuckDB) RunQueryFile(path string) error

Functions

func AddTickerColumn

func AddTickerColumn(csvData []byte, ticker string) ([]byte, error)

Types

type DuckDB

type DuckDB struct {
	Logger    *slog.Logger
	DB        *sql.DB
	Connector *duckdb.Connector
	Conn      driver.Conn
	Appender  *duckdb.Appender
	DBType    string
}

func NewDuckDB

func NewDuckDB(config *config.Config, logger *slog.Logger) (*DuckDB, error)

func (*DuckDB) Close

func (db *DuckDB) Close()

func (*DuckDB) GetQueryResults

func (db *DuckDB) GetQueryResults(query string) (map[string][]string, error)

GetQueryResults executes a query and returns the results as a map of column names to slices of values

func (*DuckDB) GetQueryResultsFromFile

func (db *DuckDB) GetQueryResultsFromFile(path string) (map[string][]string, error)

func (*DuckDB) LoadCSV

func (db *DuckDB) LoadCSV(csv []byte, table string, insert bool) error

func (*DuckDB) RunQuery

func (db *DuckDB) RunQuery(query string) error

func (*DuckDB) RunQueryFile

func (db *DuckDB) RunQueryFile(path string) error