store

type Column struct {
	Name      string `json:"name"`
	FieldName string `json:"fieldName"`
}

type DataSource struct {
	DatabaseConnConfig
	Query string
}

type DatabaseConfig struct {
	DatabaseGroup
	DatabaseConnConfig
	DatabaseConnPoolConfig
}

type DatabaseConnConfig struct {
	Hostname string `db:"hostname"`
	Port     int    `db:"port"`
	Name     string `db:"name"`
	Username string `db:"username"`
	Password string `db:"password"`
	Type     string `db:"type"`
}

type DatabaseConnPoolConfig struct {
	MaxOpenConns             int `db:"maxOpenConns"`
	MaxIdleConns             int `db:"maxIdleConns"`
	ConnMaxLifetimeInSeconds int `db:"connMaxLifetimeInSeconds"`
	ConnMaxIdleTimeInSeconds int `db:"connMaxIdleTimeInSeconds"`
}

type DatabaseGroup struct {
	GroupName string `db:"groupName" json:"groupName"`
	GroupType string `db:"groupType" json:"groupType"`
}

type DatabaseInstance struct {
	Config DatabaseConfig
	DB     *sqlx.DB
}

type DatabaseItem struct {
	DatabaseGroup
	Type string `json:"type"`
}

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

type DatabaseStoreI interface {
	AddDatabases(databases []DatabaseConfig)
	AddDatabase(config DatabaseConfig) error
	GetTablesMetadata(groupName string, groupType string) (map[string][]string, error)
	QueryDatabase(ctx context.Context, groupName string, groupType string, query string) GroupQueryResult
	QueryMultipleDatabases(ctx context.Context, groupType string, query string) []GroupQueryResult
	GetDatabaseItems() []DatabaseItem
}

type DatabaseStoreMock struct {
	AddDatabasesFunc           func(databases []DatabaseConfig)
	AddDatabaseFunc            func(config DatabaseConfig) error
	GetTablesMetadataFunc      func(groupName string, groupType string) (map[string][]string, error)
	QueryDatabaseFunc          func(ctx context.Context, groupName string, groupType string, query string) GroupQueryResult
	QueryMultipleDatabasesFunc func(ctx context.Context, groupType string, query string) []GroupQueryResult
	GetDatabaseItemsFunc       func() []DatabaseItem
}

type GroupQueryResult struct {
	GroupName string      `json:"groupName"`
	Data      *QueryData  `json:"data"`
	Error     *QueryError `json:"error"`
}

type QueryData struct {
	Columns []Column                 `json:"columns"`
	Rows    []map[string]interface{} `json:"rows"`
}

type QueryError struct {
	Message string `json:"message"`
	Err     error  `json:"err"`
}