create table if not exists transformation_column_mapping
(
table_name varchar(64) not null,
table_column varchar(64) not null,
source_column varchar(64) not null,
constraint transformation_column_mapping_pk
primary key (table_name, table_column, source_column)
);
alter table transformation_column_mapping
owner to airflow_prototype_dw_user;
–create index if not exists transformation_column_mapping_ix
– on transformation_column_mapping (table_name, source_column);