mssql

Documentation

Index

• func ColumnsWithDataTypes(columns model.TableSchema, prefix string) string
• func Connect(cred Credentials) (*sql.DB, error)
• func WithConfig(h *MSSQL, config *config.Config)
• type Credentials
• type MSSQL
  • func New() *MSSQL
  • func (ms *MSSQL) AddColumns(tableName string, columnsInfo []warehouseutils.ColumnInfo) (err error)
  • func (*MSSQL) AlterColumn(_, _, _ string) (model.AlterTableResponse, error)
  • func (ms *MSSQL) Cleanup()
  • func (ms *MSSQL) Connect(warehouse model.Warehouse) (client.Client, error)
  • func (ms *MSSQL) CrashRecover()
  • func (ms *MSSQL) CreateSchema() (err error)
  • func (ms *MSSQL) CreateTable(tableName string, columnMap model.TableSchema) (err error)
  • func (ms *MSSQL) DeleteBy(tableNames []string, params warehouseutils.DeleteByParams) (err error)
  • func (*MSSQL) DownloadIdentityRules(*misc.GZipWriter) (err error)
  • func (ms *MSSQL) DropTable(tableName string) (err error)
  • func (*MSSQL) ErrorMappings() []model.JobError
  • func (ms *MSSQL) FetchSchema() (model.Schema, model.Schema, error)
  • func (ms *MSSQL) GetTotalCountInTable(ctx context.Context, tableName string) (int64, error)
  • func (*MSSQL) IsEmpty(_ model.Warehouse) (empty bool, err error)
  • func (*MSSQL) LoadIdentityMappingsTable() (err error)
  • func (*MSSQL) LoadIdentityMergeRulesTable() (err error)
  • func (ms *MSSQL) LoadTable(ctx context.Context, tableName string) error
  • func (ms *MSSQL) LoadTestTable(_, tableName string, payloadMap map[string]interface{}, _ string) (err error)
  • func (ms *MSSQL) LoadUserTables(ctx context.Context) map[string]error
  • func (ms *MSSQL) SetConnectionTimeout(timeout time.Duration)
  • func (ms *MSSQL) Setup(warehouse model.Warehouse, uploader warehouseutils.Uploader) (err error)
  • func (ms *MSSQL) TestConnection(ctx context.Context, _ model.Warehouse) error

Functions

func ColumnsWithDataTypes

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

func Connect

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

func WithConfig

func WithConfig(h *MSSQL, config *config.Config)

Types

type Credentials

type Credentials struct {
	Host     string
	DBName   string
	User     string
	Password string
	Port     string
	SSLMode  string

	TunnelInfo *tunnelling.TunnelInfo
	// contains filtered or unexported fields
}

type MSSQL

type MSSQL struct {
	DB                          *sql.DB
	Namespace                   string
	ObjectStorage               string
	Warehouse                   model.Warehouse
	Uploader                    warehouseutils.Uploader
	ConnectTimeout              time.Duration
	EnableDeleteByJobs          bool
	Logger                      logger.Logger
	NumWorkersDownloadLoadFiles int
	LoadFileDownLoader          downloader.Downloader
}

func New

func New() *MSSQL

func (*MSSQL) AddColumns

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

func (*MSSQL) AlterColumn

func (*MSSQL) AlterColumn(_, _, _ string) (model.AlterTableResponse, error)

func (*MSSQL) Cleanup

func (ms *MSSQL) Cleanup()

func (*MSSQL) Connect

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

func (*MSSQL) CrashRecover

func (ms *MSSQL) CrashRecover()

func (*MSSQL) CreateSchema

func (ms *MSSQL) CreateSchema() (err error)

func (*MSSQL) CreateTable

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

func (*MSSQL) DeleteBy

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

func (*MSSQL) DownloadIdentityRules

func (*MSSQL) DownloadIdentityRules(*misc.GZipWriter) (err error)

func (*MSSQL) DropTable

func (ms *MSSQL) DropTable(tableName string) (err error)

func (*MSSQL) ErrorMappings

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

func (*MSSQL) FetchSchema

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

FetchSchema queries mssql and returns the schema associated with provided namespace

func (*MSSQL) GetTotalCountInTable

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

func (*MSSQL) IsEmpty

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

func (*MSSQL) LoadIdentityMappingsTable

func (*MSSQL) LoadIdentityMappingsTable() (err error)

func (*MSSQL) LoadIdentityMergeRulesTable

func (*MSSQL) LoadIdentityMergeRulesTable() (err error)

func (*MSSQL) LoadTable

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

func (*MSSQL) LoadTestTable

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

func (*MSSQL) LoadUserTables

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

func (*MSSQL) SetConnectionTimeout

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

func (*MSSQL) Setup

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

func (*MSSQL) TestConnection

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