Whether you have structured or unstructured text, numerical data, or geospatial data, Elasticsearch can efficiently store and index it to support fast searches.<\/p>\n\n\n\n
One of the fundamental strengths of Elasticsearch lies in its scalability and speed<\/strong>. Its distributed nature allows for horizontal scaling, accommodating growing data needs seamlessly. <\/p>\n\n\n\n Additionally, its near real-time indexing capability<\/a> ensures that data is available for search immediately after ingestion.<\/p>\n\n\n\n Elasticsearch also provides several other sorting techniques by default. However, the customized sort technique is one of my favorites and has several use cases.<\/p>\n\n\n\n To get started, we first need to create a module<\/a> in which we write our functionality.<\/p>\n\n\n\n You can also connect with a certified Magento 2 development company<\/a> that can assist you with the development of Adobe Commerce extensions.<\/p>\n\n\n\n After creating the module we need to create a plugin to modify the Elasticsearch query. For that, we first define our plugin in the di.xml<\/strong> file at path app\/code\/VendorName\/ModuleName\/etc\/di.xml<\/strong><\/p>\n\n\n\n After defining the plugin we need to create our plugin file at the location defined in the definition of the plugin.<\/p>\n\n\n\n The code that actually helps in sorting is.<\/p>\n\n\n\n Our actual query format looks something like this.<\/p>\n\n\n\n Here our sortOrder array contains all the odd product IDs first and all the even product IDs after them which causes our product listing to sort products that way.<\/p>\n\n\n\n According to the above code, our product listing will look like this.<\/p>\n\n\n\n That’s all guys we have successfully customized the sort order for our product listing.<\/p>\n\n\n\n You can also find other sorting techniques<\/a> Elasticsearch provides to understand the Elasticsearch better.<\/p>\n\n\n\n Take the opportunity to browse through our range of Magento 2 extensions<\/a>, meticulously created by certified Adobe Commerce Developers.<\/p>\n\n\n\n<?xml version="1.0"?>\n<config xmlns:xsi="http:\/\/www.w3.org\/2001\/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework:ObjectManager\/etc\/config.xsd">\n <type name="Magento\\Framework\\Search\\AdapterInterface">\n <plugin name="customize_elasticsearch_search_results" type="Webkul\\CustomizeElasticsearch\\Plugin\\Elasticsearch7\\SearchAdapter\\Adapter" sortOrder="1" \/>\n <\/type>\n<\/config><\/pre>\n\n\n\n
<?php\nnamespace Webkul\\CustomizeElasticsearch\\Plugin\\Elasticsearch7\\SearchAdapter;\n\nuse Magento\\Framework\\Search\\RequestInterface;\nuse Magento\\Elasticsearch7\\SearchAdapter\\Mapper;\nuse Magento\\Elasticsearch\\SearchAdapter\\ResponseFactory;\nuse Magento\\Elasticsearch\\SearchAdapter\\ConnectionManager;\nuse Magento\\Elasticsearch\\SearchAdapter\\QueryContainerFactory;\nuse Magento\\Elasticsearch\\SearchAdapter\\Aggregation\\Builder as AggregationBuilder;\n\nclass Adapter\n{\n \/**\n * @var array\n *\/\n private static $emptyRawResponse = [\n "hits" =>\n [\n "hits" => []\n ],\n "aggregations" =>\n [\n "price_bucket" => [],\n "category_bucket" =>\n [\n "buckets" => []\n\n ]\n ]\n ];\n\n \/**\n * Dependency Initilization\n *\n * @param Mapper $mapper\n * @param \\Psr\\Log\\LoggerInterface $logger\n * @param ResponseFactory $responseFactory\n * @param ConnectionManager $connectionManager\n * @param AggregationBuilder $aggregationBuilder\n * @param QueryContainerFactory $queryContainerFactory\n * @param \\Magento\\Framework\\Message\\ManagerInterface $messageManager\n * @param \\Magento\\Catalog\\Model\\ResourceModel\\Product\\CollectionFactory $collectionFactory\n *\/\n public function __construct(\n private Mapper $mapper,\n private \\Psr\\Log\\LoggerInterface $logger,\n private ResponseFactory $responseFactory,\n private ConnectionManager $connectionManager,\n private AggregationBuilder $aggregationBuilder,\n private QueryContainerFactory $queryContainerFactory,\n private \\Magento\\Framework\\Message\\ManagerInterface $messageManager,\n private \\Magento\\Catalog\\Model\\ResourceModel\\Product\\CollectionFactory $collectionFactory\n ) {\n }\n\n \/**\n * Add seller product to seller collection\n *\n * @param \\Magento\\Framework\\Search\\AdapterInterface $subject\n * @param callable $proceed\n * @param RequestInterface $request\n *\/\n public function aroundQuery(\n \\Magento\\Framework\\Search\\AdapterInterface $subject,\n callable $proceed,\n RequestInterface $request\n ) {\n try {\n $productIds = $this->getProductCustomSortOrder();\n $client = $this->connectionManager->getConnection();\n $aggregationBuilder = $this->aggregationBuilder;\n $updatedQuery = $this->mapper->buildQuery($request);\n unset($updatedQuery['body']['query']['bool']['should']);\n unset($updatedQuery['body']['query']['bool']['minimum_should_match']);\n unset($updatedQuery['body']['sort']);\n $updatedQuery['body']['sort'][0]['_script']['type'] = 'number';\n $setSortOrderAttribute = 'params.sortOrder.indexOf(doc["_id"].value)';\n $updatedQuery['body']['sort'][0]['_script']['script']['inline'] = $setSortOrderAttribute;\n $updatedQuery['body']['sort'][0]['_script']['script']['params']['sortOrder'] = $productIds;\n unset($updatedQuery['body']['sort'][0]['_score']);\n $updatedQuery['body']['query']['bool']['filter'] = ['ids' => ['values' => $productIds]];\n $aggregationBuilder->setQuery($this->queryContainerFactory->create(['query' => $updatedQuery]));\n try {\n $rawResponse = $client->query($updatedQuery);\n } catch (\\Exception $e) {\n $this->logger->debug(\n "Elasticsearch7_SearchAdapter_Adapter aroundQuery " . $e->getMessage()\n );\n $rawResponse = self::$emptyRawResponse;\n }\n $rawDocuments = $rawResponse['hits']['hits'] ?? [];\n $queryResponse = $this->responseFactory->create(\n [\n 'documents' => $rawDocuments,\n 'aggregations' => $aggregationBuilder->build($request, $rawResponse),\n 'total' => $rawResponse['hits']['total']['value'] ?? 0\n ]\n );\n return $queryResponse;\n } catch (\\Exception $e) {\n $this->logger->debug(\n "Elasticsearch7_SearchAdapter_Adapter aroundQuery " . $e->getMessage()\n );\n $this->messageManager->addError(__($e->getMessage()));\n }\n return $proceed($request);\n }\n\n \/**\n * Get Product Custom SortOrder\n *\n * @return array\n *\/\n private function getProductCustomSortOrder()\n {\n $products = $this->collectionFactory->create()\n ->addFieldToFilter('visibility', ['in' => [3, 4]]);\n $evenProductIds = [];\n $oddProductIds = [];\n foreach ($products as $product) {\n if ($product->getEntityId() % 2 == 0) {\n $evenProductIds[] = $product->getEntityId();\n } else {\n $oddProductIds[] = $product->getEntityId();\n }\n }\n return array_merge($oddProductIds, $evenProductIds);\n }\n}<\/pre>\n\n\n\n$updatedQuery['body']['sort'][0]['_script']['type'] = 'number';\n$setSortOrderAttribute = 'params.sortOrder.indexOf(doc["_id"].value)';\n$updatedQuery['body']['sort'][0]['_script']['script']['inline'] = $setSortOrderAttribute;\n$updatedQuery['body']['sort'][0]['_script']['script']['params']['sortOrder'] = $productIds;<\/pre>\n\n\n\n
Array\n(\n [body] => Array\n (\n [sort] => Array\n (\n [0] => Array\n (\n [_script] => Array\n (\n [type] => number\n [script] => Array\n (\n [inline] => params.sortOrder.indexOf(doc["_id"].value)\n [params] => Array\n (\n [sortOrder] => Array\n (\n [0] => 1\n [1] => 3\n [2] => 5\n [3] => 7\n [4] => 9\n [5] => 2\n [6] => 4\n [7] => 6\n [8] => 8\n [9] => 10\n )\n )\n )\n )\n )\n )\n )\n)<\/pre>\n\n\n\n
![\"Product](\"https:\/\/cdnblog.webkul.com\/blog\/wp-content\/uploads\/2024\/05\/blogimageproductlisting-1-1200x666.webp\")
<\/figure>\n\n\n\n