Revert "Add enforceEmbeddedSchemaCorrectness to TExecuteStatementReq (#344)"

This reverts commit 3f115aa.

Author: gopalldb

connection.go

@@ -515,8 +515,6 @@ func (c *conn) executeStatement(ctx context.Context, query string, args []driver
 		req.Parameters = parameters
 	}
 
-	req.EnforceEmbeddedSchemaCorrectness = c.cfg.EnforceEmbeddedSchemaCorrectness
-
 	// Add per-statement query tags if provided via context
 	if queryTags := driverctx.QueryTagsFromContext(ctx); len(queryTags) > 0 {
 		serialized := SerializeQueryTags(queryTags)

connector.go

@@ -329,15 +329,6 @@ func WithEnableMetricViewMetadata(enable bool) ConnOption {
 	}
 }
 
-// WithEnforceEmbeddedSchemaCorrectness enables enforcement of embedded schema correctness
-// in query execution. When set to true, the server will enforce embedded schema correctness.
-// Default is false.
-func WithEnforceEmbeddedSchemaCorrectness(enforce bool) ConnOption {
-	return func(c *config.Config) {
-		c.EnforceEmbeddedSchemaCorrectness = enforce
-	}
-}
-
 // Setup of Oauth M2m authentication
 func WithClientCredentials(clientID, clientSecret string) ConnOption {
 	return func(c *config.Config) {

internal/cli_service/cli_service.go

@@ -20,10 +20,6 @@ import (
 func TestThriftFieldIdsAreWithinAllowedRange(t *testing.T) {
 	const maxAllowedFieldID = 3329
 
-	allowedExceptions := map[int]bool{
-		3353: true,
-	}
-
 	// Get the directory of this test file
 	_, filename, _, ok := runtime.Caller(0)
 	if !ok {
@@ -34,7 +30,7 @@ func TestThriftFieldIdsAreWithinAllowedRange(t *testing.T) {
 	testDir := filepath.Dir(filename)
 	cliServicePath := filepath.Join(testDir, "cli_service.go")
 
-	violations, err := validateThriftFieldIDs(cliServicePath, maxAllowedFieldID, allowedExceptions)
+	violations, err := validateThriftFieldIDs(cliServicePath, maxAllowedFieldID)
 	if err != nil {
 		t.Fatalf("Failed to validate thrift field IDs: %v", err)
 	}
@@ -55,9 +51,8 @@ func TestThriftFieldIdsAreWithinAllowedRange(t *testing.T) {
 }
 
 // validateThriftFieldIDs parses the cli_service.go file and extracts all thrift field IDs
-// to validate they are within the allowed range. Field IDs listed in allowedExceptions
-// are permitted even if they exceed the maximum.
-func validateThriftFieldIDs(filePath string, maxAllowedFieldID int, allowedExceptions map[int]bool) ([]string, error) {
+// to validate they are within the allowed range.
+func validateThriftFieldIDs(filePath string, maxAllowedFieldID int) ([]string, error) {
 	file, err := os.Open(filePath) //nolint:gosec // G304: path is a test fixture, not user-controlled
 	if err != nil {
 		return nil, fmt.Errorf("failed to open file %s: %w", filePath, err)
@@ -89,7 +84,7 @@ func validateThriftFieldIDs(filePath string, maxAllowedFieldID int, allowedExcep
 					continue
 				}
 
-				if fieldID >= maxAllowedFieldID && !allowedExceptions[fieldID] {
+				if fieldID >= maxAllowedFieldID {
 					// Extract struct/field context from the line
 					context := extractFieldContext(line)
 					violation := fmt.Sprintf(

internal/cli_service/thrift_field_id_test.go

@@ -101,15 +101,14 @@ type UserConfig struct {
 	// Telemetry configuration
 	// Uses config overlay pattern: client > server > default.
 	// Unset = check server feature flag; explicitly true/false overrides the server.
-	EnableTelemetry                  ConfigValue[bool]
-	TelemetryBatchSize               int           // 0 = use default (100)
-	TelemetryFlushInterval           time.Duration // 0 = use default (5s)
-	TelemetryRetryCount              int           // -1 = use default (3); 0 = disable retries; set via telemetry_retry_count
-	TelemetryRetryDelay              time.Duration // 0 = use default (100ms); set via telemetry_retry_delay
-	Transport                        http.RoundTripper
-	UseLz4Compression                bool
-	EnableMetricViewMetadata         bool
-	EnforceEmbeddedSchemaCorrectness bool
+	EnableTelemetry          ConfigValue[bool]
+	TelemetryBatchSize       int           // 0 = use default (100)
+	TelemetryFlushInterval   time.Duration // 0 = use default (5s)
+	TelemetryRetryCount      int           // -1 = use default (3); 0 = disable retries; set via telemetry_retry_count
+	TelemetryRetryDelay      time.Duration // 0 = use default (100ms); set via telemetry_retry_delay
+	Transport                http.RoundTripper
+	UseLz4Compression        bool
+	EnableMetricViewMetadata bool
 	CloudFetchConfig
 }
 
@@ -303,13 +302,6 @@ func ParseDSN(dsn string) (UserConfig, error) {
 		ucfg.EnableMetricViewMetadata = enableMetricViewMetadata
 	}
 
-	if enforceEmbeddedSchemaCorrectness, ok, err := params.extractAsBool("enforceEmbeddedSchemaCorrectness"); ok {
-		if err != nil {
-			return UserConfig{}, err
-		}
-		ucfg.EnforceEmbeddedSchemaCorrectness = enforceEmbeddedSchemaCorrectness
-	}
-
 	// Telemetry parameters
 	if enableTelemetry, ok, err := params.extractAsBool("enableTelemetry"); ok {
 		if err != nil {