Code Duplication    Length = 10-10 lines in 6 locations

src/cli/Database/Base/Channel.php 1 location

@@ 664-673 (lines=10) @@
661
                $this->setInstance($this->aInstance);
662
            }
663
664
            if ($this->isNew() || $this->isModified()) {
665
                // persist changes
666
                if ($this->isNew()) {
667
                    $this->doInsert($con);
668
                    $affectedRows += 1;
669
                } else {
670
                    $affectedRows += $this->doUpdate($con);
671
                }
672
                $this->resetModified();
673
            }
674
675
            if ($this->subscriptionsScheduledForDeletion !== null) {
676
                if (!$this->subscriptionsScheduledForDeletion->isEmpty()) {

src/cli/Database/Base/Connection.php 1 location

@@ 799-808 (lines=10) @@
796
                $this->setUser($this->aUser);
797
            }
798
799
            if ($this->isNew() || $this->isModified()) {
800
                // persist changes
801
                if ($this->isNew()) {
802
                    $this->doInsert($con);
803
                    $affectedRows += 1;
804
                } else {
805
                    $affectedRows += $this->doUpdate($con);
806
                }
807
                $this->resetModified();
808
            }
809
810
            $this->alreadyInSave = false;
811

src/cli/Database/Base/User.php 1 location

@@ 681-690 (lines=10) @@
678
                $this->setInstance($this->aInstance);
679
            }
680
681
            if ($this->isNew() || $this->isModified()) {
682
                // persist changes
683
                if ($this->isNew()) {
684
                    $this->doInsert($con);
685
                    $affectedRows += 1;
686
                } else {
687
                    $affectedRows += $this->doUpdate($con);
688
                }
689
                $this->resetModified();
690
            }
691
692
            if ($this->connectionsScheduledForDeletion !== null) {
693
                if (!$this->connectionsScheduledForDeletion->isEmpty()) {

src/cli/Database/Base/Input.php 1 location

@@ 836-845 (lines=10) @@
833
                $this->setInstance($this->aInstance);
834
            }
835
836
            if ($this->isNew() || $this->isModified()) {
837
                // persist changes
838
                if ($this->isNew()) {
839
                    $this->doInsert($con);
840
                    $affectedRows += 1;
841
                } else {
842
                    $affectedRows += $this->doUpdate($con);
843
                }
844
                $this->resetModified();
845
            }
846
847
            if ($this->subscriptionsScheduledForDeletion !== null) {
848
                if (!$this->subscriptionsScheduledForDeletion->isEmpty()) {

src/cli/Database/Base/Instance.php 1 location

@@ 625-634 (lines=10) @@
622
        if (!$this->alreadyInSave) {
623
            $this->alreadyInSave = true;
624
625
            if ($this->isNew() || $this->isModified()) {
626
                // persist changes
627
                if ($this->isNew()) {
628
                    $this->doInsert($con);
629
                    $affectedRows += 1;
630
                } else {
631
                    $affectedRows += $this->doUpdate($con);
632
                }
633
                $this->resetModified();
634
            }
635
636
            if ($this->usersScheduledForDeletion !== null) {
637
                if (!$this->usersScheduledForDeletion->isEmpty()) {

src/cli/Database/Base/Subscription.php 1 location

@@ 1013-1022 (lines=10) @@
1010
                $this->setChannel($this->aChannel);
1011
            }
1012
1013
            if ($this->isNew() || $this->isModified()) {
1014
                // persist changes
1015
                if ($this->isNew()) {
1016
                    $this->doInsert($con);
1017
                    $affectedRows += 1;
1018
                } else {
1019
                    $affectedRows += $this->doUpdate($con);
1020
                }
1021
                $this->resetModified();
1022
            }
1023
1024
            $this->alreadyInSave = false;
1025