@@ -105,18 +105,7 @@ protected function execute(InputInterface $input, OutputInterface $output)
105
105
$ output ->writeln ('<info> done in ' . gmdate ('H:i:s ' , $ resultTime ) . '</info> ' );
106
106
}
107
107
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 ();
120
109
121
110
foreach ($ indexerListIds as $ indexerId ) {
122
111
/** @var $indexer \Magento\Indexer\Model\Indexer */
@@ -138,4 +127,25 @@ protected function execute(InputInterface $input, OutputInterface $output)
138
127
return \Magento \Framework \Console \Cli::RETURN_FAILURE ;
139
128
}
140
129
}
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
+ }
141
151
}
0 commit comments