redshift

package
v3.18.41 Latest Latest
Warning

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

Go to latest
Published: Jun 17, 2026 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DefaultDBName = "dev"
	DefaultSchema = "public"
)

Variables

This section is empty.

Functions

func FindMatchingParen

func FindMatchingParen(s string, open int) int

func MapType

func MapType(t string) string

func NormIdent

func NormIdent(s string) string

func NormalizeIdentifier

func NormalizeIdentifier(s string) string

func SplitStatements

func SplitStatements(sql string) []string

func SplitTopLevel

func SplitTopLevel(s string, sep byte) []string

func StripSQLComments

func StripSQLComments(sql string) string

func TranslateDiscoveryQuery

func TranslateDiscoveryQuery(sql string, args []driver.NamedValue, schema *Schema) (string, []driver.NamedValue, error)

func TranslateMetadataRefresh

func TranslateMetadataRefresh(schema *Schema) []string

func TranslateSetup

func TranslateSetup(seedSQL string, schema *Schema) ([]string, error)

func TrimIdent

func TrimIdent(s string) string

func TrimQualifiedIdent

func TrimQualifiedIdent(s string) string

Types

type Adapter

type Adapter struct{}

func NewAdapter

func NewAdapter() Adapter

func (Adapter) ClassifyPhase

func (Adapter) ClassifyPhase(sql string) string

func (Adapter) DefaultSeedPath

func (Adapter) DefaultSeedPath() string

func (Adapter) MapType

func (Adapter) MapType(sourceType string) string

func (Adapter) Name

func (Adapter) Name() string

func (Adapter) NewSession

func (Adapter) NewSession(c any) hostedemu.Session

func (Adapter) NormalizeIdentifier

func (Adapter) NormalizeIdentifier(identifier string) string

func (Adapter) ParseSeed

func (Adapter) ParseSeed(seedSQL string) (any, error)

func (Adapter) TranslateDirect

func (Adapter) TranslateDirect(sql string, args []driver.NamedValue, _ any) (string, []driver.NamedValue, error)

func (Adapter) TranslateDiscoveryExec

func (Adapter) TranslateDiscoveryExec(sql string, args []driver.NamedValue, c any) ([]string, []driver.NamedValue, error)

func (Adapter) TranslateDiscoveryQuery

func (Adapter) TranslateDiscoveryQuery(sql string, args []driver.NamedValue, c any) (string, []driver.NamedValue, error)

func (Adapter) TranslateMetadataRefresh

func (Adapter) TranslateMetadataRefresh(c any) ([]string, error)

func (Adapter) TranslateRuntime

func (Adapter) TranslateRuntime(sql string, args []driver.NamedValue, _ any) (string, []driver.NamedValue, error)

func (Adapter) TranslateSetup

func (Adapter) TranslateSetup(seedSQL string, c any) ([]string, error)

type Column

type Column struct {
	Name              string
	Type              string
	DDLType           string
	Default           string
	NotNull           bool
	PrimaryKey        bool
	UniqueKey         bool
	FKeyTable         string
	FKeyColumn        string
	Encoding          string
	DistKey           bool
	SortKey           int
	SortKeyType       string
	Identity          bool
	GeneratedIdentity bool
	Collation         string
}

type Schema

type Schema struct {
	DBName string
	Schema string
	Tables []*Table
	// contains filtered or unexported fields
}

func ParseSeedBytes

func ParseSeedBytes(data []byte) (*Schema, error)

func (*Schema) ApplyDDL

func (s *Schema) ApplyDDL(sql string)

func (*Schema) Table

func (s *Schema) Table(name string) *Table

type Session

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

func (*Session) ApplyDDL

func (s *Session) ApplyDDL(sql string)

func (*Session) PlaceholderQuery

func (s *Session) PlaceholderQuery(sql string) (*hostedemu.Rows, string, error)

type Table

type Table struct {
	DBName      string
	Schema      string
	Name        string
	IsView      bool
	DistStyle   string
	DistKey     string
	SortKeyType string
	SortKeys    []string
	Columns     []*Column
	PrimaryKeys []string
}

func (*Table) Column

func (t *Table) Column(name string) *Column

Jump to

Keyboard shortcuts

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