postgres

Documentation

Index

• func NewPostgresPlugin() *engine.Plugin
• type PostgresPlugin
  • func (p *PostgresPlugin) ConvertStringValueDuringMap(value, columnType string) (interface{}, error)
  • func (p *PostgresPlugin) DB(config *engine.PluginConfig) (*gorm.DB, error)
  • func (p *PostgresPlugin) EscapeSpecificIdentifier(identifier string) string
  • func (p *PostgresPlugin) FormTableName(schema string, storageUnit string) string
  • func (p *PostgresPlugin) FormatGeometryValue(rawBytes []byte, columnType string) string
  • func (p *PostgresPlugin) GetAllSchemasQuery() string
  • func (p *PostgresPlugin) GetColTypeQuery() string
  • func (p *PostgresPlugin) GetCreateTableQuery(schema string, storageUnit string, columns []engine.Record) string
  • func (p *PostgresPlugin) GetDatabases(config *engine.PluginConfig) ([]string, error)
  • func (p *PostgresPlugin) GetGraphQueryDB(db *gorm.DB, schema string) *gorm.DB
  • func (p *PostgresPlugin) GetPrimaryKeyColQuery() string
  • func (p *PostgresPlugin) GetSchemaTableQuery() string
  • func (p *PostgresPlugin) GetSupportedColumnDataTypes() mapset.Set[string]
  • func (p *PostgresPlugin) GetSupportedOperators() map[string]string
  • func (p *PostgresPlugin) GetTableInfoQuery() string
  • func (p *PostgresPlugin) GetTableNameAndAttributes(rows *sql.Rows, db *gorm.DB) (string, []engine.Record)
  • func (p *PostgresPlugin) RawExecute(config *engine.PluginConfig, query string) (*engine.GetRowsResult, error)

Functions

func NewPostgresPlugin

func NewPostgresPlugin() *engine.Plugin

Types

type PostgresPlugin

type PostgresPlugin struct {
	gorm_plugin.GormPlugin
}

func (*PostgresPlugin) ConvertStringValueDuringMap

func (p *PostgresPlugin) ConvertStringValueDuringMap(value, columnType string) (interface{}, error)

func (*PostgresPlugin) DB

func (p *PostgresPlugin) DB(config *engine.PluginConfig) (*gorm.DB, error)

func (*PostgresPlugin) EscapeSpecificIdentifier

func (p *PostgresPlugin) EscapeSpecificIdentifier(identifier string) string

func (*PostgresPlugin) FormTableName

func (p *PostgresPlugin) FormTableName(schema string, storageUnit string) string

func (*PostgresPlugin) FormatGeometryValue

func (p *PostgresPlugin) FormatGeometryValue(rawBytes []byte, columnType string) string

FormatGeometryValue attempts to format PostGIS geometry data PostGIS uses EWKB (Extended Well-Known Binary) format For now, we'll just return hex format, but this can be extended to parse and display WKT format if needed

func (*PostgresPlugin) GetAllSchemasQuery

func (p *PostgresPlugin) GetAllSchemasQuery() string

func (*PostgresPlugin) GetColTypeQuery

func (p *PostgresPlugin) GetColTypeQuery() string

func (*PostgresPlugin) GetCreateTableQuery

func (p *PostgresPlugin) GetCreateTableQuery(schema string, storageUnit string, columns []engine.Record) string

func (*PostgresPlugin) GetDatabases

func (p *PostgresPlugin) GetDatabases(config *engine.PluginConfig) ([]string, error)

func (*PostgresPlugin) GetGraphQueryDB

func (p *PostgresPlugin) GetGraphQueryDB(db *gorm.DB, schema string) *gorm.DB

func (*PostgresPlugin) GetPrimaryKeyColQuery

func (p *PostgresPlugin) GetPrimaryKeyColQuery() string

func (*PostgresPlugin) GetSchemaTableQuery

func (p *PostgresPlugin) GetSchemaTableQuery() string

func (*PostgresPlugin) GetSupportedColumnDataTypes

func (p *PostgresPlugin) GetSupportedColumnDataTypes() mapset.Set[string]

func (*PostgresPlugin) GetSupportedOperators

func (p *PostgresPlugin) GetSupportedOperators() map[string]string

func (*PostgresPlugin) GetTableInfoQuery

func (p *PostgresPlugin) GetTableInfoQuery() string

func (*PostgresPlugin) GetTableNameAndAttributes

func (p *PostgresPlugin) GetTableNameAndAttributes(rows *sql.Rows, db *gorm.DB) (string, []engine.Record)

func (*PostgresPlugin) RawExecute

func (p *PostgresPlugin) RawExecute(config *engine.PluginConfig, query string) (*engine.GetRowsResult, error)