| CREATE SCHEMA IF NOT EXISTS stg; | |
| CREATE SCHEMA IF NOT EXISTS dim; | |
| CREATE SCHEMA IF NOT EXISTS fact; | |
| CREATE SCHEMA IF NOT EXISTS rej; | |
| CREATE SCHEMA IF NOT EXISTS meta; | |
| CREATE TABLE IF NOT EXISTS meta.batch_log ( | |
| batch_id BIGSERIAL PRIMARY KEY, | |
| source_file TEXT NOT NULL, | |
| source_hash TEXT, | |
| rows_read INT, | |
| rows_loaded INT, | |
| rows_rejected INT, | |
| started_at TIMESTAMPTZ DEFAULT NOW(), | |
| finished_at TIMESTAMPTZ | |
| ); | |