Avoid issues when serializing during migration

danog · Apr 7, 2024 · e1c3efd · e1c3efd
1 parent ee7a261
commit e1c3efd
Show file tree

Hide file tree

Showing 2 changed files with 45 additions and 46 deletions.
diff --git a/src/Internal/Driver/MysqlArray.php b/src/Internal/Driver/MysqlArray.php
@@ -142,6 +142,30 @@ public function __construct(DbArrayBuilder $config, Serializer $serializer)
             ValueType::BOOL => new BoolInt,
             default => new Passthrough
         };
+        /** @psalm-suppress InvalidArgument */
+        parent::__construct(
+            $config,
+            $serializer,
+            $db,
+            "SELECT `value` FROM `{$config->table}` WHERE `key` = :index LIMIT 1",
+            "
+                REPLACE INTO `{$config->table}` 
+                SET `key` = :index, `value` = :value 
+            ",
+            "
+                DELETE FROM `{$config->table}`
+                WHERE `key` = :index
+            ",
+            "
+                SELECT count(`key`) as `count` FROM `{$config->table}`
+            ",
+            "
+                SELECT `key`, `value` FROM `{$config->table}`
+            ",
+            "
+                DELETE FROM `{$config->table}`
+            "
+        );
 
         $db->query("
             CREATE TABLE IF NOT EXISTS `{$config->table}`
@@ -198,31 +222,6 @@ public function __construct(DbArrayBuilder $config, Serializer $serializer)
                 $db->query("OPTIMIZE TABLE `{$config->table}`");
             }
         }
-
-        /** @psalm-suppress InvalidArgument */
-        parent::__construct(
-            $config,
-            $serializer,
-            $db,
-            "SELECT `value` FROM `{$config->table}` WHERE `key` = :index LIMIT 1",
-            "
-                REPLACE INTO `{$config->table}` 
-                SET `key` = :index, `value` = :value 
-            ",
-            "
-                DELETE FROM `{$config->table}`
-                WHERE `key` = :index
-            ",
-            "
-                SELECT count(`key`) as `count` FROM `{$config->table}`
-            ",
-            "
-                SELECT `key`, `value` FROM `{$config->table}`
-            ",
-            "
-                DELETE FROM `{$config->table}`
-            "
-        );
     }
 
     /**

diff --git a/src/Internal/Driver/PostgresArray.php b/src/Internal/Driver/PostgresArray.php
@@ -108,6 +108,27 @@ public function __construct(DbArrayBuilder $config, Serializer $serializer)
             default => new Passthrough
         };
 
+        /** @psalm-suppress InvalidArgument */
+        parent::__construct(
+            $config,
+            $serializer,
+            $connection,
+            "SELECT value FROM \"bytea_{$config->table}\" WHERE key = :index",
+            "
+                INSERT INTO \"bytea_{$config->table}\"
+                (key,value)
+                VALUES (:index, :value)
+                ON CONFLICT (key) DO UPDATE SET value = :value
+            ",
+            "
+                DELETE FROM \"bytea_{$config->table}\"
+                WHERE key = :index
+            ",
+            "SELECT count(key) as count FROM \"bytea_{$config->table}\"",
+            "SELECT key, value FROM \"bytea_{$config->table}\"",
+            "DELETE FROM \"bytea_{$config->table}\""
+        );
+
         $connection->query("
             CREATE TABLE IF NOT EXISTS \"bytea_{$config->table}\"
             (
@@ -147,27 +168,6 @@ public function __construct(DbArrayBuilder $config, Serializer $serializer)
                 // @codeCoverageIgnoreEnd
             }
         }
-
-        /** @psalm-suppress InvalidArgument */
-        parent::__construct(
-            $config,
-            $serializer,
-            $connection,
-            "SELECT value FROM \"bytea_{$config->table}\" WHERE key = :index",
-            "
-                INSERT INTO \"bytea_{$config->table}\"
-                (key,value)
-                VALUES (:index, :value)
-                ON CONFLICT (key) DO UPDATE SET value = :value
-            ",
-            "
-                DELETE FROM \"bytea_{$config->table}\"
-                WHERE key = :index
-            ",
-            "SELECT count(key) as count FROM \"bytea_{$config->table}\"",
-            "SELECT key, value FROM \"bytea_{$config->table}\"",
-            "DELETE FROM \"bytea_{$config->table}\""
-        );
     }
 
     protected function importFromTable(string $fromTable): void