           (
           id                  NUMBER GENERATED BY DEFAULT ON NULL AS IDENTITY,
           record_timestamp    TIMESTAMP,
+          record_table_schema VARCHAR2(200 BYTE),
           record_table_name   VARCHAR2(200 BYTE),
           record_id           VARCHAR2(200 BYTE),
           record_id_type      VARCHAR2(200 BYTE),

        $BODY$
        BEGIN
        INSERT INTO appshare_realtime_log
        (record_timestamp,  record_table_name,  record_id, record_id_type, record_operation)
        VALUES
        ( now(),   TG_TABLE_NAME ,  NEW.id,
        (select data_type from information_schema.columns where column_name='id' and table_name = TG_TABLE_NAME),
        'INSERT');
        RETURN NULL;

        $BODY$
        BEGIN
        INSERT INTO appshare_realtime_log
        (record_timestamp,  record_table_schema, record_table_name,  record_id, record_id_type,  record_operation)
        VALUES
        ( now(),   TG_TABLE_SCHEMA ,TG_TABLE_NAME ,  NEW.id,
        (select data_type from information_schema.columns where column_name='id' and table_name = TG_TABLE_NAME),
        'UPDATE');
        RETURN NULL;
