mssql

package
v0.13.0 Latest Latest
Warning

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

Go to latest
Published: Apr 19, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

README

Microsoft SQL Server

Extract table metadata from Microsoft SQL Server databases.

Usage

source:
  name: mssql
  config:
    connection_url: sqlserver://admin:pass123@localhost:1433/
    exclude:
      databases:
        - database_a
        - database_b
      tables:
        - database_c.table_a

Configuration

Key Type Required Description
connection_url string Yes URL to access the MSSQL server
exclude.databases []string No List of databases to exclude from extraction
exclude.tables []string No List of tables to exclude (format: database.table)

System databases master, msdb, model, and tempdb are excluded by default.

Entities

  • Entity type: table
  • Source: mssql
  • URN format: urn:mssql:{scope}:table:{database}.{table}
Properties
Property Type Description
properties.columns array List of column metadata
properties.columns[].name string Column name
properties.columns[].data_type string Data type of the column
properties.columns[].is_nullable bool Whether the column is nullable
properties.columns[].length int Character maximum length (omitted if 0)

Edges

Source Target Type Description
table table references Foreign key relationship to the referenced table.

Contributing

Refer to the contribution guidelines for information on contributing to this module.

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	ConnectionURL string  `json:"connection_url" yaml:"connection_url" mapstructure:"connection_url" validate:"required"`
	Exclude       Exclude `json:"exclude" yaml:"exclude" mapstructure:"exclude"`
}

Config holds the connection URL for the extractor

type Exclude

type Exclude struct {
	Databases []string `json:"databases" yaml:"databases" mapstructure:"databases"`
	Tables    []string `json:"tables" yaml:"tables" mapstructure:"tables"`
}

type Extractor

type Extractor struct {
	plugins.BaseExtractor
	// contains filtered or unexported fields
}

Extractor manages the extraction of data from the database

func New

func New(logger log.Logger) *Extractor

New returns a pointer to an initialized Extractor Object

func (*Extractor) Extract

func (e *Extractor) Extract(ctx context.Context, emit plugins.Emit) error

Extract checks if the extractor is ready to extract and then extract and push data into stream

func (*Extractor) Init

func (e *Extractor) Init(ctx context.Context, config plugins.Config) (err error)

Init initializes the extractor

Jump to

Keyboard shortcuts

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