mssql

package

v0.11.310 Latest Latest Go to latest Published: Oct 7, 2025 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/bruin-data/bruin

Links

Open Source Insights

Documentation ¶

Index ¶

func NewColumnCheckOperator(manager config.ConnectionGetter) *ansisql.ColumnCheckOperator
func NewMaterializer(fullRefresh bool) *pipeline.Materializer
type AcceptedValuesCheck
- func (c *AcceptedValuesCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error
type BasicOperator
- func NewBasicOperator(conn config.ConnectionGetter, extractor query.QueryExtractor, ...) *BasicOperator
- func (o BasicOperator) Run(ctx context.Context, ti scheduler.TaskInstance) error
- func (o BasicOperator) RunTask(ctx context.Context, p *pipeline.Pipeline, t *pipeline.Asset) error
type Config
- func (c *Config) GetIngestrURI() string
- func (c *Config) ToDBConnectionURI() string
type DB
- func NewDB(c *Config) (*DB, error)
type Limiter
type MsClient
type PatternCheck
- func (c *PatternCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error
type UniqueCheck
- func NewUniqueCheck(conn config.ConnectionGetter) *UniqueCheck
- func (c *UniqueCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewColumnCheckOperator ¶

func NewColumnCheckOperator(manager config.ConnectionGetter) *ansisql.ColumnCheckOperator

func NewMaterializer ¶

func NewMaterializer(fullRefresh bool) *pipeline.Materializer

Types ¶

type AcceptedValuesCheck ¶

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

func (*AcceptedValuesCheck) Check ¶

func (c *AcceptedValuesCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error

type BasicOperator ¶

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

func NewBasicOperator ¶

func NewBasicOperator(conn config.ConnectionGetter, extractor query.QueryExtractor, materializer materializer) *BasicOperator

func (BasicOperator) Run ¶

func (o BasicOperator) Run(ctx context.Context, ti scheduler.TaskInstance) error

func (BasicOperator) RunTask ¶

func (o BasicOperator) RunTask(ctx context.Context, p *pipeline.Pipeline, t *pipeline.Asset) error

type Config ¶

type Config struct {
	Username string
	Password string
	Host     string
	Port     int
	Database string
	Query    string
}

func (*Config) GetIngestrURI ¶ added in v0.7.0

func (c *Config) GetIngestrURI() string

func (*Config) ToDBConnectionURI ¶

func (c *Config) ToDBConnectionURI() string

type DB ¶

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

func NewDB ¶

func NewDB(c *Config) (*DB, error)

func (*DB) BuildTableExistsQuery ¶ added in v0.11.296

func (db *DB) BuildTableExistsQuery(tableName string) (string, error)

func (*DB) GetColumns ¶ added in v0.11.247

func (db *DB) GetColumns(ctx context.Context, databaseName, tableName string) ([]*ansisql.DBColumn, error)

func (*DB) GetDatabaseSummary ¶ added in v0.11.260

func (db *DB) GetDatabaseSummary(ctx context.Context) (*ansisql.DBDatabase, error)

func (*DB) GetDatabases ¶ added in v0.11.247

func (db *DB) GetDatabases(ctx context.Context) ([]string, error)

func (*DB) GetIngestrURI ¶ added in v0.7.0

func (db *DB) GetIngestrURI() (string, error)

func (*DB) GetTables ¶ added in v0.11.247

func (db *DB) GetTables(ctx context.Context, databaseName string) ([]string, error)

func (*DB) Limit ¶ added in v0.11.144

func (db *DB) Limit(query string, limit int64) string

func (*DB) Ping ¶ added in v0.11.274

func (db *DB) Ping(ctx context.Context) error

func (*DB) RunQueryWithoutResult ¶

func (db *DB) RunQueryWithoutResult(ctx context.Context, query *query.Query) error

func (*DB) Select ¶

func (db *DB) Select(ctx context.Context, query *query.Query) ([][]interface{}, error)

func (*DB) SelectWithSchema ¶ added in v0.11.274

func (db *DB) SelectWithSchema(ctx context.Context, queryObj *query.Query) (*query.QueryResult, error)

type Limiter ¶ added in v0.11.144

type Limiter interface {
	Limit(query string, limit int64) string
}

type MsClient ¶

type MsClient interface {
	RunQueryWithoutResult(ctx context.Context, query *query.Query) error
	Select(ctx context.Context, query *query.Query) ([][]interface{}, error)
}

type PatternCheck ¶ added in v0.10.1

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

func (*PatternCheck) Check ¶ added in v0.10.1

func (c *PatternCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error

type UniqueCheck ¶ added in v0.11.23

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

func NewUniqueCheck ¶ added in v0.11.23

func NewUniqueCheck(conn config.ConnectionGetter) *UniqueCheck

func (*UniqueCheck) Check ¶ added in v0.11.23

func (c *UniqueCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL