databricks

package

v0.16.0-rc1 Latest Latest Go to latest Published: Jul 10, 2026 License: Apache-2.0 Imports: 16 Imported by: 0

Details

This section is empty.

This section is empty.

func IsPermissionError(err error) bool

IsPermissionError reports whether err indicates the DWH credentials lack the privileges required for the attempted operation.

func NewQuerier[T any](conn *DatabricksExecutor) querier.Querier[T]

type Auth interface {
	Configure(config *databricks.Config)
}

type DatabricksConf struct {
	WorkspaceUrl string
	Auth         Auth
	WarehouseId  string
}

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

func NewDatabricksExecutor(ctx context.Context, conf *DatabricksConf) (*DatabricksExecutor, error)

func (e *DatabricksExecutor) Close() error

func (e *DatabricksExecutor) Exec(ctx context.Context, query string, args ...any) error

func (e *DatabricksExecutor) GetDb() *sqlx.DB

func (e *DatabricksExecutor) QueryRows(ctx context.Context, sql string, args ...interface{}) (*sqlx.Rows, error)

func (e *DatabricksExecutor) Select(ctx context.Context, dest any, query string, args ...any) error

type Executor interface {
	stdsql.StdSqlExecutor
}

type OAuthM2mAuth struct {
	ClientId     string
	ClientSecret string
}

func NewOAuthM2mAuth(clientId, clientSecret string) *OAuthM2mAuth

func (o OAuthM2mAuth) Configure(config *databricks.Config)

type TokenAuth struct {
	Token string
}

func NewTokenAuth(token string) *TokenAuth

func (t TokenAuth) Configure(config *databricks.Config)