sqlutils

Documentation

Index

• type SQLCluster
  • func NewSQLCluster(uri string, c client.Client, notifier utils.NotifyProgressFunc) *SQLCluster
  • func (c *SQLCluster) AquireTargets(filter schemav1alpha1.TargetFilter) (schemav1alpha1.ClusterTargets, error)
  • func (c *SQLCluster) CreateExecConfiguration(targets schemav1alpha1.ClusterTargets, cfgMap *v1.ConfigMap, ...) (schemav1alpha1.ExecutionConfiguration, error)
  • func (c *SQLCluster) Execute(targets schemav1alpha1.ClusterTargets, ...) (schemav1alpha1.ClusterTargets, error)

Types

type SQLCluster

type SQLCluster struct {
	URI       string
	Databases []string
	Schemas   []string
	// contains filtered or unexported fields
}

SQLCluster represents a SQL Server Databse

func NewSQLCluster

func NewSQLCluster(uri string, c client.Client, notifier utils.NotifyProgressFunc) *SQLCluster

NewSQLCluster returns a new `SQLCluster`

func (*SQLCluster) AquireTargets

func (c *SQLCluster) AquireTargets(filter schemav1alpha1.TargetFilter) (schemav1alpha1.ClusterTargets, error)

AquireTargets for SQL Server supports 2 modes: 1. return a single DB - to be used as the target DB. 2. if the schema filter is defined we will use it as a regexp to filter schemas - and apply the DacPac per schema.

func (*SQLCluster) CreateExecConfiguration

func (c *SQLCluster) CreateExecConfiguration(targets schemav1alpha1.ClusterTargets, cfgMap *v1.ConfigMap, failIfDataLoss bool) (schemav1alpha1.ExecutionConfiguration, error)

CreateExecConfiguration creates a configuration for the execution of the dacpac in the ConfigMap on the provided targets

func (*SQLCluster) Execute

func (c *SQLCluster) Execute(targets schemav1alpha1.ClusterTargets, config schemav1alpha1.ExecutionConfiguration) (schemav1alpha1.ClusterTargets, error)

Execute runs the configured dacpacs on the targets defined.