CREATE_TABLE_TRANSFORMED_DATA.plpgsql

CREATE OR REPLACE PROCEDURE CREATE_TABLE_TRANSFORMED_DATA()
LANGUAGE 'plpgsql'
AS $$
    CREATE TABLE IF NOT EXISTS public.transformed_data
    (
        value_timestamp timestamp without time zone NOT NULL,
        CONSTRAINT transformed_data_pkey PRIMARY KEY (value_timestamp)
    );

    DECLARE names ARRAY;
    NAMES := (SELECT DISTINCT VALUE_NAME FROM DATA_FROM_KAFKA);
BEGIN
    FOREACH NAME in ARRAY NAMES
    LOOP
    EXECUTE 'ALTER TABLE public.transformed_data ADD COLUMN %I double precision;'
    USING format(%I, NAME);

    END LOOP;
END;
$$;