trino

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

type Client interface {
	Query(ctx context.Context, sql string, opts trinoclient.QueryOptions) (*trinoclient.QueryResult, error)
	ListCatalogs(ctx context.Context) ([]string, error)
	ListSchemas(ctx context.Context, catalog string) ([]string, error)
	ListTables(ctx context.Context, catalog, schema string) ([]trinoclient.TableInfo, error)
	DescribeTable(ctx context.Context, catalog, schema, table string) (*trinoclient.TableInfo, error)
	Ping(ctx context.Context) error
	Close() error
}

type Config struct {
	Host           string
	Port           int
	User           string
	Password       string // #nosec G117 -- Trino connection credential from admin config
	Catalog        string
	Schema         string
	SSL            bool
	SSLVerify      bool
	Timeout        time.Duration
	DefaultLimit   int
	MaxLimit       int
	ReadOnly       bool
	ConnectionName string

	// CatalogMapping maps DataHub catalog names to Trino catalog names.
	// This is the reverse of the semantic layer's catalog mapping.
	// For example: {"warehouse": "rdbms"} means DataHub "warehouse" → Trino "rdbms"
	CatalogMapping map[string]string

	// EstimateRowCounts controls whether GetTableAvailability runs
	// SELECT COUNT(*) to estimate row counts. Disabled by default because
	// COUNT(*) can cause full table scans on large tables, making DataHub
	// search enrichment very slow.
	EstimateRowCounts bool
}