Update driver integration for config overlay pattern

Adapt InitializeForConnection to use ConfigValue[bool] pattern from base branch.
- Change enableTelemetry parameter to *bool (nil = unset, check server)
- Use config.NewConfigValue() to set explicit values
- Update connector.go call site to pass pointer
- Remove ForceEnableTelemetry (now handled by ConfigValue override)

Signed-off-by: samikshya-chand_data <samikshya.chand@databricks.com>

Author: samikshya-db

connector.go

@@ -76,18 +76,23 @@ func (c *connector) Connect(ctx context.Context) (driver.Conn, error) {
 	}
 	log := logger.WithContext(conn.id, driverctx.CorrelationIdFromContext(ctx), "")
 
-	// Initialize telemetry if configured
-	if c.cfg.EnableTelemetry || c.cfg.ForceEnableTelemetry {
-		conn.telemetry = telemetry.InitializeForConnection(
-			ctx,
-			c.cfg.Host,
-			c.client,
-			c.cfg.EnableTelemetry,
-			c.cfg.ForceEnableTelemetry,
-		)
-		if conn.telemetry != nil {
-			log.Debug().Msg("telemetry initialized for connection")
-		}
+	// Initialize telemetry (always attempt, let feature flags decide)
+	var enableTelemetry *bool
+	if c.cfg.ForceEnableTelemetry || c.cfg.EnableTelemetry {
+		// User explicitly enabled telemetry
+		trueVal := true
+		enableTelemetry = &trueVal
+	}
+	// else: leave nil to check server feature flag
+
+	conn.telemetry = telemetry.InitializeForConnection(
+		ctx,
+		c.cfg.Host,
+		c.client,
+		enableTelemetry,
+	)
+	if conn.telemetry != nil {
+		log.Debug().Msg("telemetry initialized for connection")
 	}
 
 	log.Info().Msgf("connect: host=%s port=%d httpPath=%s serverProtocolVersion=0x%X", c.cfg.Host, c.cfg.Port, c.cfg.HTTPPath, session.ServerProtocolVersion)

telemetry/driver_integration.go

@@ -3,6 +3,8 @@ package telemetry
 import (
 	"context"
 	"net/http"
+
+	"github.com/databricks/databricks-sql-go/internal/config"
 )
 
 // InitializeForConnection initializes telemetry for a database connection.
@@ -13,22 +15,24 @@ import (
 //   - ctx: Context for the initialization
 //   - host: Databricks host
 //   - httpClient: HTTP client for making requests
-//   - enableTelemetry: User opt-in flag
-//   - forceEnableTelemetry: Force enable flag (bypasses server checks)
+//   - enableTelemetry: User opt-in flag (nil = unset, true = enable, false = disable)
 //
 // Returns:
 //   - *Interceptor: Telemetry interceptor if enabled, nil otherwise
 func InitializeForConnection(
 	ctx context.Context,
 	host string,
 	httpClient *http.Client,
-	enableTelemetry bool,
-	forceEnableTelemetry bool,
+	enableTelemetry *bool,
 ) *Interceptor {
 	// Create telemetry config
 	cfg := DefaultConfig()
-	cfg.EnableTelemetry = enableTelemetry
-	cfg.ForceEnableTelemetry = forceEnableTelemetry
+
+	// Set EnableTelemetry based on user preference
+	if enableTelemetry != nil {
+		cfg.EnableTelemetry = config.NewConfigValue(*enableTelemetry)
+	}
+	// else: leave unset (will check server feature flag)
 
 	// Check if telemetry should be enabled
 	if !isTelemetryEnabled(ctx, cfg, host, httpClient) {
@@ -38,6 +42,9 @@ func InitializeForConnection(
 	// Get or create telemetry client for this host
 	clientMgr := getClientManager()
 	telemetryClient := clientMgr.getOrCreateClient(host, httpClient, cfg)
+	if telemetryClient == nil {
+		return nil
+	}
 
 	// Get feature flag cache context (for reference counting)
 	flagCache := getFeatureFlagCache()