@@ -105,18 +105,7 @@ protected function execute(InputInterface $input, OutputInterface $output)
105105 $ output ->writeln ('<info> done in ' . gmdate ('H:i:s ' , $ resultTime ) . '</info> ' );
106106 }
107107
108- $ viewConfig = $ fixtureModel ->getObjectManager ()->create (CollectionInterface::class);
109-
110- /* @var ResourceConnection $resource */
111- $ resource = $ fixtureModel ->getObjectManager ()->get (ResourceConnection::class);
112-
113- foreach ($ viewConfig as $ view ) {
114- /* @var \Magento\Framework\Mview\ViewInterface $view */
115- $ changeLogTableName = $ resource ->getTableName ($ view ->getChangelog ()->getName ());
116- if ($ resource ->getConnection ()->isTableExists ($ changeLogTableName )) {
117- $ resource ->getConnection ()->truncateTable ($ changeLogTableName );
118- }
119- }
108+ $ this ->clearChangelog ();
120109
121110 foreach ($ indexerListIds as $ indexerId ) {
122111 /** @var $indexer \Magento\Indexer\Model\Indexer */
@@ -138,4 +127,25 @@ protected function execute(InputInterface $input, OutputInterface $output)
138127 return \Magento \Framework \Console \Cli::RETURN_FAILURE ;
139128 }
140129 }
130+
131+ /**
132+ * Clear changelog after generation
133+ *
134+ * @return void
135+ */
136+ private function clearChangelog ()
137+ {
138+ $ viewConfig = $ this ->fixtureModel ->getObjectManager ()->create (CollectionInterface::class);
139+
140+ /* @var ResourceConnection $resource */
141+ $ resource = $ this ->fixtureModel ->getObjectManager ()->get (ResourceConnection::class);
142+
143+ foreach ($ viewConfig as $ view ) {
144+ /* @var \Magento\Framework\Mview\ViewInterface $view */
145+ $ changeLogTableName = $ resource ->getTableName ($ view ->getChangelog ()->getName ());
146+ if ($ resource ->getConnection ()->isTableExists ($ changeLogTableName )) {
147+ $ resource ->getConnection ()->truncateTable ($ changeLogTableName );
148+ }
149+ }
150+ }
141151}
0 commit comments