Bugfix/Migration-command-forces-dbId-with-getId-instead-of-using-the-configured-identifier-

src/Adapter/Doctrine/DoctrineTenantDatabaseManager.php

@@ -69,7 +69,7 @@ public function getTenantDbListByDatabaseStatus(DatabaseStatusEnum $status): arr
             );
     }
 
-    public function getTenantDatabaseById(int $identifier): TenantConnectionConfigDTO
+    public function getTenantDatabaseById(mixed $identifier): TenantConnectionConfigDTO
     {
         $tenantDbConfig = $this->tenantDatabaseRepository->findOneBy([$this->tenantDbIdentifier => $identifier]);
         if (null === $tenantDbConfig) {
@@ -109,7 +109,7 @@ public function createTenantDatabase(TenantConnectionConfigDTO $tenantConnection
         }
     }
 
-    public function updateTenantDatabaseStatus(int $identifier, DatabaseStatusEnum $status): bool
+    public function updateTenantDatabaseStatus(mixed $identifier, DatabaseStatusEnum $status): bool
     {
         $tenantDbConfig = $this->tenantDatabaseRepository->findOneBy([$this->tenantDbIdentifier => $identifier]);
         if (null === $tenantDbConfig) {
@@ -142,7 +142,7 @@ public function addNewTenantDbConfig(TenantConnectionConfigDTO $dto): TenantConn
     private function convertToDTO(TenantDbConfigurationInterface $dbConfig): TenantConnectionConfigDTO
     {
         return TenantConnectionConfigDTO::fromArgs(
-            identifier: $dbConfig->getId() ?? null,
+            identifier: $dbConfig->getIdentifierValue() ?? null,
             driver: $dbConfig->getDriverType(),
             dbStatus: $dbConfig->getDatabaseStatus(),
             host: $dbConfig->getDbHost(),

src/Command/MigrateCommand.php

@@ -57,7 +57,36 @@ protected function configure(): void
 
     protected function execute(InputInterface $input, OutputInterface $output): int
     {
+        $dbId = $input->getArgument('dbId');
+        $migrationType = $input->getArgument('type');
         $io = new SymfonyStyle($input, $output);
+
+        if ($dbId !== null) {
+            $io->warning('DEPRECATION: The "dbId" argument is deprecated and will be removed in v4.0.');
+            $io->note(sprintf('Migrating specific database with identifier: %s', $dbId));
+            $io->newLine();
+
+            try {
+                $tenantDb = $this->tenantDatabaseManager->getTenantDatabaseById($dbId);
+
+                if ($migrationType === self::MIGRATE_TYPE_INIT && $tenantDb->dbStatus !== DatabaseStatusEnum::DATABASE_CREATED) {
+                    $io->error(sprintf('Database "%s" is not in CREATED status. Current status: %s', $dbId, $tenantDb->dbStatus->value));
+                    return 1;
+                }
+
+                if ($migrationType === self::MIGRATE_TYPE_UPDATE && $tenantDb->dbStatus !== DatabaseStatusEnum::DATABASE_MIGRATED) {
+                    $io->error(sprintf('Database "%s" is not in MIGRATED status. Current status: %s', $dbId, $tenantDb->dbStatus->value));
+                    return 1;
+                }
+
+                return $this->migrateSingleDB($input, $output, $io, $tenantDb);
+
+            } catch (\RuntimeException $e) {
+                $io->error(sprintf('Tenant database with identifier "%s" not found: %s', $dbId, $e->getMessage()));
+                return 1;
+            }
+        }
+        // Migrate all databases based on the type
         switch ($input->getArgument('type')) {
             case self::MIGRATE_TYPE_INIT:
                 $io->note('Migrating the new databases');
@@ -120,4 +149,31 @@ private function runMigrateCommand(InputInterface $input, OutputInterface $outpu
         $otherCommand = new \Doctrine\Migrations\Tools\Console\Command\MigrateCommand($this->getDependencyFactory($input));
         $otherCommand->run($newInput, $output);
     }
+
+    private function migrateSingleDB(InputInterface $input, OutputInterface $output, SymfonyStyle $io, TenantConnectionConfigDTO $tenantDb): int
+    {
+        try {
+            // we already checked that dbId is not null or add it  in the loop
+            $io->note(sprintf('Start Migrating database with identifier "%s" (Database: %s, Host: %s)', 
+                $tenantDb->identifier, $tenantDb->dbname, $tenantDb->host));
+            $io->newLine();
+
+            $this->runMigrateCommand($input, $output);
+
+            // Update database status if this was an init migration
+            if ($tenantDb->dbStatus === DatabaseStatusEnum::DATABASE_CREATED) {
+                $this->tenantDatabaseManager->updateTenantDatabaseStatus(
+                    $tenantDb->identifier, 
+                    DatabaseStatusEnum::DATABASE_MIGRATED
+                );
+                $this->registry->getManager()->flush();
+            }
+
+            $io->success(sprintf('Database with identifier "%s" migrated successfully.', $tenantDb->identifier));
+            return 0;
+        } catch (Throwable $e) {
+            $io->error(sprintf('Failed to migrate database with identifier "%s": %s', $tenantDb->identifier, $e->getMessage()));
+            return 1;
+        }
+    }
 }

src/Config/TenantConnectionConfigDTO.php

@@ -11,7 +11,7 @@
 class TenantConnectionConfigDTO
 {
     private function __construct(
-        public ?int               $identifier,
+        public mixed              $identifier,
         public DriverTypeEnum     $driver,
         public DatabaseStatusEnum $dbStatus,
         public string             $host,
@@ -24,7 +24,7 @@ private function __construct(
     }
 
     public static function fromArgs(
-        ?int               $identifier,
+        mixed              $identifier,
         DriverTypeEnum     $driver,
         DatabaseStatusEnum $dbStatus,
         string             $host,

src/Services/TenantDbConfigurationInterface.php

@@ -53,4 +53,10 @@ public function setDatabaseStatus(DatabaseStatusEnum $databaseStatus): self;
     public function getDsnUrl(): string;
 
     public function getDriverType(): DriverTypeEnum;
+
+    /**
+     * Get the tenant identifier value as configured in the system.
+     * This should return the value of the field specified in tenant_database_identifier config.
+     */
+    public function getIdentifierValue(): mixed;
 }

tests/Unit/EventListener/DbSwitchEventListenerTest.php

@@ -85,6 +85,12 @@ public function getDbName(): string
         return $this->dbName;
     }
 
+    public function getIdentifierValue(): mixed
+    {
+        return 1;
+    }
+
+
     public function setDbName(string $dbName): void
     {
         $this->dbName = $dbName;