sqlmanager_mssql

Documentation

Index

• func BuildMssqlDeleteStatement(schema, table string) string
• func BuildMssqlIdentityColumnResetStatement(schema, table, identityGeneration string) *string
• type Manager
  • func NewManager(querier mssql_queries.Querier, db mysql_queries.DBTX, closer func()) *Manager
  • func (m *Manager) BatchExec(ctx context.Context, batchSize int, statements []string, ...) error
  • func (m *Manager) Close()
  • func (m *Manager) Exec(ctx context.Context, statement string) error
  • func (m *Manager) GetCreateTableStatement(ctx context.Context, schema, table string) (string, error)
  • func (m *Manager) GetDatabaseSchema(ctx context.Context) ([]*sqlmanager_shared.DatabaseSchemaRow, error)
  • func (m *Manager) GetRolePermissionsMap(ctx context.Context) (map[string][]string, error)
  • func (m *Manager) GetSchemaColumnMap(ctx context.Context) (map[string]map[string]*sqlmanager_shared.ColumnInfo, error)
  • func (m *Manager) GetSchemaInitStatements(ctx context.Context, tables []*sqlmanager_shared.SchemaTable) ([]*sqlmanager_shared.InitSchemaStatements, error)
  • func (m *Manager) GetSchemaTableDataTypes(ctx context.Context, tables []*sqlmanager_shared.SchemaTable) (*sqlmanager_shared.SchemaTableDataTypeResponse, error)
  • func (m *Manager) GetSchemaTableTriggers(ctx context.Context, tables []*sqlmanager_shared.SchemaTable) ([]*sqlmanager_shared.TableTrigger, error)
  • func (m *Manager) GetTableConstraintsBySchema(ctx context.Context, schemas []string) (*sqlmanager_shared.TableConstraints, error)
  • func (m *Manager) GetTableInitStatements(ctx context.Context, tables []*sqlmanager_shared.SchemaTable) ([]*sqlmanager_shared.TableInitStatement, error)
  • func (m *Manager) GetTableRowCount(ctx context.Context, schema, table string, whereClause *string) (int64, error)

Functions

func BuildMssqlDeleteStatement

func BuildMssqlDeleteStatement(
	schema, table string,
) string

func BuildMssqlIdentityColumnResetStatement

func BuildMssqlIdentityColumnResetStatement(
	schema, table, identityGeneration string,
) *string

Types

type Manager

type Manager struct {
	// contains filtered or unexported fields
}

func NewManager

func NewManager(querier mssql_queries.Querier, db mysql_queries.DBTX, closer func()) *Manager

func (*Manager) BatchExec

func (m *Manager) BatchExec(ctx context.Context, batchSize int, statements []string, opts *sqlmanager_shared.BatchExecOpts) error

func (*Manager) Close

func (m *Manager) Close()

func (*Manager) Exec

func (m *Manager) Exec(ctx context.Context, statement string) error

func (*Manager) GetCreateTableStatement

func (m *Manager) GetCreateTableStatement(ctx context.Context, schema, table string) (string, error)

func (*Manager) GetDatabaseSchema

func (m *Manager) GetDatabaseSchema(ctx context.Context) ([]*sqlmanager_shared.DatabaseSchemaRow, error)

func (*Manager) GetRolePermissionsMap

func (m *Manager) GetRolePermissionsMap(ctx context.Context) (map[string][]string, error)

func (*Manager) GetSchemaColumnMap

func (m *Manager) GetSchemaColumnMap(ctx context.Context) (map[string]map[string]*sqlmanager_shared.ColumnInfo, error)

func (*Manager) GetSchemaInitStatements

func (m *Manager) GetSchemaInitStatements(ctx context.Context, tables []*sqlmanager_shared.SchemaTable) ([]*sqlmanager_shared.InitSchemaStatements, error)

func (*Manager) GetSchemaTableDataTypes

func (m *Manager) GetSchemaTableDataTypes(ctx context.Context, tables []*sqlmanager_shared.SchemaTable) (*sqlmanager_shared.SchemaTableDataTypeResponse, error)

func (*Manager) GetSchemaTableTriggers

func (m *Manager) GetSchemaTableTriggers(ctx context.Context, tables []*sqlmanager_shared.SchemaTable) ([]*sqlmanager_shared.TableTrigger, error)

func (*Manager) GetTableConstraintsBySchema

func (m *Manager) GetTableConstraintsBySchema(ctx context.Context, schemas []string) (*sqlmanager_shared.TableConstraints, error)

func (*Manager) GetTableInitStatements

func (m *Manager) GetTableInitStatements(ctx context.Context, tables []*sqlmanager_shared.SchemaTable) ([]*sqlmanager_shared.TableInitStatement, error)

func (*Manager) GetTableRowCount

func (m *Manager) GetTableRowCount(
	ctx context.Context,
	schema, table string,
	whereClause *string,
) (int64, error)