postgres

Documentation

Index

• Constants
• func New(ctx context.Context, cfg ConnectionConfig) (graph.Factory, error)
• type Column
  • func (c *Column) ScanRow(rows pgx.Rows) error
• type ConnectionConfig

Constants

const (
	DescribeTableSQL = "SELECT column_name, ordinal_position, column_default, is_nullable, data_type " +
		"FROM information_schema.columns " +
		"WHERE table_schema = $1 AND table_name = $2 " +
		"ORDER BY ordinal_position ASC"
)

Functions

func New

func New(ctx context.Context, cfg ConnectionConfig) (graph.Factory, error)

Types

type Column

type Column struct {
	Name          string
	Position      uint
	Type          api.IDataType
	Default       *string
	Nullable      bool
	MaxCharLength uint
	Precision     uint
}

func (*Column) ScanRow

func (c *Column) ScanRow(rows pgx.Rows) error

type ConnectionConfig

type ConnectionConfig struct {
	ConnectionString string
	SyncTable        string
	SequenceTable    string
}