Joins

composer.json

@@ -26,7 +26,7 @@
         "ext-curl": "*",
         "ext-openssl": "*",
         "appwrite/appwrite": "19.*",
-        "utopia-php/database": "4.*",
+        "utopia-php/database": "dev-joins8 as 4.5.2",
         "utopia-php/storage": "0.18.*",
         "utopia-php/dsn": "0.2.*",
         "utopia-php/console": "0.0.*"

src/Migration/Resources/Database/Database.php

@@ -38,6 +38,7 @@ public function __construct(
      *     updatedAt: string,
      *     enabled: bool,
      *     originalId: string|null,
+     *     type: string|null,
      * } $array
      */
     public static function fromArray(array $array): self

src/Migration/Sources/Appwrite.php

@@ -1142,7 +1142,9 @@ private function exportRows(int $batchSize): void
                 }
                 /** @var Column|Relationship $attribute */
 
-                $queries[] = $this->database->querySelect($selects);
+                foreach ($selects as $select) {
+                    $queries[] = $this->database->querySelect($select);
+                }
 
                 $response = $this->database->listRows($table, $queries);
 

src/Migration/Sources/Appwrite/Reader.php

@@ -2,6 +2,7 @@
 
 namespace Utopia\Migration\Sources\Appwrite;
 
+use Utopia\Database\Query;
 use Utopia\Migration\Resource;
 use Utopia\Migration\Resources\Database\Database;
 use Utopia\Migration\Resources\Database\Table;
@@ -78,10 +79,10 @@ public function getRow(Table $resource, string $rowId, array $queries = []): arr
     /**
      * Return a query to select the given attributes
      *
-     * @param array $columns
+     * @param string $column
      * @return QueryType|string
      */
-    public function querySelect(array $columns): mixed;
+    public function querySelect(string $column): mixed;
 
     /**
      * Return a query to filter the given attributes

src/Migration/Sources/Appwrite/Reader/API.php

@@ -212,12 +212,17 @@ public function getRow(Table $resource, string $rowId, array $queries = []): arr
     }
 
     /**
-     * @param array $columns
-     * @return string
+     * @param string $column
+     * @return Query
      */
-    public function querySelect(array $columns): string
+    public function querySelect(string $column): string
     {
-        return Query::select($columns);
+        return new Query('select', $column);
+
+        /**
+         * todo fix Query::select to get attribute not array
+         */
+        return Query::select($column);
     }
 
     /**

src/Migration/Sources/Appwrite/Reader/Database.php

@@ -360,12 +360,12 @@ public function getRow(TableResource $resource, string $rowId, array $queries =
     }
 
     /**
-     * @param array $columns
+     * @param string $column
      * @return Query
      */
-    public function querySelect(array $columns): Query
+    public function querySelect(string $column): Query
     {
-        return Query::select($columns);
+        return Query::select($column);
     }
 
     /**