postgres

Documentation

Index

• func AddConstrantStatement(tableName string, constraint *types.KeyConstraint) string
• func AddForeignKeyStatement(tableName string, schemaForeignKey *schemasv1alpha4.PostgresqlTableForeignKey) string
• func AddIndexStatement(tableName string, schemaIndex *schemasv1alpha4.PostgresqlTableIndex) string
• func AlterColumnStatements(tableName string, primaryKeys []string, ...) ([]string, error)
• func CreateTableStatements(tableName string, tableSchema *schemasv1alpha4.PostgresqlTableSchema) ([]string, error)
• func DatabaseNameFromURI(uri string) (string, error)
• func DeployPostgresStatements(uri string, statements []string) error
• func InsertColumnStatement(tableName string, desiredColumn *schemasv1alpha4.PostgresqlTableColumn) (string, error)
• func PlanPostgresTable(uri string, tableName string, ...) ([]string, error)
• func RemoveConstraintStatement(tableName string, index *types.Index) string
• func RemoveConstrantStatement(tableName string, constraint *types.KeyConstraint) string
• func RemoveForeignKeyStatement(tableName string, foreignKey *types.ForeignKey) string
• func RemoveIndexStatement(tableName string, index *types.Index) string
• func RenameIndexStatement(tableName string, index *types.Index, ...) string
• func SeedDataStatements(tableName string, tableSchema *schemasv1alpha4.PostgresqlTableSchema, ...) ([]string, error)
• func UDTNameToDataType(udtName string) string
• type PostgresConnection
  • func Connect(uri string) (*PostgresConnection, error)
  • func (p *PostgresConnection) Close() error
  • func (p *PostgresConnection) DatabaseName() string
  • func (p *PostgresConnection) EngineVersion() string
  • func (p *PostgresConnection) GetTablePrimaryKey(tableName string) (*types.KeyConstraint, error)
  • func (p *PostgresConnection) GetTableSchema(tableName string) ([]*types.Column, error)
  • func (p *PostgresConnection) ListTableConstraints(databaseName string, tableName string) ([]string, error)
  • func (p *PostgresConnection) ListTableForeignKeys(databaseName string, tableName string) ([]*types.ForeignKey, error)
  • func (p *PostgresConnection) ListTableIndexes(databaseName string, tableName string) ([]*types.Index, error)
  • func (p *PostgresConnection) ListTables() ([]*types.Table, error)

Functions

func AddConstrantStatement

func AddConstrantStatement(tableName string, constraint *types.KeyConstraint) string

func AddForeignKeyStatement

func AddForeignKeyStatement(tableName string, schemaForeignKey *schemasv1alpha4.PostgresqlTableForeignKey) string

func AddIndexStatement

func AddIndexStatement(tableName string, schemaIndex *schemasv1alpha4.PostgresqlTableIndex) string

func AlterColumnStatements

func AlterColumnStatements(tableName string, primaryKeys []string, desiredColumns []*schemasv1alpha4.PostgresqlTableColumn, existingColumn *types.Column) ([]string, error)

func CreateTableStatements

func CreateTableStatements(tableName string, tableSchema *schemasv1alpha4.PostgresqlTableSchema) ([]string, error)

func DatabaseNameFromURI

func DatabaseNameFromURI(uri string) (string, error)

func DeployPostgresStatements

func DeployPostgresStatements(uri string, statements []string) error

func InsertColumnStatement

func InsertColumnStatement(tableName string, desiredColumn *schemasv1alpha4.PostgresqlTableColumn) (string, error)

func PlanPostgresTable

func PlanPostgresTable(uri string, tableName string, postgresTableSchema *schemasv1alpha4.PostgresqlTableSchema, seedData *schemasv1alpha4.SeedData) ([]string, error)

func RemoveConstraintStatement

func RemoveConstraintStatement(tableName string, index *types.Index) string

func RemoveConstrantStatement

func RemoveConstrantStatement(tableName string, constraint *types.KeyConstraint) string

func RemoveForeignKeyStatement

func RemoveForeignKeyStatement(tableName string, foreignKey *types.ForeignKey) string

func RemoveIndexStatement

func RemoveIndexStatement(tableName string, index *types.Index) string

func RenameIndexStatement

func RenameIndexStatement(tableName string, index *types.Index, schemaIndex *schemasv1alpha4.PostgresqlTableIndex) string

func SeedDataStatements

func SeedDataStatements(tableName string, tableSchema *schemasv1alpha4.PostgresqlTableSchema, seedData *schemasv1alpha4.SeedData) ([]string, error)

func UDTNameToDataType

func UDTNameToDataType(udtName string) string

This function only works for a few built-in types right now This needs a better design to make this work past basic arrays

Types

type PostgresConnection

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

func Connect

func Connect(uri string) (*PostgresConnection, error)

func (*PostgresConnection) Close

func (p *PostgresConnection) Close() error

func (*PostgresConnection) DatabaseName

func (p *PostgresConnection) DatabaseName() string

func (*PostgresConnection) EngineVersion

func (p *PostgresConnection) EngineVersion() string

func (*PostgresConnection) GetTablePrimaryKey

func (p *PostgresConnection) GetTablePrimaryKey(tableName string) (*types.KeyConstraint, error)

func (*PostgresConnection) GetTableSchema

func (p *PostgresConnection) GetTableSchema(tableName string) ([]*types.Column, error)

func (*PostgresConnection) ListTableConstraints

func (p *PostgresConnection) ListTableConstraints(databaseName string, tableName string) ([]string, error)

func (*PostgresConnection) ListTableForeignKeys

func (p *PostgresConnection) ListTableForeignKeys(databaseName string, tableName string) ([]*types.ForeignKey, error)

func (*PostgresConnection) ListTableIndexes

func (p *PostgresConnection) ListTableIndexes(databaseName string, tableName string) ([]*types.Index, error)

func (*PostgresConnection) ListTables

func (p *PostgresConnection) ListTables() ([]*types.Table, error)