clickhouse

Documentation

Overview

Package clickhouse contains code specific for ClickHouse database.

Index

• func NewConnectionManager(cfg utils.ConnectionManagerBase) utils.ConnectionManager
• func NewSQLFormatter() utils.SQLFormatter
• func NewTypeMapper() utils.TypeMapper
• type Connection
  • func (c Connection) Query(ctx context.Context, query string, args ...any) (utils.Rows, error)
• type Transformer
  • func (t Transformer) AppendToArrowBuilders(builders []array.Builder) error
  • func (t Transformer) GetAcceptors() []any

Functions

func NewConnectionManager

func NewConnectionManager(cfg utils.ConnectionManagerBase) utils.ConnectionManager

func NewSQLFormatter

func NewSQLFormatter() utils.SQLFormatter

func NewTypeMapper

func NewTypeMapper() utils.TypeMapper

Types

type Connection

type Connection struct {
	*sql.DB
	// contains filtered or unexported fields
}

func (Connection) Query

func (c Connection) Query(ctx context.Context, query string, args ...any) (utils.Rows, error)

type Transformer

type Transformer struct {
	// contains filtered or unexported fields
}

func (Transformer) AppendToArrowBuilders

func (t Transformer) AppendToArrowBuilders(builders []array.Builder) error

func (Transformer) GetAcceptors

func (t Transformer) GetAcceptors() []any