PHP 中的 Elasticsearch 映射类型

Question

我想连接到我们的elasticsearch服务器（V7.0.0）使用官方PHP Client. The elasticsearch Documentation states that mapping types have been removed版本6.0.0.

但在整个官方PHP客户端文档类型中仍然提到并且似乎是必要的（例如）：

// 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);

Source

任何人都可以向我解释为什么在删除类型后我仍然必须使用它们吗？

Answer 1

映射 types 已在 Elasticsearch 7.x 中删除。在以前的版本中（Elasticsearch 6.x 你只需要为每个索引指定一种类型），而在版本 2.x - 5.6 中你可以为每个索引使用多个类型。请检查您的文档版本。

因为你有 Elasticsearch 6.0.0，你需要指定映射类型，我不太确定这个 API 甚至可以与更新版本的 Elasticsearch 7.X[=21= 一起使用]

这是 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 版本。在本地主机

中的 Elasticsearch 7.15 中映射数据库 table

<?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;
        }
    }
?>

PHP 中的 Elasticsearch 映射类型

Elasticsearch Mapping Types in PHP

php

elasticsearch

elasticsearch-php