trino

package

v1.35.0 Latest Latest Go to latest Published: Oct 20, 2026 License: MIT Imports: 20 Imported by: 0

Details

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

Repository

github.com/rudderlabs/sqlconnect-go

Links

Open Source Insights

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)

Constants ¶

View Source

const (
	DatabaseType = "trino"
)

Variables ¶

This section is empty.

Functions ¶

func GoquDialectOptions ¶ added in v1.10.0

func GoquDialectOptions() *sqlgen.SQLDialectOptions

func GoquExpressions ¶ added in v1.10.0

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"`

	// SkipHostValidation relaxes host validation to permit loopback addresses,
	// for tests that run against a local container. It cannot be used to reach
	// link-local, private or unspecified addresses — those stay rejected.
	SkipHostValidation bool `json:"skipHostValidation"`
	// 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) ListSchemas ¶ added in v1.25.0

func (db *DB) ListSchemas(ctx context.Context, opts ...sqlconnect.Option) ([]sqlconnect.SchemaRef, error)

ListSchemas overrides the base implementation to handle nonexistent catalog gracefully

func (*DB) ListTables ¶ added in v1.25.0

func (db *DB) ListTables(ctx context.Context, schema sqlconnect.SchemaRef, opts ...sqlconnect.Option) ([]sqlconnect.RelationRef, error)

ListTables overrides the base implementation to handle nonexistent catalog gracefully

func (*DB) Ping ¶

func (db *DB) Ping() error

func (*DB) PingContext ¶

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

func (*DB) SchemaExists ¶ added in v1.25.0

func (db *DB) SchemaExists(ctx context.Context, schemaRef sqlconnect.SchemaRef, opts ...sqlconnect.Option) (bool, error)

SchemaExists overrides the base implementation to handle nonexistent catalog gracefully

Source Files ¶

View all Source files

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