mssql

package
v1.12.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 15, 2023 License: AGPL-3.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ColumnsWithDataTypes

func ColumnsWithDataTypes(columns model.TableSchema, prefix string) string

func Connect

func Connect(cred credentials) (*sql.DB, error)

Types

type MSSQL added in v1.7.0

type MSSQL struct {
	DB            *sql.DB
	Namespace     string
	ObjectStorage string
	Warehouse     model.Warehouse
	Uploader      warehouseutils.Uploader

	LoadFileDownLoader downloader.Downloader
	// contains filtered or unexported fields
}

func New added in v1.8.0

func New(conf *config.Config, log logger.Logger) *MSSQL

func (*MSSQL) AddColumns added in v1.7.0

func (ms *MSSQL) AddColumns(ctx context.Context, tableName string, columnsInfo []warehouseutils.ColumnInfo) (err error)

func (*MSSQL) AlterColumn added in v1.7.0

func (*MSSQL) Cleanup added in v1.7.0

func (ms *MSSQL) Cleanup(ctx context.Context)

func (*MSSQL) Connect added in v1.7.0

func (ms *MSSQL) Connect(_ context.Context, warehouse model.Warehouse) (client.Client, error)

func (*MSSQL) CrashRecover added in v1.7.0

func (ms *MSSQL) CrashRecover(ctx context.Context)

func (*MSSQL) CreateSchema added in v1.7.0

func (ms *MSSQL) CreateSchema(ctx context.Context) (err error)

func (*MSSQL) CreateTable added in v1.7.0

func (ms *MSSQL) CreateTable(ctx context.Context, tableName string, columnMap model.TableSchema) (err error)

func (*MSSQL) DeleteBy added in v1.7.0

func (ms *MSSQL) DeleteBy(ctx context.Context, tableNames []string, params warehouseutils.DeleteByParams) (err error)

func (*MSSQL) DownloadIdentityRules added in v1.7.0

func (*MSSQL) DownloadIdentityRules(context.Context, *misc.GZipWriter) (err error)

func (*MSSQL) DropTable added in v1.7.0

func (ms *MSSQL) DropTable(ctx context.Context, tableName string) (err error)

func (*MSSQL) ErrorMappings added in v1.7.0

func (*MSSQL) ErrorMappings() []model.JobError

func (*MSSQL) FetchSchema added in v1.7.0

func (ms *MSSQL) FetchSchema(ctx context.Context) (model.Schema, model.Schema, error)

FetchSchema queries mssql and returns the schema associated with provided namespace

func (*MSSQL) GetTotalCountInTable added in v1.7.0

func (ms *MSSQL) GetTotalCountInTable(ctx context.Context, tableName string) (int64, error)

func (*MSSQL) IsEmpty added in v1.7.0

func (*MSSQL) IsEmpty(context.Context, model.Warehouse) (empty bool, err error)

func (*MSSQL) LoadIdentityMappingsTable added in v1.7.0

func (*MSSQL) LoadIdentityMappingsTable(context.Context) (err error)

func (*MSSQL) LoadIdentityMergeRulesTable added in v1.7.0

func (*MSSQL) LoadIdentityMergeRulesTable(context.Context) (err error)

func (*MSSQL) LoadTable added in v1.7.0

func (ms *MSSQL) LoadTable(ctx context.Context, tableName string) error

func (*MSSQL) LoadTestTable added in v1.7.0

func (ms *MSSQL) LoadTestTable(ctx context.Context, _, tableName string, payloadMap map[string]interface{}, _ string) (err error)

func (*MSSQL) LoadUserTables added in v1.7.0

func (ms *MSSQL) LoadUserTables(ctx context.Context) map[string]error

func (*MSSQL) SetConnectionTimeout added in v1.7.0

func (ms *MSSQL) SetConnectionTimeout(timeout time.Duration)

func (*MSSQL) Setup added in v1.7.0

func (ms *MSSQL) Setup(_ context.Context, warehouse model.Warehouse, uploader warehouseutils.Uploader) (err error)

func (*MSSQL) TestConnection added in v1.7.0

func (ms *MSSQL) TestConnection(ctx context.Context, _ model.Warehouse) error

Jump to

Keyboard shortcuts

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