Merge pull request #9 from spiral/save-tree-sequences

save looped sequences + more tests

source/Spiral/ORM/Entities/Relations/BelongsToMorphedRelation.php

@@ -99,8 +99,13 @@ protected function getRoles(): array
     private function queueRelated(
         ContextualCommandInterface $parentCommand
     ): ContextualCommandInterface {
-        //Command or command set needed to store
-        $innerCommand = $this->instance->queueStore(true);
+        /*
+         * Only queue parent relations when parent wasn't saved already, attention, this might
+         * cause an issues with very deep recursive structures (and it's expected).
+         */
+        $innerCommand = $this->instance->queueStore(
+            !$this->instance->isLoaded()
+        );
 
         if (!$this->isSynced($this->parent, $this->instance)) {
             //Syncing FKs before primary command been executed

source/Spiral/ORM/Entities/Relations/BelongsToRelation.php

@@ -75,8 +75,13 @@ public function queueCommands(ContextualCommandInterface $parentCommand): Comman
     private function queueRelated(
         ContextualCommandInterface $parentCommand
     ): ContextualCommandInterface {
-        //Command or command set needed to store
-        $innerCommand = $this->instance->queueStore(true);
+        /*
+         * Only queue parent relations when parent wasn't saved already, attention, this might
+         * cause an issues with very deep recursive structures (and it's expected).
+         */
+        $innerCommand = $this->instance->queueStore(
+            !$this->instance->isLoaded()
+        );
 
         if (!$this->isSynced($this->parent, $this->instance)) {
             //Syncing FKs before primary command been executed

source/Spiral/ORM/RecordInterface.php

@@ -13,6 +13,13 @@
 
 interface RecordInterface extends EntityInterface
 {
+    /**
+     * Indication that record has allocated database row.
+     *
+     * @return bool
+     */
+    public function isLoaded(): bool;
+
     /**
      * Can be null.
      *

tests/ORM/MySQL/TreeSequenceTest.php

@@ -0,0 +1,15 @@
+<?php
+/**
+ * orm
+ *
+ * @author    Wolfy-J
+ */
+
+namespace Spiral\Tests\ORM\MySQL;
+
+use Spiral\Tests\Database\MySQL\DriverTrait;
+
+class TreeSequenceTest extends \Spiral\Tests\ORM\TreeSequenceTest
+{
+    use DriverTrait;
+}

tests/ORM/Postgres/TreeSequenceTest.php

@@ -0,0 +1,15 @@
+<?php
+/**
+ * orm
+ *
+ * @author    Wolfy-J
+ */
+
+namespace Spiral\Tests\ORM\Postgres;
+
+use Spiral\Tests\Database\Postgres\DriverTrait;
+
+class TreeSequenceTest extends \Spiral\Tests\ORM\TreeSequenceTest
+{
+    use DriverTrait;
+}

tests/ORM/SQLServer/TreeSequenceTest.php

@@ -0,0 +1,15 @@
+<?php
+/**
+ * orm
+ *
+ * @author    Wolfy-J
+ */
+
+namespace Spiral\Tests\ORM\SQLServer;
+
+use Spiral\Tests\Database\SQLServer\DriverTrait;
+
+class TreeSequenceTest extends \Spiral\Tests\ORM\TreeSequenceTest
+{
+    use DriverTrait;
+}

tests/ORM/SQLite/TreeSequenceTest.php

@@ -0,0 +1,15 @@
+<?php
+/**
+ * orm
+ *
+ * @author    Wolfy-J
+ */
+
+namespace Spiral\Tests\ORM\SQLite;
+
+use Spiral\Tests\Database\SQLite\DriverTrait;
+
+class TreeSequenceTest extends \Spiral\Tests\ORM\TreeSequenceTest
+{
+    use DriverTrait;
+}

tests/ORM/TreeSequenceTest.php

@@ -0,0 +1,103 @@
+<?php
+/**
+ * orm
+ *
+ * @author    Wolfy-J
+ */
+
+namespace Spiral\Tests\ORM;
+
+use Spiral\ORM\Transaction;
+use Spiral\Tests\ORM\Fixtures\Post;
+use Spiral\Tests\ORM\Fixtures\User;
+
+abstract class TreeSequenceTest extends BaseTest
+{
+    public function testSaveParentAndChild()
+    {
+        $user = new User();
+
+        $post = new Post();
+        $post->author = $user;
+
+        $transaction = new Transaction();
+        $transaction->store($user);
+        $transaction->store($post);
+
+        $transaction->run();
+
+        $this->assertSameInDB($user);
+        $this->assertSameInDB($post);
+    }
+
+    public function testSaveChildAndParent()
+    {
+        $user = new User();
+
+        $post = new Post();
+        $post->author = $user;
+
+        $transaction = new Transaction();
+        $transaction->store($post);
+        $transaction->store($user);
+
+        $transaction->run();
+
+        $this->assertSameInDB($user);
+        $this->assertSameInDB($post);
+    }
+
+    public function testSaveChildAndParentLOOP()
+    {
+        $user = new User();
+
+        $post = new Post();
+        $post->author = $user;
+        $user->posts->add(clone $post);
+
+        $transaction = new Transaction();
+        $transaction->store($post);
+        $transaction->store($user);
+
+        $transaction->run();
+
+        $this->assertSameInDB($user);
+        $this->assertSameInDB($post);
+    }
+
+    public function testSaveChildAndParentLOOP_noParentSave()
+    {
+        $user = new User();
+
+        $post = new Post();
+        $post->author = $user;
+        $user->posts->add(clone $post);
+
+        $transaction = new Transaction();
+        $transaction->store($post);
+
+        $transaction->run();
+
+        $this->assertSameInDB($user);
+        $this->assertSameInDB($post);
+    }
+
+    public function testSavedParentAndChildLOOP()
+    {
+        $user = new User();
+
+        $post = new Post();
+        $post->author = $user;
+        $user->posts->add(clone $post);
+
+        $transaction = new Transaction();
+
+        $transaction->store($user);
+        $transaction->store($post);
+
+        $transaction->run();
+
+        $this->assertSameInDB($user);
+        $this->assertSameInDB($post);
+    }
+}