fix: extended query anonymizer tests with functional tests queries

[tolgadur]

Description

This tests take queries used in the ksqldb functional tests to test the QueryAnonymizer and make it more robust before shipping. The issues identified and fixed are:

• Types weren't anonymized correctly (i.e. custom types weren't anonymized at all)
• PRIMARY KEYS / KEYS were omitted in the anonymized query
• Explain queries weren't anonymized correctly. I.e. EXPLAIN SELECT * FROM my_table; just resulted in EXPLAIN query;
• If the same name was used to create a table and stream name they used to result in the same name. (not sure if this is expected behavior?)
• SELECT statements werent anonymized at all.
• * was completely omitted in the anonymizations. i.e. SELECT * FROM my_table
• JOIN statements were completely ommited in anonymizations.

Unfortunately with the current implementation I did not find a way to determine whether it's a stream or table in SELECT statements. Thus, the anonymizer is just using the generic 'source'. I.e. SELECT * FROM my_table becomes SELECT * FROM source1.

I was also not able to correctly determine the keys in JOIN statements. Thus, the anonymizer is just using the generic key1=key2. I.e.

INSERT INTO OUTPUT SELECT col1, col2, col3  FROM SOURCE1 S1 JOIN SOURCE2 S2 WITHIN 1 SECOND ON col1.k=col2.k;

becomes

INSERT INTO OUTPUT SELECT col1, col2, col3 FROM SOURCE1 S1 JOIN SOURCE2 S2 WITHIN 1 SECOND ON col1.k=col2.k;

Reviewer checklist

• Ensure docs are updated if necessary. (eg. if a user visible feature is being added or changed).
• Ensure relevant issues are linked (description should include text like "Fixes #")

[ghost]

@confluentinc It looks like @tolgadur just signed our Contributor License Agreement. 👍

Always at your service,

clabot

[swist]

Changes