clickhouse

Documentation

Overview

Package clickhouse contains code specific for ClickHouse database.

Index

• func GetQueryAndArgs(request *api_service_protos.TDescribeTableRequest) (string, []any)
• func NewConnectionManager(cfg rdbms_utils.ConnectionManagerBase) rdbms_utils.ConnectionManager
• func NewSQLFormatter() rdbms_utils.SQLFormatter
• func NewTypeMapper() utils.TypeMapper
• type Connection
  • func (c Connection) Query(ctx context.Context, query string, args ...any) (rdbms_utils.Rows, error)

Functions

func GetQueryAndArgs

func GetQueryAndArgs(request *api_service_protos.TDescribeTableRequest) (string, []any)

func NewConnectionManager

func NewConnectionManager(cfg rdbms_utils.ConnectionManagerBase) rdbms_utils.ConnectionManager

func NewSQLFormatter

func NewSQLFormatter() rdbms_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) (rdbms_utils.Rows, error)