duckdb

Documentation

Index

• type DuckDBServer
  • func OpenServer(settings map[string]any) (*DuckDBServer, error)
  • func (s *DuckDBServer) Close() error
  • func (b *DuckDBServer) Columns(table string) ([]models.Column, error)
  • func (s *DuckDBServer) CreateColumns(table string, fileName string) error
  • func (s *DuckDBServer) CreateEmptyTable(table string) error
  • func (s *DuckDBServer) InsertFromNDJsonFile(table string, fileName string) error
  • func (s *DuckDBServer) QueryCSV(query string, writer io.Writer) error
  • func (s *DuckDBServer) QueryJSON(query string, writer io.Writer) error
  • func (s *DuckDBServer) QueryJSONString(query string, writer io.Writer) error
  • func (s *DuckDBServer) QueryNDJson(query string, writer io.Writer) error
  • func (s *DuckDBServer) QueryPipe(query string, format string, writer io.Writer) error
  • func (b *DuckDBServer) Tables() ([]string, error)

Types

type DuckDBServer

type DuckDBServer struct {
	Database string `mapstructure:"database" schema:"database" form:"label:Database Name,type:text"`
	Token    string `mapstructure:"token" schema:"token" form:"label:MotherDuck Token,type:password"`

	File string `mapstructure:"file"`

	InMemory bool `mapstructure:"in_memory"`

	MaxOpenConns        int `mapstructure:"max_open_conns"`
	MaxIdleConns        int `mapstructure:"max_idle_conns"`
	ConnMaxLifetimeSecs int `mapstructure:"conn_max_lifetime_secs"`
	// contains filtered or unexported fields
}

func OpenServer

func OpenServer(settings map[string]any) (*DuckDBServer, error)

func (*DuckDBServer) Close

func (s *DuckDBServer) Close() error

func (*DuckDBServer) Columns

func (b *DuckDBServer) Columns(table string) ([]models.Column, error)

func (*DuckDBServer) CreateColumns

func (s *DuckDBServer) CreateColumns(table string, fileName string) error

func (*DuckDBServer) CreateEmptyTable

func (s *DuckDBServer) CreateEmptyTable(table string) error

func (*DuckDBServer) InsertFromNDJsonFile

func (s *DuckDBServer) InsertFromNDJsonFile(table string, fileName string) error

func (*DuckDBServer) QueryCSV

func (s *DuckDBServer) QueryCSV(query string, writer io.Writer) error

func (*DuckDBServer) QueryJSON

func (s *DuckDBServer) QueryJSON(query string, writer io.Writer) error

func (*DuckDBServer) QueryJSONString

func (s *DuckDBServer) QueryJSONString(query string, writer io.Writer) error

func (*DuckDBServer) QueryNDJson

func (s *DuckDBServer) QueryNDJson(query string, writer io.Writer) error

func (*DuckDBServer) QueryPipe

func (s *DuckDBServer) QueryPipe(query string, format string, writer io.Writer) error

func (*DuckDBServer) Tables

func (b *DuckDBServer) Tables() ([]string, error)