FIX DELETE rowsIn compilation

Author: francerz

src/DeleteQuery.php

@@ -61,7 +61,7 @@ public function getConnection()
 
     public function rowsIn(string $table)
     {
-        $this->rowsInArray[$table];
+        $this->rowsInArray[] = $table;
     }
 
     public function getRowsIn()

src/Driver/QueryCompiler.php

@@ -152,7 +152,7 @@ protected function compileDelete(DeleteQuery $delete): string
         $query = 'DELETE FROM ';
         $rowsIn = $delete->getRowsIn();
         if (count($rowsIn) > 0) {
-            $query = 'DELETE ' . join(',', $rowsIn) . ' FROM';
+            $query = 'DELETE ' . join(',', $rowsIn) . ' FROM ';
         }
         $query .= $this->compileTable($delete->getTable());
         foreach ($delete->getJoins() as $join) {

test/DeleteQueryTest.php

@@ -24,4 +24,19 @@ public function testDeleteCase()
         $this->assertEquals('DELETE FROM table1 WHERE key = :v1', $compiled->getQuery());
         $this->assertEquals(['v1' => 15], $compiled->getValues());
     }
+
+    public function testDeleteRowsIn()
+    {
+        $query = Query::deleteFrom(['t1' => 'table1']);
+        $query->innerJoin(['t2' => 'table2'])
+            ->on('t2.key1', 't1.key1');
+        $query->where('t2.filter', 3);
+        $query->rowsIn('t1');
+
+        $compiled = $this->compiler->compileQuery($query);
+
+        $expected = 'DELETE t1 FROM table1 AS t1 INNER JOIN table2 AS t2 ON t2.key1 = t1.key1 WHERE t2.filter = :v1';
+        $this->assertEquals($expected, $compiled->getQuery());
+        $this->assertEquals(['v1' => 3], $compiled->getValues());
+    }
 }