Optional read direct from db for database resources

bin/MigrationCLI.php

@@ -213,7 +213,9 @@ public function getSource(): Source
                 return new Appwrite(
                     $_ENV['SOURCE_APPWRITE_TEST_PROJECT'],
                     $_ENV['SOURCE_APPWRITE_TEST_ENDPOINT'],
-                    $_ENV['SOURCE_APPWRITE_TEST_KEY']
+                    $_ENV['SOURCE_APPWRITE_TEST_KEY'],
+                    Appwrite::SOURCE_DATABASE,
+                    $this->getDatabase(),
                 );
             case 'supabase':
                 return new Supabase(
@@ -361,21 +363,18 @@ function (mixed $value, Document $attribute) {
             }
         );
 
-        $database = new Database(
-            new MariaDB(new PDO(
-                $_ENV['DESTINATION_APPWRITE_TEST_DSN'],
-                $_ENV['DESTINATION_APPWRITE_TEST_USER'],
-                $_ENV['DESTINATION_APPWRITE_TEST_PASSWORD'],
-                [
-                    PDO::ATTR_TIMEOUT => 3,
-                    PDO::ATTR_PERSISTENT => true,
-                    PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
-                    PDO::ATTR_EMULATE_PREPARES => true,
-                    PDO::ATTR_STRINGIFY_FETCHES => true
-                ],
-            )),
-            new Cache(new None())
-        );
+        $database = new Database(new MariaDB(new PDO(
+            $_ENV['DESTINATION_APPWRITE_TEST_DSN'],
+            $_ENV['DESTINATION_APPWRITE_TEST_USER'],
+            $_ENV['DESTINATION_APPWRITE_TEST_PASSWORD'],
+            [
+                PDO::ATTR_TIMEOUT => 3,
+                PDO::ATTR_PERSISTENT => true,
+                PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
+                PDO::ATTR_EMULATE_PREPARES => true,
+                PDO::ATTR_STRINGIFY_FETCHES => true
+            ],
+        )), new Cache(new None()));
 
         $database
             ->setDatabase('appwrite')

src/Migration/Destinations/Appwrite.php

@@ -438,6 +438,7 @@ protected function createAttribute(Attribute $resource): bool
             'databases',
             $resource->getCollection()->getDatabase()->getId(),
         );
+
         if ($database->isEmpty()) {
             throw new Exception(
                 resourceName: $resource->getName(),
@@ -451,6 +452,7 @@ protected function createAttribute(Attribute $resource): bool
             'database_' . $database->getInternalId(),
             $resource->getCollection()->getId(),
         );
+
         if ($collection->isEmpty()) {
             throw new Exception(
                 resourceName: $resource->getName(),