fix max

luca-iachini · luca-iachini · commit 87efdc6dd21c · 2026-02-01T16:26:05.000+01:00
diff --git a/disintegrate-postgres/src/event_store.rs b/disintegrate-postgres/src/event_store.rs
@@ -107,7 +107,7 @@ where
     {
         let sql = format!(
             r#"SELECT event.event_id, event.payload, epoch.__epoch_id
-            FROM (SELECT MAX(event_id) AS __epoch_id FROM event) AS epoch
+            FROM (SELECT COALESCE(MAX(event_id),0) AS __epoch_id FROM event) AS epoch
             LEFT JOIN event ON event.event_id <= epoch.__epoch_id AND ({criteria})
             ORDER BY event_id ASC"#,
             criteria = CriteriaBuilder::new(query).build()

Original file line number	Diff line number	Diff line change
`@@ -107,7 +107,7 @@ where`
`107`	`107`	`{`
`108`	`108`	`let sql = format!(`
`109`	`109`	`r#"SELECT event.event_id, event.payload, epoch.__epoch_id`
`110`		`- FROM (SELECT MAX(event_id) AS __epoch_id FROM event) AS epoch`
	`110`	`+ FROM (SELECT COALESCE(MAX(event_id),0) AS __epoch_id FROM event) AS epoch`
`111`	`111`	`LEFT JOIN event ON event.event_id <= epoch.__epoch_id AND ({criteria})`
`112`	`112`	`ORDER BY event_id ASC"#,`
`113`	`113`	`criteria = CriteriaBuilder::new(query).build()`