Code Duplication    Length = 24-24 lines in 5 locations

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

@@ 562-585 (lines=24) @@
559
     * @throws PropelException Any exceptions caught during processing will be
560
     *                         rethrown wrapped into a PropelException.
561
     */
562
    public function delete(ConnectionInterface $con = null)
563
    {
564
        if (null === $con) {
565
            $con = Propel::getServiceContainer()->getWriteConnection(ChannelTableMap::DATABASE_NAME);
566
        }
567
568
        $criteria = $this;
569
570
        // Set the correct dbName
571
        $criteria->setDbName(ChannelTableMap::DATABASE_NAME);
572
573
        // use transaction because $criteria could contain info
574
        // for more than one table or we could emulating ON DELETE CASCADE, etc.
575
        return $con->transaction(function () use ($con, $criteria) {
576
            $affectedRows = 0; // initialize var to track total num of affected rows
577
578
            ChannelTableMap::removeInstanceFromPool($criteria);
579
580
            $affectedRows += ModelCriteria::delete($con);
581
            ChannelTableMap::clearRelatedInstancePool();
582
583
            return $affectedRows;
584
        });
585
    }
586
587
} // ChannelQuery
588

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

@@ 696-719 (lines=24) @@
693
     * @throws PropelException Any exceptions caught during processing will be
694
     *                         rethrown wrapped into a PropelException.
695
     */
696
    public function delete(ConnectionInterface $con = null)
697
    {
698
        if (null === $con) {
699
            $con = Propel::getServiceContainer()->getWriteConnection(ConnectionTableMap::DATABASE_NAME);
700
        }
701
702
        $criteria = $this;
703
704
        // Set the correct dbName
705
        $criteria->setDbName(ConnectionTableMap::DATABASE_NAME);
706
707
        // use transaction because $criteria could contain info
708
        // for more than one table or we could emulating ON DELETE CASCADE, etc.
709
        return $con->transaction(function () use ($con, $criteria) {
710
            $affectedRows = 0; // initialize var to track total num of affected rows
711
712
            ConnectionTableMap::removeInstanceFromPool($criteria);
713
714
            $affectedRows += ModelCriteria::delete($con);
715
            ConnectionTableMap::clearRelatedInstancePool();
716
717
            return $affectedRows;
718
        });
719
    }
720
721
} // ConnectionQuery
722

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

@@ 644-667 (lines=24) @@
641
     * @throws PropelException Any exceptions caught during processing will be
642
     *                         rethrown wrapped into a PropelException.
643
     */
644
    public function delete(ConnectionInterface $con = null)
645
    {
646
        if (null === $con) {
647
            $con = Propel::getServiceContainer()->getWriteConnection(InstanceTableMap::DATABASE_NAME);
648
        }
649
650
        $criteria = $this;
651
652
        // Set the correct dbName
653
        $criteria->setDbName(InstanceTableMap::DATABASE_NAME);
654
655
        // use transaction because $criteria could contain info
656
        // for more than one table or we could emulating ON DELETE CASCADE, etc.
657
        return $con->transaction(function () use ($con, $criteria) {
658
            $affectedRows = 0; // initialize var to track total num of affected rows
659
660
            InstanceTableMap::removeInstanceFromPool($criteria);
661
662
            $affectedRows += ModelCriteria::delete($con);
663
            InstanceTableMap::clearRelatedInstancePool();
664
665
            return $affectedRows;
666
        });
667
    }
668
669
} // InstanceQuery
670

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

@@ 925-948 (lines=24) @@
922
     * @throws PropelException Any exceptions caught during processing will be
923
     *                         rethrown wrapped into a PropelException.
924
     */
925
    public function delete(ConnectionInterface $con = null)
926
    {
927
        if (null === $con) {
928
            $con = Propel::getServiceContainer()->getWriteConnection(SubscriptionTableMap::DATABASE_NAME);
929
        }
930
931
        $criteria = $this;
932
933
        // Set the correct dbName
934
        $criteria->setDbName(SubscriptionTableMap::DATABASE_NAME);
935
936
        // use transaction because $criteria could contain info
937
        // for more than one table or we could emulating ON DELETE CASCADE, etc.
938
        return $con->transaction(function () use ($con, $criteria) {
939
            $affectedRows = 0; // initialize var to track total num of affected rows
940
941
            SubscriptionTableMap::removeInstanceFromPool($criteria);
942
943
            $affectedRows += ModelCriteria::delete($con);
944
            SubscriptionTableMap::clearRelatedInstancePool();
945
946
            return $affectedRows;
947
        });
948
    }
949
950
} // SubscriptionQuery
951

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

@@ 645-668 (lines=24) @@
642
     * @throws PropelException Any exceptions caught during processing will be
643
     *                         rethrown wrapped into a PropelException.
644
     */
645
    public function delete(ConnectionInterface $con = null)
646
    {
647
        if (null === $con) {
648
            $con = Propel::getServiceContainer()->getWriteConnection(UserTableMap::DATABASE_NAME);
649
        }
650
651
        $criteria = $this;
652
653
        // Set the correct dbName
654
        $criteria->setDbName(UserTableMap::DATABASE_NAME);
655
656
        // use transaction because $criteria could contain info
657
        // for more than one table or we could emulating ON DELETE CASCADE, etc.
658
        return $con->transaction(function () use ($con, $criteria) {
659
            $affectedRows = 0; // initialize var to track total num of affected rows
660
661
            UserTableMap::removeInstanceFromPool($criteria);
662
663
            $affectedRows += ModelCriteria::delete($con);
664
            UserTableMap::clearRelatedInstancePool();
665
666
            return $affectedRows;
667
        });
668
    }
669
670
} // UserQuery
671