schemer

type Column struct {
	TableRef
	models.TableColumn
}

type ColumnsProvider interface {
	GetColumns(c context.Context, db *sql.DB, catalog, schemaName, tableName string) (ColumnsReader, error)
}

type ColumnsReader interface {
	// NextColumn returns next column
	NextColumn() (Column, error)
}

type Constraint struct {
	TableRef
	ColumnName                                                            string
	UniqueConstraintCatalog, UniqueConstraintSchema, UniqueConstraintName sql.NullString
	MatchOption, UpdateRule, DeleteRule                                   sql.NullString
	RefTableCatalog, RefTableSchema, RefTableName, RefColName             sql.NullString
	*models.Constraint
}

type ConstraintsProvider interface {
	// GetConstraints returns constrains
	GetConstraints(c context.Context, db *sql.DB, catalog, schema, table string) (ConstraintsReader, error)
}

type ConstraintsReader interface {
	NextConstraint() (*Constraint, error)
}

type Index struct {
	TableRef
	*models.Index
}

type IndexColumn struct {
	TableRef
	IndexName string
	*models.IndexColumn
}

type IndexColumnsProvider interface {
	// GetIndexColumns returns index columns
	GetIndexColumns(c context.Context, db *sql.DB, catalog, schema, table, index string) (IndexColumnsReader, error)
}

type IndexColumnsReader interface {
	// NextIndexColumn returns index column
	NextIndexColumn() (*IndexColumn, error)
}

type IndexesProvider interface {
	// GetIndexes returns next index
	GetIndexes(c context.Context, db *sql.DB, catalog, schema, table string) (IndexesReader, error)
}

type IndexesReader interface {
	// NextIndex returns next index
	NextIndex() (*Index, error)
}

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

type RecordsCountProvider interface {
	RecordsCount(c context.Context, db *sql.DB, catalog, schema, table string) (*int, error)
}

type Scanner interface {
	ScanCatalog(c context.Context, db *sql.DB, name string) (database *models.DbCatalog, err error)
}

type SchemaProvider interface {
	IsBulkProvider() bool
	TablesProvider
	ColumnsProvider
	IndexesProvider
	IndexColumnsProvider
	ConstraintsProvider
	RecordsCountProvider
}

type TablePropsReader struct {
	Table string
	Rows  *sql.Rows
}

type TableRef struct {
	SchemaName string
	TableName  string
	TableType  string
}

type TablesProvider interface {
	// GetTables returns tables
	GetTables(c context.Context, db *sql.DB, catalog, schema string) (TablesReader, error)
}

type TablesReader interface {
	NextTable() (*models.Table, error)
}