Untitled

 avatar
unknown
plain_text
a year ago
997 B
3
Indexable
# Generate an INSERT query dynamically
insert_query = f"INSERT INTO {schema_ext}.{table_name} ("
insert_columns = []
insert_values = []

for column_name, source_val in source_row.items():
    if source_val is not None and ' ' in source_val:
        try:
            # Attempt to parse the value as a datetime
            parsed_datetime = datetime.strptime(source_val, '%Y-%m-%d %H:%M:%S')
            formatted_datetime = f"TO_DATE('{parsed_datetime.strftime('%Y-%m-%d %H:%M:%S')}', 'YYYY-MM-DD HH24:MI:SS')"
            insert_columns.append(column_name)
            insert_values.append(formatted_datetime)
        except ValueError:
            insert_columns.append(column_name)
            insert_values.append('NULL')
    else:
        insert_columns.append(column_name)
        insert_values.append(f"'{source_val}'" if source_val is not None else 'NULL')

insert_query += ", ".join(insert_columns)
insert_query += ") VALUES ("
insert_query += ", ".join(insert_values)
insert_query += ")"