postgresql

Documentation

Overview

Package postgresql contains code specific for PostgreSQL database.

Index

• func NewConnectionManager(cfg ConnectionManagerConfig, base rdbms_utils.ConnectionManagerBase, ...) rdbms_utils.ConnectionManager
• func NewSQLFormatter() rdbms_utils.SQLFormatter
• func NewTypeMapper() datasource.TypeMapper
• func TableMetadataQuery(request *api_service_protos.TDescribeTableRequest, schema string) (string, []any)
• type Connection
  • func (c Connection) Close() error
  • func (c Connection) Query(ctx context.Context, _ *zap.Logger, query string, args ...any) (rdbms_utils.Rows, error)
• type ConnectionManagerConfig

Functions

func NewConnectionManager

func NewConnectionManager(
	cfg ConnectionManagerConfig,
	base rdbms_utils.ConnectionManagerBase,
	schemaGetter func(*api_common.TDataSourceInstance) string,
) rdbms_utils.ConnectionManager

func NewSQLFormatter

func NewSQLFormatter() rdbms_utils.SQLFormatter

func NewTypeMapper

func NewTypeMapper() datasource.TypeMapper

func TableMetadataQuery

func TableMetadataQuery(
	request *api_service_protos.TDescribeTableRequest,
	schema string,
) (string, []any)

Types

type Connection

type Connection struct {
	*pgx.Conn
	// contains filtered or unexported fields
}

func (Connection) Close

func (c Connection) Close() error

func (Connection) Query

func (c Connection) Query(ctx context.Context, _ *zap.Logger, query string, args ...any) (rdbms_utils.Rows, error)

type ConnectionManagerConfig

type ConnectionManagerConfig interface {
	GetOpenConnectionTimeout() string
}