Method queryStringValues

backend/plugin/db/trino/sync.go:96–117

(ctx context.Context, query string, args ...any)

}

func (d *Driver) queryStringValues(ctx context.Context, query string, args ...any) ([]string, error) {
	rows, err := d.db.QueryContext(ctx, query, args...)
	if err != nil {
		return nil, err
	}
	defer rows.Close()

	var results []string
	for rows.Next() {
		var value string
		if err := rows.Scan(&value); err != nil {
			return nil, errors.Wrap(err, "failed to scan row")
		}
		results = append(results, value)
	}

	if err := rows.Err(); err != nil {
		return nil, errors.Wrap(err, "error during row iteration")
	}

	return results, nil
}

func (d *Driver) getCatalog(ctx context.Context) ([]string, error) {
	query := "SELECT catalog_name FROM system.metadata.catalogs ORDER BY catalog_name"