postgres

Documentation

Index

• func AddConstrantStatement(tableName string, constraint *types.KeyConstraint) string
• func AddForeignKeyStatement(tableName string, schemaForeignKey *schemasv1alpha2.SQLTableForeignKey) string
• func AddIndexStatement(tableName string, schemaIndex *schemasv1alpha2.SQLTableIndex) string
• func AlterColumnStatement(tableName string, primaryKeys []string, ...) (string, error)
• func CreateTableStatement(tableName string, tableSchema *schemasv1alpha2.SQLTableSchema) (string, error)
• func DatabaseNameFromURI(uri string) (string, error)
• func DeployPostgresTable(uri string, tableName string, ...) error
• func InsertColumnStatement(tableName string, desiredColumn *schemasv1alpha2.SQLTableColumn) (string, error)
• 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
• type PostgresConnection
  • func Connect(uri string) (*PostgresConnection, error)
  • func (p *PostgresConnection) CheckAlive(namespace string, instanceName string) (bool, error)
  • func (p *PostgresConnection) DatabaseName() string
  • func (p *PostgresConnection) EngineVersion() string
  • func (p *PostgresConnection) GetConnection() *sql.Conn
  • func (p *PostgresConnection) GetDB() *sql.DB
  • func (p *PostgresConnection) GetTablePrimaryKey(tableName string) (*types.KeyConstraint, error)
  • func (p *PostgresConnection) GetTableSchema(tableName string) ([]*types.Column, 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() ([]string, error)

Functions

func AddConstrantStatement

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

func AddForeignKeyStatement

func AddForeignKeyStatement(tableName string, schemaForeignKey *schemasv1alpha2.SQLTableForeignKey) string

func AddIndexStatement

func AddIndexStatement(tableName string, schemaIndex *schemasv1alpha2.SQLTableIndex) string

func AlterColumnStatement

func AlterColumnStatement(tableName string, primaryKeys []string, desiredColumns []*schemasv1alpha2.SQLTableColumn, existingColumn *types.Column) (string, error)

func CreateTableStatement

func CreateTableStatement(tableName string, tableSchema *schemasv1alpha2.SQLTableSchema) (string, error)

func DatabaseNameFromURI

func DatabaseNameFromURI(uri string) (string, error)

func DeployPostgresTable

func DeployPostgresTable(uri string, tableName string, postgresTableSchema *schemasv1alpha2.SQLTableSchema) error

func InsertColumnStatement

func InsertColumnStatement(tableName string, desiredColumn *schemasv1alpha2.SQLTableColumn) (string, error)

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 *schemasv1alpha2.SQLTableIndex) string

Types

type PostgresConnection

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

func Connect

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

func (*PostgresConnection) CheckAlive

func (p *PostgresConnection) CheckAlive(namespace string, instanceName string) (bool, error)

func (*PostgresConnection) DatabaseName

func (p *PostgresConnection) DatabaseName() string

func (*PostgresConnection) EngineVersion

func (p *PostgresConnection) EngineVersion() string

func (*PostgresConnection) GetConnection

func (p *PostgresConnection) GetConnection() *sql.Conn

func (*PostgresConnection) GetDB

func (p *PostgresConnection) GetDB() *sql.DB

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) 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() ([]string, error)