fix: support default_value and last_insert_id

Author: Javakky-pxv

src/Processor/InsertProcessor.php

@@ -8,6 +8,11 @@
 
 final class InsertProcessor extends Processor
 {
+    /**
+     * @throws SQLFakeUniqueKeyViolation
+     * @throws ProcessorException
+     * @throws \Exception
+     */
     public static function process(
         \Vimeo\MysqlEngine\FakePdoInterface $conn,
         Scope $scope,
@@ -115,19 +120,45 @@ public static function process(
                 $stmt->selectQuery
             )->rows;
 
-            $row = [];
-            foreach ($selectResult as $value) {
+            foreach ($selectResult as $selected_param) {
+                $row = [];
                 foreach ($stmt->selectQuery->selectExpressions as $index => $expr) {
                     if (key_exists($index, $stmt->insertColumns)
-                        && (is_string($value[$expr->name]) || is_int($value[$expr->name]))) {
-                        $row[$stmt->insertColumns[$index]] = $value[$expr->name];
+                        && (is_string($selected_param[$expr->name]) || is_int($selected_param[$expr->name]))) {
+                        $row[$stmt->insertColumns[$index]] = $selected_param[$expr->name];
                     }
                 }
-            }
 
-            $table[] = $row;
+                $row = DataIntegrity::coerceToSchema($conn, $row, $table_definition);
+
+                $result = DataIntegrity::checkUniqueConstraints($table, $row, $table_definition);
+
+                if ($result !== null) {
+                    throw new SQLFakeUniqueKeyViolation($result[0]);
+                }
+
+                /**
+                 * @psalm-suppress MixedAssignment
+                 */
+                foreach ($row as $column_name => $value) {
+                    $column = $table_definition->columns[$column_name];
+
+                    if ($column instanceof IntegerColumn && $column->isAutoIncrement() && is_int($value)) {
+                        $last_incremented_value = $conn->getServer()->addAutoIncrementMinValue(
+                            $database,
+                            $table_name,
+                            $column_name,
+                            $value
+                        );
+                    }
+                }
+
+                $table[] = $row;
+            }
 
             $conn->getServer()->saveTable($database, $table_name, $table);
+            $conn->setLastInsertId((string)($last_incremented_value ?? 0));
+
             return count($selectResult);
         }
 

tests/EndToEndTest.php

@@ -897,14 +897,16 @@ public function testInsertWithSelect(): void
 
         $query = $pdo->prepare(
             "INSERT INTO `video_game_characters`
-                (`id`, `name`, `type`, `profession`, `console`, `is_alive`, `powerups`, `skills`, `created_on`)
+                (`name`, `type`, `profession`, `console`, `is_alive`, `powerups`, `skills`, `created_on`)
                 SELECT
-                    19+`id`, 'wario','villain','plumber','nes','1','3','{\"magic\":0, \"speed\":0, \"strength\":0, \"weapons\":0}', NOW(), 
+                    'wario','villain','plumber','nes','1','3','{\"magic\":0, \"speed\":0, \"strength\":0, \"weapons\":0}', NOW(), 
                 FROM `video_game_characters`"
         );
 
         $query->execute();
 
+        self::assertEquals($pdo->lastInsertId(), 32);
+
         $query = $pdo->prepare(
             'SELECT `id`, `name`
             FROM `video_game_characters`
@@ -916,7 +918,7 @@ public function testInsertWithSelect(): void
 
         $this->assertSame(
             [
-                ['id' => 35, 'name' => 'wario'],
+                ['id' => 32, 'name' => 'wario'],
             ],
             $query->fetchAll(PDO::FETCH_ASSOC)
         );