ezsystems / ezpublish-kernel

        $i = 0;

        do {

            $contentObjects = [];

            for ($k = 0; $k <= $bulkCount; ++$k) {

                if (!$row = $stmt->fetch(PDO::FETCH_ASSOC)) {

                    break;

                }

                try {

                    $contentObjects[] = $this->persistenceHandler->contentHandler()->load(

                        $row['id'],

                        $row['current_version']

                    );

                } catch (NotFoundException $e) {

                    $this->logWarning($output, $progress, "Could not load current version of Content with id ${row['id']}, so skipped for indexing. Full exception: " . $e->getMessage());

                }

            }

            $this->searchHandler->bulkIndex(

                $contentObjects,

        $i = 0;

        do {

            $contentObjects = [];

            for ($k = 0; $k <= $iterationCount; ++$k) {

                if (!$row = $stmt->fetch(PDO::FETCH_ASSOC)) {

                    break;

                }

                try {

                    $contentObjects[] = $this->persistenceHandler->contentHandler()->load(

                        $row['id'],

                        $row['current_version']

                    );

                } catch (NotFoundException $e) {

                    $this->logWarning($progress, "Could not load current version of Content with id ${row['id']}, so skipped for indexing. Full exception: " . $e->getMessage());

                }

            }

            foreach ($contentObjects as $contentObject) {

                try {

                    $this->searchHandler->indexContent($contentObject);