Add enforceEmbeddedSchemaCorrectness option to TExecuteStatementReq

Add a new optional bool field (0xD19) to TExecuteStatementReq in the thrift
contract and expose it as an opt-in configuration parameter. When enabled,
the server enforces embedded schema correctness during query execution.

- Add field to thrift-generated cli_service.go with full Read/Write/Equals support
- Add EnforceEmbeddedSchemaCorrectness to UserConfig (default false)
- Add WithEnforceEmbeddedSchemaCorrectness connector option
- Add DSN parameter support (enforceEmbeddedSchemaCorrectness=true)
- Wire config to TExecuteStatementReq in executeStatement

ES-1804970

Co-authored-by: Isaac

Author: gopalldb

connection.go

@@ -323,6 +323,11 @@ func (c *conn) executeStatement(ctx context.Context, query string, args []driver
 		req.Parameters = parameters
 	}
 
+	// Add enforce embedded schema correctness if enabled
+	if c.cfg.EnforceEmbeddedSchemaCorrectness {
+		req.EnforceEmbeddedSchemaCorrectness = &c.cfg.EnforceEmbeddedSchemaCorrectness
+	}
+
 	resp, err := c.client.ExecuteStatement(ctx, &req)
 	var log *logger.DBSQLLogger
 	log, ctx = client.LoggerAndContext(ctx, resp)

connector.go

@@ -291,6 +291,15 @@ 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

@@ -99,8 +99,9 @@ type UserConfig struct {
 	RetryWaitMax             time.Duration
 	RetryMax                 int
 	Transport                http.RoundTripper
-	UseLz4Compression        bool
-	EnableMetricViewMetadata bool
+	UseLz4Compression                bool
+	EnableMetricViewMetadata         bool
+	EnforceEmbeddedSchemaCorrectness bool
 	CloudFetchConfig
 }
 
@@ -282,6 +283,13 @@ 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
+	}
+
 	// 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.