fluvio-connectors
fluvio-connectors copied to clipboard
As a user I need to translate JSON records from a data stream (topic) and generate SQL statements.
Acceptance criteria
- Take a data record in a JSON format and translate it to the following SQL statements: 1. CREATE TABLE 2. DROP TABLE 3. INSERT ROWS 4. UPDATE ROWS 5. DELETE ROWS 6. ADD COLUMN 7. DELETE COLUMN 8. RENAME COLUMN
- Should support the following database formats - BOOL - CHAR - INT2 - INT4 - INT8 - OID - FLOAT4 - FLOAT8 - CHAR_ARRAY - VARCHAR - TEXT - NAME - UNKNOWN - JSON - XID - CID - XM - BYTEA - UUID - TIMESTAMP - DATE - TIME - INET - BIT - * (bytes)