Documentation
¶
Index ¶
- func NewColumnCheckOperator(manager config.ConnectionGetter) *ansisql.ColumnCheckOperator
- func NewMaterializer(fullRefresh bool) *pipeline.Materializer
- func QuoteIdentifier(identifier string) string
- type AcceptedValuesCheck
- type BasicOperator
- type Config
- type DB
- func (db *DB) Close() error
- func (db *DB) GetIngestrURI() (string, error)
- func (db *DB) Ping(ctx context.Context) error
- func (db *DB) RunQueryWithoutResult(ctx context.Context, q *query.Query) error
- func (db *DB) Select(ctx context.Context, q *query.Query) ([][]interface{}, error)
- func (db *DB) SelectWithSchema(ctx context.Context, queryObj *query.Query) (*query.QueryResult, error)
- type MaxCheck
- type MinCheck
- type NegativeCheck
- type NonNegativeCheck
- type NotNullCheck
- type PatternCheck
- type PositiveCheck
- type UniqueCheck
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
func QuoteIdentifier ¶
QuoteIdentifier quotes a Fabric identifier using square brackets. Fabric is case-sensitive, so proper quoting is important.
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) GetConnection ¶
func (o BasicOperator) GetConnection() (config.ConnectionGetter, bool)
func (BasicOperator) Run ¶
func (o BasicOperator) Run(ctx context.Context, ti scheduler.TaskInstance) error
type Config ¶
type Config struct {
Username string
Password string
Host string
Port int
Database string
Options string
UseAzureDefaultCredential bool
ClientID string
ClientSecret string
TenantID string
}
func (*Config) DriverName ¶
func (*Config) GetIngestrURI ¶
func (*Config) ToDBConnectionURI ¶
type DB ¶
type DB struct {
// contains filtered or unexported fields
}
func (*DB) GetIngestrURI ¶
func (*DB) RunQueryWithoutResult ¶
func (*DB) SelectWithSchema ¶
type NegativeCheck ¶
type NegativeCheck struct {
// contains filtered or unexported fields
}
func (*NegativeCheck) Check ¶
func (c *NegativeCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error
type NonNegativeCheck ¶
type NonNegativeCheck struct {
// contains filtered or unexported fields
}
func (*NonNegativeCheck) Check ¶
func (c *NonNegativeCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error
type NotNullCheck ¶
type NotNullCheck struct {
// contains filtered or unexported fields
}
func (*NotNullCheck) Check ¶
func (c *NotNullCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error
type PatternCheck ¶
type PatternCheck struct {
// contains filtered or unexported fields
}
func (*PatternCheck) Check ¶
func (c *PatternCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error
type PositiveCheck ¶
type PositiveCheck struct {
// contains filtered or unexported fields
}
func (*PositiveCheck) Check ¶
func (c *PositiveCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error
type UniqueCheck ¶
type UniqueCheck struct {
// contains filtered or unexported fields
}
func (*UniqueCheck) Check ¶
func (c *UniqueCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error
Click to show internal directories.
Click to hide internal directories.