Add metric view metadata support

Author: shivam2680

connector.go

@@ -41,10 +41,28 @@ func (c *connector) Connect(ctx context.Context) (driver.Conn, error) {
 	if err != nil {
 		return nil, dbsqlerrint.NewDriverError(ctx, dbsqlerr.ErrThriftClient, err)
 	}
+
+	// Prepare session configuration
+	sessionParams := c.cfg.SessionParams
+	if c.cfg.EnableMetricViewMetadata {
+		// Make a copy of session params and add metric view metadata config
+		if sessionParams == nil {
+			sessionParams = make(map[string]string)
+		} else {
+			// Create a copy to avoid modifying the original
+			paramsCopy := make(map[string]string, len(sessionParams)+1)
+			for k, v := range sessionParams {
+				paramsCopy[k] = v
+			}
+			sessionParams = paramsCopy
+		}
+		sessionParams["spark.sql.thriftserver.metadata.metricview.enabled"] = "true"
+	}
+
 	protocolVersion := int64(c.cfg.ThriftProtocolVersion)
 	session, err := tclient.OpenSession(ctx, &cli_service.TOpenSessionReq{
 		ClientProtocolI64: &protocolVersion,
-		Configuration:     c.cfg.SessionParams,
+		Configuration:     sessionParams,
 		InitialNamespace: &cli_service.TNamespace{
 			CatalogName: catalogName,
 			SchemaName:  schemaName,
@@ -265,6 +283,14 @@ func WithMaxDownloadThreads(numThreads int) ConnOption {
 	}
 }
 
+// WithEnableMetricViewMetadata enables metric view metadata support. Default is false.
+// When enabled, adds spark.sql.thriftserver.metadata.metricview.enabled=true to session configuration.
+func WithEnableMetricViewMetadata(enable bool) ConnOption {
+	return func(c *config.Config) {
+		c.EnableMetricViewMetadata = enable
+	}
+}
+
 // Setup of Oauth M2m authentication
 func WithClientCredentials(clientID, clientSecret string) ConnOption {
 	return func(c *config.Config) {

connector_test.go

@@ -213,6 +213,39 @@ func TestNewConnector(t *testing.T) {
 		require.True(t, ok)
 		require.True(t, internalClient.TLSClientConfig.InsecureSkipVerify)
 	})
+
+	t.Run("Connector test WithEnableMetricViewMetadata enabled", func(t *testing.T) {
+		host := "databricks-host"
+		accessToken := "token"
+		httpPath := "http-path"
+		con, err := NewConnector(
+			WithServerHostname(host),
+			WithAccessToken(accessToken),
+			WithHTTPPath(httpPath),
+			WithEnableMetricViewMetadata(true),
+		)
+		assert.Nil(t, err)
+
+		coni, ok := con.(*connector)
+		require.True(t, ok)
+		assert.True(t, coni.cfg.EnableMetricViewMetadata)
+	})
+
+	t.Run("Connector test WithEnableMetricViewMetadata disabled by default", func(t *testing.T) {
+		host := "databricks-host"
+		accessToken := "token"
+		httpPath := "http-path"
+		con, err := NewConnector(
+			WithServerHostname(host),
+			WithAccessToken(accessToken),
+			WithHTTPPath(httpPath),
+		)
+		assert.Nil(t, err)
+
+		coni, ok := con.(*connector)
+		require.True(t, ok)
+		assert.False(t, coni.cfg.EnableMetricViewMetadata)
+	})
 }
 
 type mockRoundTripper struct{}

internal/config/config.go

@@ -98,8 +98,9 @@ type UserConfig struct {
 	RetryWaitMin      time.Duration
 	RetryWaitMax      time.Duration
 	RetryMax          int
-	Transport         http.RoundTripper
-	UseLz4Compression bool
+	Transport                 http.RoundTripper
+	UseLz4Compression         bool
+	EnableMetricViewMetadata  bool
 	CloudFetchConfig
 }
 
@@ -123,25 +124,26 @@ func (ucfg UserConfig) DeepCopy() UserConfig {
 	}
 
 	return UserConfig{
-		Protocol:          ucfg.Protocol,
-		Host:              ucfg.Host,
-		Port:              ucfg.Port,
-		HTTPPath:          ucfg.HTTPPath,
-		Catalog:           ucfg.Catalog,
-		Schema:            ucfg.Schema,
-		Authenticator:     ucfg.Authenticator,
-		AccessToken:       ucfg.AccessToken,
-		MaxRows:           ucfg.MaxRows,
-		QueryTimeout:      ucfg.QueryTimeout,
-		UserAgentEntry:    ucfg.UserAgentEntry,
-		Location:          loccp,
-		SessionParams:     sessionParams,
-		RetryWaitMin:      ucfg.RetryWaitMin,
-		RetryWaitMax:      ucfg.RetryWaitMax,
-		RetryMax:          ucfg.RetryMax,
-		Transport:         ucfg.Transport,
-		UseLz4Compression: ucfg.UseLz4Compression,
-		CloudFetchConfig:  ucfg.CloudFetchConfig,
+		Protocol:                 ucfg.Protocol,
+		Host:                     ucfg.Host,
+		Port:                     ucfg.Port,
+		HTTPPath:                 ucfg.HTTPPath,
+		Catalog:                  ucfg.Catalog,
+		Schema:                   ucfg.Schema,
+		Authenticator:            ucfg.Authenticator,
+		AccessToken:              ucfg.AccessToken,
+		MaxRows:                  ucfg.MaxRows,
+		QueryTimeout:             ucfg.QueryTimeout,
+		UserAgentEntry:           ucfg.UserAgentEntry,
+		Location:                 loccp,
+		SessionParams:            sessionParams,
+		RetryWaitMin:             ucfg.RetryWaitMin,
+		RetryWaitMax:             ucfg.RetryWaitMax,
+		RetryMax:                 ucfg.RetryMax,
+		Transport:                ucfg.Transport,
+		UseLz4Compression:        ucfg.UseLz4Compression,
+		EnableMetricViewMetadata: ucfg.EnableMetricViewMetadata,
+		CloudFetchConfig:         ucfg.CloudFetchConfig,
 	}
 }
 
@@ -272,6 +274,14 @@ func ParseDSN(dsn string) (UserConfig, error) {
 		ucfg.MaxDownloadThreads = numThreads
 	}
 
+	// Metric View Metadata parameter
+	if enableMetricViewMetadata, ok, err := params.extractAsBool("enableMetricViewMetadata"); ok {
+		if err != nil {
+			return UserConfig{}, err
+		}
+		ucfg.EnableMetricViewMetadata = enableMetricViewMetadata
+	}
+
 	// for timezone we do a case insensitive key match.
 	// We use getNoCase because we want to leave timezone in the params so that it will also
 	// be used as a session param.