chutils

Documentation

Index

• func ConvertColumn(w utils.Writer, column *config.PgColumn, tupleData *message.Tuple, ...) error
• func ToClickHouseType(pgColumn *config.PgColumn) (string, error)
• type CHConn
  • func MakeChConnection(c *config.CHConnConfig, useGzip bool) *CHConn
  • func (c *CHConn) Exec(query string) error
  • func (c *CHConn) PerformInsert(tableName config.ChTableName, columns []string, reqBody io.Reader) error
  • func (c *CHConn) Query(query string) ([][]string, error)
• type CHConnector

Functions

func ConvertColumn

func ConvertColumn(w utils.Writer, column *config.PgColumn, tupleData *message.Tuple, colProp *config.ColumnProperty) error

func ToClickHouseType

func ToClickHouseType(pgColumn *config.PgColumn) (string, error)

ToClickHouseType converts pg type into ClickHouse type

Types

type CHConn

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

ClickHouse connection

func MakeChConnection

func MakeChConnection(c *config.CHConnConfig, useGzip bool) *CHConn

Make new ClickHouse connection. For HTTP it just makes URL

func (*CHConn) Exec

func (c *CHConn) Exec(query string) error

Make command without results, sends SQL command as body

func (*CHConn) PerformInsert

func (c *CHConn) PerformInsert(tableName config.ChTableName, columns []string, reqBody io.Reader) error

Make INSERT command, sends SQL command as query parameter

func (*CHConn) Query

func (c *CHConn) Query(query string) ([][]string, error)

type CHConnector

type CHConnector interface {
	Exec(string) error
	PerformInsert(config.ChTableName, []string, io.Reader) error
	Query(string) ([][]string, error)
}