add migration

rust-playground · Sep 23, 2023 · 52c321f · 52c321f
1 parent 018b5c7
commit 52c321f
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 4 deletions.
diff --git a/relay-backend-postgres/migrations/1695506628848_bytea.sql b/relay-backend-postgres/migrations/1695506628848_bytea.sql
@@ -0,0 +1,4 @@
+ALTER TABLE jobs ALTER COLUMN data TYPE text;
+ALTER TABLE jobs ALTER COLUMN state TYPE text;
+ALTER TABLE jobs ALTER COLUMN data TYPE bytea USING data::bytea;
+ALTER TABLE jobs ALTER COLUMN state TYPE bytea USING state::bytea;
diff --git a/relay-backend-postgres/src/postgres.rs b/relay-backend-postgres/src/postgres.rs
@@ -25,10 +25,16 @@ use tokio_postgres::{Config as PostgresConfig, Row};
 use tokio_stream::{Stream, StreamExt};
 use tracing::{debug, warn};
 
-const MIGRATIONS: [Migration; 1] = [Migration::new(
-    "1678464484380_initialize.sql",
-    include_str!("../migrations/1678464484380_initialize.sql"),
-)];
+const MIGRATIONS: [Migration; 2] = [
+    Migration::new(
+        "1678464484380_initialize.sql",
+        include_str!("../migrations/1678464484380_initialize.sql"),
+    ),
+    Migration::new(
+        "1695506628848_bytea.sql",
+        include_str!("../migrations/1695506628848_bytea.sql"),
+    ),
+];
 
 /// `RawJob` represents a Relay Job for the Postgres backend.
 type RawJob = Job<Box<RawValue>, Box<RawValue>>;