postgres

package

v0.0.5 Latest Latest Go to latest Published: Mar 10, 2025 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/centralmind/gateway

Links

Open Source Insights

README ¶

title: 'PostgreSQL'

PostgreSQL connector allows querying PostgreSQL databases.

Config Schema

Field	Type	Required	Description
hosts	string[]	yes	List of database hosts
database	string	yes	Database name
user	string	yes	Username
password	string	yes	Password
port	integer	yes	TCP port (default 5432)
schema	string	no	instead of "public" it could be custom
tlsFile	string	no	PEM-encoded certificate for TLS
enableTLS	boolean	no	Enable TLS/SSL connection

Config example:

type: postgres
hosts: 
  - localhost
database: mydb
user: postgres
password: secret
port: 5432
schema: sales
tlsFile: ""        # Optional PEM-encoded certificate
enableTLS: false   # Enable TLS/SSL connection

Deploy PostgreSQL Sample Databases

You can deploy sample database using a docker and example of DVD store data DVDStore Sample Database

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	Hosts      []string
	Database   string
	User       string
	Password   string
	Port       int
	TLSFile    string
	EnableTLS  bool
	ConnString string // Connection string in format: postgresql://user:password@host:port/database
	Schema     string // Database schema name for table access (format: schema.table_name)
}

func (Config) Doc ¶

func (c Config) Doc() string

func (Config) MakeConfig ¶

func (c Config) MakeConfig() (*pgx.ConnConfig, error)

func (Config) TLSConfig ¶

func (c Config) TLSConfig() (*tls.Config, error)

func (Config) Type ¶

func (c Config) Type() string

func (*Config) UnmarshalYAML ¶

func (c *Config) UnmarshalYAML(value *yaml.Node) error

UnmarshalYAML implements the yaml.Unmarshaler interface to allow for both direct connection string or full configuration objects in YAML

type Connector ¶

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

Connector implements the connectors.Connector interface for PostgreSQL

func (Connector) Discovery ¶

func (c Connector) Discovery(ctx context.Context) ([]model.Table, error)

func (*Connector) GuessColumnType ¶

func (c *Connector) GuessColumnType(sqlType string) model.ColumnType

GuessColumnType implements TypeGuesser interface for PostgreSQL

func (*Connector) InferQuery ¶

func (c *Connector) InferQuery(ctx context.Context, query string) ([]model.ColumnSchema, error)

InferQuery implements the Connector interface

func (*Connector) InferResultColumns ¶

func (c *Connector) InferResultColumns(ctx context.Context, query string) ([]model.ColumnSchema, error)

InferResultColumns returns column information for the given query

func (Connector) LoadsColumns ¶

func (c Connector) LoadsColumns(ctx context.Context, tableName string) ([]model.ColumnSchema, error)

func (Connector) Ping ¶

func (c Connector) Ping(ctx context.Context) error

func (Connector) Query ¶

func (c Connector) Query(ctx context.Context, endpoint model.Endpoint, params map[string]any) ([]map[string]any, error)

func (Connector) Sample ¶

func (c Connector) Sample(ctx context.Context, table model.Table) ([]map[string]any, error)

Source Files ¶

View all Source files

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