Put DB Operation behind flag

.github/workflows/e2e/k8s/sample-job.yml

@@ -38,6 +38,8 @@ spec:
           value: "tracecontext,baggage"
         - name: OTEL_GO_AUTO_INCLUDE_DB_STATEMENT
           value: "true"
+        - name: OTEL_GO_AUTO_INCLUDE_DB_OPERATION
+          value: "true"
         - name: OTEL_BSP_SCHEDULE_DELAY
           value: "60000"
         resources: {}

internal/pkg/instrumentation/bpf/database/sql/probe.go

@@ -29,6 +29,9 @@ const (
 
 	// IncludeDBStatementEnvVar is the environment variable to opt-in for sql query inclusion in the trace.
 	IncludeDBStatementEnvVar = "OTEL_GO_AUTO_INCLUDE_DB_STATEMENT"
+
+	// IncludeDBOperationEnvVar is the environment variable to opt-in for sql query operation in the trace.
+	IncludeDBOperationEnvVar = "OTEL_GO_AUTO_INCLUDE_DB_OPERATION"
 )
 
 // New returns a new [probe.Probe].
@@ -97,24 +100,30 @@ func processFn(e *event) ptrace.SpanSlice {
 	query := unix.ByteSliceToString(e.Query[:])
 	if query != "" {
 		span.Attributes().PutStr(string(semconv.DBQueryTextKey), query)
+	}
 
-		q, err := sql.Parse(query)
-		if err == nil {
-			operation := ""
-			switch q.(type) {
-			case *sql.Select:
-				operation = "SELECT"
-			case *sql.Update:
-				operation = "UPDATE"
-			case *sql.Insert:
-				operation = "INSERT"
-			case *sql.Delete:
-				operation = "DELETE"
-			}
-
-			if operation != "" {
-				span.Attributes().PutStr(string(semconv.DBOperationNameKey), operation)
-				span.SetName(operation)
+	includeOperationVal := os.Getenv(IncludeDBOperationEnvVar)
+	if includeOperationVal != "" {
+		include, err := strconv.ParseBool(includeOperationVal)
+		if err == nil && include {
+			q, err := sql.Parse(query)
+			if err == nil {
+				operation := ""
+				switch q.(type) {
+				case *sql.Select:
+					operation = "SELECT"
+				case *sql.Update:
+					operation = "UPDATE"
+				case *sql.Insert:
+					operation = "INSERT"
+				case *sql.Delete:
+					operation = "DELETE"
+				}
+
+				if operation != "" {
+					span.Attributes().PutStr(string(semconv.DBOperationNameKey), operation)
+					span.SetName(operation)
+				}
 			}
 		}
 	}