diff --git a/src/db/runtime.js b/src/db/runtime.js index 78a49a0..11f505f 100644 --- a/src/db/runtime.js +++ b/src/db/runtime.js @@ -64,12 +64,12 @@ function rewriteSql(sql, params) { text = text.replace(/AUTOINCREMENT/gi, 'GENERATED BY DEFAULT AS IDENTITY'); text = text.replace(/INTEGER\s+PRIMARY\s+KEY\s+GENERATED BY DEFAULT AS IDENTITY/gi, 'BIGINT PRIMARY KEY GENERATED BY DEFAULT AS IDENTITY'); text = text.replace(/INTEGER\s+PRIMARY\s+KEY\s+AUTOINCREMENT/gi, 'BIGINT PRIMARY KEY GENERATED BY DEFAULT AS IDENTITY'); + text = text.replace(/ingested_at\s*>=\s*datetime\('now',\s*'-48 hours'\)/gi, "ingested_at >= to_char(CURRENT_TIMESTAMP - interval '48 hours', 'YYYY-MM-DD HH24:MI:SS')"); text = text.replace(/datetime\('now',\s*\?\)/gi, 'CURRENT_TIMESTAMP + (?::interval)'); text = text.replace(/datetime\('now',\s*'\+60 seconds'\)/gi, "CURRENT_TIMESTAMP + interval '60 seconds'"); text = text.replace(/datetime\('now',\s*'([^']+)'\)/gi, "CURRENT_TIMESTAMP + interval '$1'"); text = text.replace(/datetime\('now'\)/gi, 'CURRENT_TIMESTAMP'); text = text.replace(/date\('now'\)/gi, 'CURRENT_DATE'); - text = text.replace(/\bingested_at\s*>=\s*CURRENT_TIMESTAMP/gi, 'ingested_at::timestamp >= CURRENT_TIMESTAMP'); text = text.replace(/datetime\(COALESCE\(([^)]+)\)\)/gi, 'COALESCE($1)::timestamp'); text = text.replace(/datetime\((p\.information_cutoff),\s*'\+'\s*\|\|\s*(p\.horizon_days)\s*\|\|\s*' days'\)/gi, "($1::timestamp + ($2 || ' days')::interval)"); text = text.replace(/datetime\(([^)]+)\)/gi, '($1)::timestamp');