adapters

Documentation

Index

• func NewClickhouseDbqDataSourceAdapter(cnn driver.Conn, logger *slog.Logger) dbqcore.DbqDataSourceAdapter
• func NewMysqlDbqDataSourceAdapter(db *sql.DB, logger *slog.Logger) dbqcore.DbqDataSourceAdapter
• func NewPostgresqlDbqDataSourceAdapter(db *sql.DB, logger *slog.Logger) dbqcore.DbqDataSourceAdapter
• type ClickhouseDbqDataSourceAdapter
  • func (a *ClickhouseDbqDataSourceAdapter) ExecuteQuery(ctx context.Context, query string) (interface{}, error)
  • func (a *ClickhouseDbqDataSourceAdapter) InterpretDataQualityCheck(check *dbqcore.DataQualityCheck, dataset string, whereClause string) (string, error)
• type MysqlDbqDataSourceAdapter
  • func (a *MysqlDbqDataSourceAdapter) ExecuteQuery(ctx context.Context, query string) (interface{}, error)
  • func (a *MysqlDbqDataSourceAdapter) InterpretDataQualityCheck(check *dbqcore.DataQualityCheck, dataset string, whereClause string) (string, error)
• type PostgresqlDbqDataSourceAdapter
  • func (a *PostgresqlDbqDataSourceAdapter) ExecuteQuery(ctx context.Context, query string) (interface{}, error)
  • func (a *PostgresqlDbqDataSourceAdapter) InterpretDataQualityCheck(check *dbqcore.DataQualityCheck, dataset string, whereClause string) (string, error)

Functions

func NewClickhouseDbqDataSourceAdapter

func NewClickhouseDbqDataSourceAdapter(cnn driver.Conn, logger *slog.Logger) dbqcore.DbqDataSourceAdapter

func NewMysqlDbqDataSourceAdapter

func NewMysqlDbqDataSourceAdapter(db *sql.DB, logger *slog.Logger) dbqcore.DbqDataSourceAdapter

func NewPostgresqlDbqDataSourceAdapter

func NewPostgresqlDbqDataSourceAdapter(db *sql.DB, logger *slog.Logger) dbqcore.DbqDataSourceAdapter

Types

type ClickhouseDbqDataSourceAdapter

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

func (*ClickhouseDbqDataSourceAdapter) ExecuteQuery

func (a *ClickhouseDbqDataSourceAdapter) ExecuteQuery(ctx context.Context, query string) (interface{}, error)

func (*ClickhouseDbqDataSourceAdapter) InterpretDataQualityCheck

func (a *ClickhouseDbqDataSourceAdapter) InterpretDataQualityCheck(check *dbqcore.DataQualityCheck, dataset string, whereClause string) (string, error)

type MysqlDbqDataSourceAdapter

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

func (*MysqlDbqDataSourceAdapter) ExecuteQuery

func (a *MysqlDbqDataSourceAdapter) ExecuteQuery(ctx context.Context, query string) (interface{}, error)

func (*MysqlDbqDataSourceAdapter) InterpretDataQualityCheck

func (a *MysqlDbqDataSourceAdapter) InterpretDataQualityCheck(check *dbqcore.DataQualityCheck, dataset string, whereClause string) (string, error)

type PostgresqlDbqDataSourceAdapter

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

func (*PostgresqlDbqDataSourceAdapter) ExecuteQuery

func (a *PostgresqlDbqDataSourceAdapter) ExecuteQuery(ctx context.Context, query string) (interface{}, error)

func (*PostgresqlDbqDataSourceAdapter) InterpretDataQualityCheck

func (a *PostgresqlDbqDataSourceAdapter) InterpretDataQualityCheck(check *dbqcore.DataQualityCheck, dataset string, whereClause string) (string, error)