Documentation ¶
Index ¶
- type ClickhouseServer
- func (s *ClickhouseServer) Close() error
- func (b *ClickhouseServer) Columns(table string) ([]models.Column, error)
- func (s *ClickhouseServer) CreateColumns(table string, filePath string) error
- func (s *ClickhouseServer) CreateEmptyTable(table string) error
- func (s *ClickhouseServer) InsertBatchFromNDJson(table string, input io.ReadSeeker) error
- func (s *ClickhouseServer) InsertFromNDJsonFile(table string, filePath string) error
- func (s *ClickhouseServer) QueryCSV(query string, writer io.Writer) error
- func (s *ClickhouseServer) QueryJSON(query string, writer io.Writer) error
- func (s *ClickhouseServer) QueryNDJson(query string, writer io.Writer) error
- func (b *ClickhouseServer) Tables() ([]string, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClickhouseServer ¶
type ClickhouseServer struct { Host string `mapstructure:"host" schema:"host" form:"label:Host,type:text"` Username string `mapstructure:"username" schema:"username" form:"label:Username,type:text"` Password string `mapstructure:"password" schema:"password" form:"label:Password,type:password"` Database string `mapstructure:"database" schema:"database" form:"label:Database Name,type:text,default:default"` HTTPProtocol string `mapstructure:"http_protocol" schema:"http_protocol" form:"label:HTTP Protocol,type:text,default:https"` HTTPPort int `mapstructure:"http_port" schema:"http_port" form:"label:HTTP Port,type:number,default:8443"` TCPPort int `mapstructure:"tcp_port" schema:"tcp_port" form:"label:TCP Port,type:number,default:9440"` TLS bool `mapstructure:"tls" schema:"tls" form:"label:TLS,type:bool,default:true"` StoragePolicy string `mapstructure:"storage_policy"` 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) (*ClickhouseServer, error)
func (*ClickhouseServer) Close ¶
func (s *ClickhouseServer) Close() error
func (*ClickhouseServer) Columns ¶ added in v1.0.9
func (b *ClickhouseServer) Columns(table string) ([]models.Column, error)
func (*ClickhouseServer) CreateColumns ¶ added in v1.0.3
func (s *ClickhouseServer) CreateColumns(table string, filePath string) error
func (*ClickhouseServer) CreateEmptyTable ¶ added in v1.0.3
func (s *ClickhouseServer) CreateEmptyTable(table string) error
func (*ClickhouseServer) InsertBatchFromNDJson ¶
func (s *ClickhouseServer) InsertBatchFromNDJson(table string, input io.ReadSeeker) error
func (*ClickhouseServer) InsertFromNDJsonFile ¶ added in v1.0.3
func (s *ClickhouseServer) InsertFromNDJsonFile(table string, filePath string) error
func (*ClickhouseServer) QueryCSV ¶ added in v1.0.4
func (s *ClickhouseServer) QueryCSV(query string, writer io.Writer) error
func (*ClickhouseServer) QueryJSON ¶
func (s *ClickhouseServer) QueryJSON(query string, writer io.Writer) error
func (*ClickhouseServer) QueryNDJson ¶ added in v1.0.11
func (s *ClickhouseServer) QueryNDJson(query string, writer io.Writer) error
func (*ClickhouseServer) Tables ¶ added in v1.0.9
func (b *ClickhouseServer) Tables() ([]string, error)
Click to show internal directories.
Click to hide internal directories.