Documentation
¶
Index ¶
- type ClickHouseDatabase
- func (c *ClickHouseDatabase) ExecuteSql(sql string) (map[string]interface{}, error)
- func (c *ClickHouseDatabase) GetSourceDatabases() ([]string, error)
- func (c *ClickHouseDatabase) GetSourceTableColumns(database, table string) ([]Column, error)
- func (c *ClickHouseDatabase) GetSourceTables(database string) ([]string, error)
- type Column
- type IColumn
- type IDatabase
- type MysqlDatabase
- func (m *MysqlDatabase) ExecuteSql(sqlSentence string) (map[string]interface{}, error)
- func (m *MysqlDatabase) GetSourceDatabases() ([]string, error)
- func (m *MysqlDatabase) GetSourceTableColumns(database string, table string) ([]Column, error)
- func (m *MysqlDatabase) GetSourceTables(database string) ([]string, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClickHouseDatabase ¶
type ClickHouseDatabase struct {
// contains filtered or unexported fields
}
func NewClickHouseDatabase ¶
func NewClickHouseDatabase(user, password, address, port string) (*ClickHouseDatabase, error)
func (*ClickHouseDatabase) ExecuteSql ¶
func (c *ClickHouseDatabase) ExecuteSql(sql string) (map[string]interface{}, error)
todo clickhouse impl 未完成
func (*ClickHouseDatabase) GetSourceDatabases ¶
func (c *ClickHouseDatabase) GetSourceDatabases() ([]string, error)
func (*ClickHouseDatabase) GetSourceTableColumns ¶
func (c *ClickHouseDatabase) GetSourceTableColumns(database, table string) ([]Column, error)
func (*ClickHouseDatabase) GetSourceTables ¶
func (c *ClickHouseDatabase) GetSourceTables(database string) ([]string, error)
type IDatabase ¶
type IDatabase interface {
GetSourceDatabases() ([]string, error)
GetSourceTables(database string) ([]string, error)
GetSourceTableColumns(database string, table string) ([]Column, error)
ExecuteSql(sql string) (map[string]interface{}, error)
}
func GetDatabaseInstance ¶
type MysqlDatabase ¶
type MysqlDatabase struct {
// contains filtered or unexported fields
}
func NewMysqlDatabase ¶
func NewMysqlDatabase(user, password, address, port string) (*MysqlDatabase, error)
func (*MysqlDatabase) ExecuteSql ¶
func (m *MysqlDatabase) ExecuteSql(sqlSentence string) (map[string]interface{}, error)
func (*MysqlDatabase) GetSourceDatabases ¶
func (m *MysqlDatabase) GetSourceDatabases() ([]string, error)
func (*MysqlDatabase) GetSourceTableColumns ¶
func (m *MysqlDatabase) GetSourceTableColumns(database string, table string) ([]Column, error)
func (*MysqlDatabase) GetSourceTables ¶
func (m *MysqlDatabase) GetSourceTables(database string) ([]string, error)
Click to show internal directories.
Click to hide internal directories.