trino

Documentation

Index

• Constants
• func GoquDialectOptions() *sqlgen.SQLDialectOptions
• func GoquExpressions() *base.Expressions
• type Config
  • func (c Config) ConnectionString() (string, error)
  • func (c *Config) Parse(input json.RawMessage) error
• type DB
  • func NewDB(configJSON json.RawMessage) (*DB, error)
  • func (db *DB) Ping() error
  • func (db *DB) PingContext(ctx context.Context) error

Constants

const (
	DatabaseType = "trino"
)

Functions

func GoquDialectOptions

func GoquDialectOptions() *sqlgen.SQLDialectOptions

func GoquExpressions

func GoquExpressions() *base.Expressions

Types

type Config

type Config struct {
	Host     string `json:"host"`
	Port     int    `json:"port"`
	Catalog  string `json:"catalog"`
	User     string `json:"user"`
	Password string `json:"password"`

	TunnelInfo *sshtunnel.Config `json:"tunnel_info,omitempty"`
	// contains filtered or unexported fields
}

func (Config) ConnectionString

func (c Config) ConnectionString() (string, error)

func (*Config) Parse

func (c *Config) Parse(input json.RawMessage) error

type DB

type DB struct {
	*base.DB
}

func NewDB

func NewDB(configJSON json.RawMessage) (*DB, error)

NewDB creates a new trino db client

func (*DB) Ping

func (db *DB) Ping() error

func (*DB) PingContext

func (db *DB) PingContext(ctx context.Context) error