SourceRowSizeEstimator.php

Go to the documentation of this file.

<?php
namespace Magento\Catalog\Model\ResourceModel\Product\Indexer\Eav;

use Magento\Store\Api\StoreManagementInterface;
use Magento\Framework\Indexer\IndexTableRowSizeEstimatorInterface;
use Magento\Framework\EntityManager\MetadataPool;
use Magento\Catalog\Api\Data\ProductInterface;
use Magento\Framework\DB\Adapter\AdapterInterface;

class SourceRowSizeEstimator implements IndexTableRowSizeEstimatorInterface
{
    private $storeManagement;

    private $indexerResource;

    private $metadataPool;

    public function __construct(
        StoreManagementInterface $storeManagement,
        Source $indexerResource,
        MetadataPool $metadataPool
    ) {
        $this->storeManagement = $storeManagement;
        $this->indexerResource = $indexerResource;
        $this->metadataPool = $metadataPool;
    }

    public function estimateRowSize()
    {
        $connection = $this->indexerResource->getConnection();
        $entityIdField = $this->metadataPool->getMetadata(ProductInterface::class)->getLinkField();

        $maxRowsPerStore = max(
            $this->getMaxRowsPerStore(
                $connection,
                $this->indexerResource->getTable('catalog_product_entity_int'),
                $entityIdField
            ),
            $this->getMaxRowsPerStore(
                $connection,
                $this->indexerResource->getTable('catalog_product_entity_varchar'),
                $entityIdField
            )
        );

        return ceil($maxRowsPerStore * $this->storeManagement->getCount() * 500);
    }

    private function getMaxRowsPerStore(
        AdapterInterface $connection,
        $valueTable,
        $entityIdField
    ) {
        $valueSelect = $connection->select();
        $valueSelect->from(
            ['value_table' => $valueTable],
            ['count' => new \Zend_Db_Expr('count(value_table.value_id)')]
        );
        $valueSelect->group([$entityIdField, 'store_id']);

        $maxSelect = $connection->select();
        $maxSelect->from(
            ['max_value' => $valueSelect],
            ['count' => new \Zend_Db_Expr('MAX(count)')]
        );
        return $connection->fetchOne($maxSelect);
    }
}