store: prepare for breaking changes of the database

node/src/store_builder.rs

@@ -191,7 +191,7 @@ impl StoreBuilder {
         );
         block_store
             .update_db_version()
-            .expect("Updating `db_version` works");
+            .expect("Updating `db_version` should work");
 
         Arc::new(DieselStore::new(subgraph_store, block_store))
     }

store/postgres/migrations/2025-01-08-180000_rename_db_version/down.sql

@@ -0,0 +1 @@
+-- we don't rename the column name back in order to avoid the accidental downgrade of the binary

store/postgres/migrations/2025-01-08-180000_rename_db_version/up.sql

@@ -0,0 +1,2 @@
+alter table public.db_version
+    rename column db_version to database_version;

store/postgres/src/block_store.rs

@@ -33,6 +33,10 @@ use self::primary::Chain;
 #[cfg(debug_assertions)]
 pub const FAKE_NETWORK_SHARED: &str = "fake_network_shared";
 
+// Highest version of the database that the executable supports.
+// To be incremented on each breaking change to the database.
+const SUPPORTED_DB_VERSION: i64 = 3;
+
 /// The status of a chain: whether we can only read from the chain, or
 /// whether it is ok to ingest from it, too
 #[derive(Copy, Clone)]
@@ -531,6 +535,18 @@ impl BlockStore {
                 .set(dbv::version.eq(3))
                 .execute(&mut conn)?;
         };
+        if version < SUPPORTED_DB_VERSION {
+            // Bump it to make sure that all executables are working with the same DB format
+            diesel::update(dbv::table)
+                .set(dbv::version.eq(SUPPORTED_DB_VERSION))
+                .execute(&mut conn)?;
+        };
+        if version > SUPPORTED_DB_VERSION {
+            panic!(
+                "The executable is too old and doesn't support the database version: {}",
+                version
+            )
+        }
         Ok(())
     }
 

store/postgres/src/primary.rs

@@ -186,7 +186,7 @@ table! {
 
 table! {
     public.db_version(version) {
-        #[sql_name = "db_version"]
+        #[sql_name = "database_version"]
         version -> BigInt,
     }
 }