pkg

type ConnectionParameterLayer struct {
	layers.ParameterLayerImpl
}

type DBConnectionFactory func() (*sqlx.DB, error)

type DatabaseConfig struct {
	Host            string
	Database        string
	User            string
	Password        string
	Port            int
	Schema          string
	Type            string
	DSN             string
	Driver          string
	DbtProfilesPath string
	DbtProfile      string
	UseDbtProfiles  bool
}

type DbtParameterLayer struct {
	layers.ParameterLayerImpl
}

type Source struct {
	Name     string
	Type     string `yaml:"type"`
	Hostname string `yaml:"server"`
	Port     int    `yaml:"port"`
	Username string `yaml:"username"`
	Password string `yaml:"password"`
	Schema   string `yaml:"schema"`
	Database string `yaml:"database"`
}

type SqlCommand struct {
	Query string
	// contains filtered or unexported fields
}

type SqlCommandDescription struct {
	Name      string                            `yaml:"name"`
	Short     string                            `yaml:"short"`
	Long      string                            `yaml:"long,omitempty"`
	Flags     []*parameters.ParameterDefinition `yaml:"flags,omitempty"`
	Arguments []*parameters.ParameterDefinition `yaml:"arguments,omitempty"`
	Layers    []layers.ParameterLayer           `yaml:"layers,omitempty"`

	Query string `yaml:"query"`
}

type SqlCommandLoader struct {
	DBConnectionFactory DBConnectionFactory
}

type SqletonCommand interface {
	cmds.Command
	RunQueryIntoGlaze(ctx context.Context, db *sqlx.DB, parameters map[string]interface{}, gp *cmds.GlazeProcessor) error
	RenderQuery(parameters map[string]interface{}) (string, error)
}