extract stmtId for exec stmt events

Author: kenanfarukcakir

aggregator/data.go

@@ -1402,7 +1402,9 @@ func (a *Aggregator) parseMySQLCommand(d *l7_req.L7Event) (string, error) {
 		a.mySqlStmtsMu.Unlock()
 	} else if d.Method == l7_req.MYSQL_EXEC_STMT {
 		a.mySqlStmtsMu.RLock()
-		query, ok := a.mySqlStmts[fmt.Sprintf("%d-%d-%d", d.Pid, d.Fd, d.MySqlPrepStmtId)]
+		// extract statementId from payload
+		stmtId := binary.LittleEndian.Uint32(r)
+		query, ok := a.mySqlStmts[fmt.Sprintf("%d-%d-%d", d.Pid, d.Fd, stmtId)]
 		a.mySqlStmtsMu.RUnlock()
 		if !ok || query == "" { // we don't have the query for the prepared statement
 			// Execute (name of prepared statement) [(parameter)]

ebpf/l7_req/l7.go

@@ -748,16 +748,6 @@ func (l7p *L7Prog) Consume(ctx context.Context, ch chan interface{}) {
 				Dport:               l7Event.Dport,
 			}
 
-			if protocol == L7_PROTOCOL_MYSQL {
-				log.Logger.Debug().
-					Str("payload", string(userspacel7Event.Payload[:userspacel7Event.PayloadSize])).
-					Uint32("pid", userspacel7Event.Pid).
-					Str("method", userspacel7Event.Method).
-					Uint32("stmtId", userspacel7Event.MySqlPrepStmtId).
-					Uint64("fd", userspacel7Event.Fd).
-					Msg("mysql-event")
-			}
-
 			go func(l7Event *L7Event) {
 				select {
 				case ch <- l7Event: