File size: 465 Bytes
02fd3ca | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 | 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
);
|