Elasticsearch Mapping Types в PHP

Question

Я хочу подключиться к нашему Серверу asticsearch (V7.0.0), используя официальный клиент PHP. В документации эластичного поиска указано, что типы сопоставления были удалены в Версии 6.0.0.

Но в целом официальные типы документации PHP Client все еще упоминаются и кажутся необходимыми (например):

// Set the index and type
$params = [
    'index' => 'my_index',
    'type' => 'my_type2',
    'body' => [
        'my_type2' => [
            '_source' => [
                'enabled' => true
            ],
            'properties' => [
                'first_name' => [
                    'type' => 'keyword',
                    'analyzer' => 'standard'
                ],
                'age' => [
                    'type' => 'integer'
                ]
            ]
        ]
    ]
];

// Update the index mapping
$client->indices()->putMapping($params);

Источник

Может кто-нибудь объяснить мне, почему я все еще должен использовать типы, когда они были удалены?

Answer 1

Картографирование types были удалены в Elasticsearch 7.x, В предыдущей версии (Elasticsearch 6.x вам нужно указать только ОДИН тип для каждого индекса), в то время как в версии 2.x - 5.6 Вы можете использовать более одного типа для каждого индекса. Пожалуйста, проверьте ваши версии документации.

• Удаление типов [7.X]

• PHP API [6.X]

Так как у вас есть Elasticsearch 6.0.0нужно указать тип отображений, и я не совсем уверен в этом API будет даже работать с более новой версией Elasticsearch 7.X

Вот матрица версий для php API:

Elasticsearch Version   Elasticsearch-PHP Branch
>= 6.6, < 7.0                              6.7.x
>= 6.0, < 6.6                              6.5.x
>= 5.0, < 6.0                                5.0
>= 2.0, < 5.0                         1.0 or 2.0
>= 1.0, < 2.0                         1.0 or 2.0
<= 0.90.x                                    0.4

Answer 2

Elasticsearch 7.15 с использованием версии php 8.0. TO отображение таблицы базы данных в Elasticsearch 7.15 на локальном хосте

      <?php
    require 'includes/connection.php';
    require 'vendor/autoload.php';

    class SearchElastic {
        
        private $elasticclient = null;
        
        public function __construct(){
            $db = new Connection();
            $this->con = $db->connect();
            //echo "<pre>";print_r($this->con); //die;
            
            $hosts = [
                'http://localhost:9200'        // SSL to localhost
            ];
            
            $this->elasticclient = Elasticsearch\ClientBuilder::create()->setHosts($hosts)->build();
        }
        
        public function Mapping(){
            $params = ['index' => 'employees'];
            $response = $this->elasticclient->indices()->delete($params);
            $params = [
                'index' => 'employees',
                'body' => [             
                    'mappings' => [             
                        'properties' => [
                            'code' => [
                                'type' => 'integer'
                            ],
                            'name' => [
                                'type' => 'text'
                            ],
                            'created_at' => [
                                'type' => 'text'
                            ],
                            'last_updated' => [
                                'type' => 'text'
                            ],
                            'rank' => [
                                'type' => 'integer'
                            ],
                        ]                   
                    ]
                ]
            ];
            //echo "<pre>"; print_r($params); //die;
            $this->elasticclient->indices()->create($params);

        }
        
        public function Search($query){
            $client = $this->elasticclient;
            $result = array();

            $i = 0;

            $params = [
                'index' => 'employees',
                'type'  => '_doc',
                'body'  => [
                    'query' => [
                        'match' => ['name' => $query],
                    ],
                    'size' => 9,
                    'sort' => [
                        ['rank' =>  'desc'],
                    ],
                ],
            ];
            
            $query = $client->search($params);
            $hits  = sizeof($query['hits']['hits']);
            $hit   = $query['hits']['hits'];
            
            $result['searchfound'] = $hits;
            while ($i < $hits) {

                $result['result'][$i] = $query['hits']['hits'][$i]['_source'];

                $i++;
            }

            return  $result;
        }
        
        public function InsertData(){
            $this->Mapping();   
            $client = $this->elasticclient;
            $stmt = "SELECT * FROM `table_name` limit 1";
            $result = $this->con->query($stmt);
            
            $params = null;
            while ($row = $result->fetch_assoc()){  
                $params['body'][] = array(
                  'index' => array(
                    '_index' => 'employees',
                    '_type' => '_doc',
                    '_id' => $row['id'],
                  ) ,
                );
                $params['body'][] = [
                    'id'         => $row['id'],
                    'name'         => $row['name'],
                    'created_at'   => $row['created_at'],
                    'last_updated' => $row['last_updated'],
                    'rank'         => $row['rank'],
                ];
            }
            $responses = $client->bulk($params);
            //echo "<pre>"; print_r($responses); die;
            return true;
        }
        
        public function UpdateData(){      
            $client = $this->elasticclient;
            $stmt = "SELECT * FROM `table_name` limit 1, 1000";
            $result = $this->con->query($stmt);
            
            $params = null;
            while ($row = $result->fetch_assoc()){  
                $params['body'][] = array(
                  'index' => array(
                    '_index' => 'employees',
                    '_type' => 'rules_employee',
                    '_type' => '_doc',
                    '_id' => $row['id'],
                  ) ,
                );
                $params['body'][] = [
                    'id'         => $row['id'],
                    'name'         => $row['name'],
                    'created_at'   => $row['created_at'],
                    'last_updated' => $row['last_updated'],
                    'rank'         => $row['rank'],
                ];
                
            }
            $responses = $client->bulk($params);
            //echo "<pre>"; print_r($responses); die;
            return true;
        }
    }
?>