extractdb

Documentation

Index

• func ClusterIDs(uniqueIDList map[int]string, clusterSize int, IDDataTypeString bool) map[int]string
• func Deduplicate(IDLists []map[int]string) map[int]string
• func EventToResourceIDs(ctx context.Context, db *sql.DB, fh *sql.DB, sourceTable string, ...) map[int]string
• func LsnMax(ctx context.Context, db *sql.DB) string
• func MsSQLInit(connectionName string, ConnMaxLifetimeHours int, MaxIdleConns int, ...) (*sql.DB, context.Context)

Functions

func ClusterIDs

func ClusterIDs(uniqueIDList map[int]string, clusterSize int, IDDataTypeString bool) map[int]string

ClusterIDs serialises ID's for 'IN' clause in SQL-statement, E.g. 1234','2345','3456','5678

func Deduplicate

func Deduplicate(IDLists []map[int]string) map[int]string

Deduplicate receives multiple maps of ID's and returns a single map containing unique values

func EventToResourceIDs

func EventToResourceIDs(ctx context.Context, db *sql.DB, fh *sql.DB, sourceTable string, srcLsnMax string, srcQuery string) map[int]string

EventToResourceIDs load CDC rows and return a map

func LsnMax

func LsnMax(ctx context.Context, db *sql.DB) string

LsnMax fetch max Lsn in source database

func MsSQLInit

func MsSQLInit(connectionName string, ConnMaxLifetimeHours int, MaxIdleConns int, MaxOpenConns int) (*sql.DB, context.Context)

MsSQLInit checks connection (ping) and sets, e.g., maximum amount of concurrent connection