source

Apr 13, 2023

Changes in this version

+ type ClickHouse struct

+ func NewClickHouse(s *Source) *ClickHouse

+ func (c *ClickHouse) ClusterInfo() (isCluster, isShard, isReplica int, clusters []string, err error)

+ func (c *ClickHouse) Columns(database, table string) (res []view.Column, err error)

+ func (c *ClickHouse) Databases() (res []string, err error)

+ func (c *ClickHouse) Exec(s string) (err error)

+ func (c *ClickHouse) Query(s string) (res []map[string]interface{}, err error)

+ func (c *ClickHouse) Tables(database string) (res []string, err error)

+ type Databend struct

+ func NewDatabend(s *Source) *Databend

+ func (c *Databend) ClusterInfo() (isCluster, isShard, isReplica int, clusters []string, err error)

+ func (c *Databend) Columns(database, table string) (res []view.Column, err error)

+ func (c *Databend) Exec(s string) (err error)

+ func (c *Databend) Query(s string) (res []map[string]interface{}, err error)

+ func (c *Databend) Tables(database string) (res []string, err error)

+ func (d *Databend) Databases() (res []string, err error)

+ type MySQL struct

+ func NewMySQL(s *Source) *MySQL

+ func (c *MySQL) ClusterInfo() (isCluster, isShard, isReplica int, clusters []string, err error)

+ func (c *MySQL) Columns(database, table string) (res []view.Column, err error)

+ func (c *MySQL) Databases() (res []string, err error)

+ func (c *MySQL) Exec(s string) (err error)

+ func (c *MySQL) Query(s string) (res []map[string]interface{}, err error)

+ func (c *MySQL) Tables(database string) (res []string, err error)

+ type Operator interface

+ ClusterInfo func() (isCluster, isShard, isReplica int, clusters []string, err error)

+ Columns func(string, string) ([]view.Column, error)

+ Databases func() ([]string, error)

+ Exec func(s string) error

+ Query func(s string) (res []map[string]interface{}, err error)

+ Tables func(string) ([]string, error)

+ func Instantiate(s *Source) Operator

+ type Source struct

+ DSN string

+ Password string

+ Typ int

+ URL string

+ UserName string

+ func (s *Source) GetDSN() string