24
24
class ChangelogBatchWalker implements ChangelogBatchWalkerInterface
25
25
{
26
26
/**
27
- * @var \Magento\Framework\App\ ResourceConnection
27
+ * @var ResourceConnection
28
28
*/
29
29
private ResourceConnection $ resourceConnection ;
30
+
30
31
/**
31
- * @var \Magento\Framework\DB\Query\ Generator
32
+ * @var Generator
32
33
*/
33
34
private Generator $ generator ;
35
+
34
36
/**
35
- * @var \Magento\Framework\Mview\View\ChangelogBatchWalker\ IdsTableBuilderInterface
37
+ * @var IdsTableBuilderInterface
36
38
*/
37
39
private IdsTableBuilderInterface $ idsTableBuilder ;
40
+
38
41
/**
39
- * @var \Magento\Framework\Mview\View\ChangelogBatchWalker\ IdsSelectBuilderInterface
42
+ * @var IdsSelectBuilderInterface
40
43
*/
41
44
private IdsSelectBuilderInterface $ idsSelectBuilder ;
45
+
42
46
/**
43
- * @var \Magento\Framework\Mview\View\ChangelogBatchWalker\ IdsFetcherInterface
47
+ * @var IdsFetcherInterface
44
48
*/
45
49
private IdsFetcherInterface $ idsFetcher ;
46
50
47
51
/**
48
52
* @param ResourceConnection $resourceConnection
49
- * @param \Magento\Framework\DB\Query\ Generator $generator
50
- * @param \Magento\Framework\Mview\View\ChangelogBatchWalker\ IdsContext $idsContext
53
+ * @param Generator $generator
54
+ * @param IdsContext $idsContext
51
55
*/
52
56
public function __construct (
53
57
ResourceConnection $ resourceConnection ,
@@ -70,9 +74,11 @@ public function walk(
70
74
int $ lastVersionId ,
71
75
int $ batchSize
72
76
): iterable {
77
+ echo '0 ' ;
73
78
$ connection = $ this ->resourceConnection ->getConnection ();
74
79
$ changelogTableName = $ this ->resourceConnection ->getTableName ($ changelog ->getName ());
75
80
81
+
76
82
if (!$ connection ->isTableExists ($ changelogTableName )) {
77
83
throw new ChangelogTableNotExistsException (new Phrase ("Table %1 does not exist " , [$ changelogTableName ]));
78
84
}
0 commit comments