source

Documentation

Index

• type ClickHouse
  • func NewClickHouse(s *Source) *ClickHouse
  • func (c *ClickHouse) Columns(database, table string) (res []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 Column
• type MySQL
  • func NewMySQL(s *Source) *MySQL
  • func (c *MySQL) Columns(database, table string) (res []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
  • func Instantiate(s *Source) Operator
• type Source
  • func (s *Source) GetDSN() string

Types

type ClickHouse

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

func NewClickHouse

func NewClickHouse(s *Source) *ClickHouse

func (*ClickHouse) Columns

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

func (*ClickHouse) Databases

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

func (*ClickHouse) Exec

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

func (*ClickHouse) Query

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

func (*ClickHouse) Tables

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

type Column

type Column struct {
	Field string `json:"field"`
	Type  string `json:"type"`
}

type MySQL

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

func NewMySQL

func NewMySQL(s *Source) *MySQL

func (*MySQL) Columns

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

func (*MySQL) Databases

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

func (*MySQL) Exec

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

func (*MySQL) Query

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

func (*MySQL) Tables

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

type Operator

type Operator interface {
	Databases() ([]string, error)
	Tables(string) ([]string, error)
	Columns(string, string) ([]Column, error)
	Query(s string) (res []map[string]interface{}, err error)
	Exec(s string) error
}

func Instantiate

func Instantiate(s *Source) Operator

type Source

type Source struct {
	DSN      string
	URL      string
	UserName string
	Password string
	Typ      int
}

func (*Source) GetDSN

func (s *Source) GetDSN() string