Добавить версионирование схемы БД и заблокировать прод-очистку БД

shine-server-db/src/main/java/shine/db/DatabaseInitializer.java

@@ -24,6 +24,9 @@ import java.sql.Statement;
  */
 public final class DatabaseInitializer {
 
+    public static final String DB_SCHEMA_VERSION_TABLE = "db_schema_version";
+    public static final int SCHEMA_VERSION_1 = 1;
+
     private DatabaseInitializer() {}
 
     /* ===================== TEXT (msg_type=1) ===================== */
@@ -101,7 +104,15 @@ public final class DatabaseInitializer {
         }
     }
 
+    public static void ensureSchemaV1Structure(String jdbcUrl) throws SQLException {
+        createSchema(jdbcUrl, false);
+    }
+
     private static void createSchema(String jdbcUrl) throws SQLException {
+        createSchema(jdbcUrl, true);
+    }
+
+    private static void createSchema(String jdbcUrl, boolean initializeVersionRow) throws SQLException {
         try {
             Class.forName("org.sqlite.JDBC");
         } catch (ClassNotFoundException e) {
@@ -586,6 +597,24 @@ public final class DatabaseInitializer {
                 ON signed_message_session_delivery (session_id, delivered);
                 """);
 
+            st.executeUpdate("""
+                CREATE TABLE IF NOT EXISTS db_schema_version (
+                    id             INTEGER NOT NULL PRIMARY KEY CHECK (id = 1),
+                    schema_version INTEGER NOT NULL,
+                    updated_at_ms  INTEGER NOT NULL
+                );
+                """);
+
+            if (initializeVersionRow) {
+                st.executeUpdate("""
+                    INSERT INTO db_schema_version (id, schema_version, updated_at_ms)
+                    VALUES (1, 1, CAST(strftime('%s','now') AS INTEGER) * 1000)
+                    ON CONFLICT(id) DO UPDATE SET
+                        schema_version = excluded.schema_version,
+                        updated_at_ms = excluded.updated_at_ms;
+                    """);
+            }
+
             DatabaseTriggersInstaller.createAllTriggers(st);
         }
     }