php操作ElasticSearch搜索引擎流程详解

快乐人L

目录

• 一、安装
  
• 二、使用
  
• 三、新建ES数据库
  
• 四、创建表
  
• 五、插入数据
  
• 六、 查询所有数据
  
• 七、查询单条数据
  
• 八、搜索
  
• 九、测试代码
  

〝 古人学问遗无力，少壮功夫老始成 〞

如果这篇文章能给你带来一点帮助，希望给飞兔小哥哥一键三连，表示支持，谢谢各位小伙伴们。

一、安装

通过composer安装

1. composer require 'elasticsearch/elasticsearch'

复制代码

二、使用

创建ES类

1. <?php
   
2. 
   
3. require 'vendor/autoload.php';
   
4. 
   
5. //如果未设置密码
   
6. $es = \Elasticsearch\ClientBuilder::create()->setHosts(['xxx.xxx.xxx.xxx'])->build();
   
7. 
   
8. //如果es设置了密码
   
9. $es = \Elasticsearch\ClientBuilder::create()->setHosts(['http://username:password@xxx.xxx.xxx.xxx:9200'])->build()

复制代码

三、新建ES数据库

index 对应关系型数据（以下简称MySQL）里面的数据库，而不是对应MySQL里面的索引

1. <?php
   
2. $params = [
   
3.     'index' => 'autofelix_db', #index的名字不能是大写和下划线开头
   
4.     'body' => [
   
5.         'settings' => [
   
6.             'number_of_shards' => 5,
   
7.             'number_of_replicas' => 0
   
8.         ]
   
9.     ]
   
10. ];
    
11. $es->indices()->create($params);

复制代码

四、创建表

   

• 在MySQL里面，光有了数据库还不行，还需要建立表，ES也是一样的   
  
• ES中的type对应MySQL里面的表   
  
• ES6以前，一个index有多个type，就像MySQL中一个数据库有多个表一样   
  
• 但是ES6以后，每个index只允许一个type   
  
• 在定义字段的时候，可以看出每个字段可以定义单独的类型   
  
• 在first_name中还自定义了 分词器 ik，这是个插件，是需要单独安装的
  

1. <?php
   
2. $params = [
   
3.     'index' => 'autofelix_db',
   
4.     'type' => 'autofelix_table',
   
5.     'body' => [
   
6.         'mytype' => [
   
7.             '_source' => [
   
8.                 'enabled' => true
   
9.             ],
   
10.             'properties' => [
    
11.                 'id' => [
    
12.                     'type' => 'integer'
    
13.                 ],
    
14.                 'first_name' => [
    
15.                     'type' => 'text',
    
16.                     'analyzer' => 'ik_max_word'
    
17.                 ],
    
18.                 'last_name' => [
    
19.                     'type' => 'text',
    
20.                     'analyzer' => 'ik_max_word'
    
21.                 ],
    
22.                 'age' => [
    
23.                     'type' => 'integer'
    
24.                 ]
    
25.             ]
    
26.         ]
    
27.     ]
    
28. ];
    
29. $es->indices()->putMapping($params);

复制代码

五、插入数据

   

• 现在数据库和表都有了，可以往里面插入数据了   
  
• 在ES里面的数据叫文档   
  
• 可以多插入一些数据，等会可以模拟搜索功能
  

1. <?php
   
2. $params = [
   
3.     'index' => 'autofelix_db',
   
4.     'type' => 'autofelix_table',
   
5.     //'id' => 1, #可以手动指定id，也可以不指定随机生成
   
6.     'body' => [
   
7.         'first_name' => '飞',
   
8.         'last_name' => '兔',
   
9.         'age' => 26
   
10.     ]
    
11. ];
    
12. $es->index($params);

复制代码

六、 查询所有数据

1. <?php
   
2. $data = $es->search();
   
3. 
   
4. var_dump($data);

复制代码

七、查询单条数据

   

• 如果你在插入数据的时候指定了id，就可以查询的时候加上id   
  
• 如果你在插入的时候未指定id，系统将会自动生成id，你可以通过查询所有数据后查看其id
  

1. <?php
   
2. $params = [
   
3.     'index' => 'autofelix_db',
   
4.     'type' => 'autofelix_table',
   
5.     'id' =>  //你插入数据时候的id
   
6. ];
   
7. $data = $es->get($params);

复制代码

八、搜索

ES精髓的地方就在于搜索

1. <?php
   
2. $params = [
   
3.     'index' => 'autofelix_db',
   
4.     'type' => 'autofelix_table',
   
5.     'body' => [
   
6.         'query' => [
   
7.             'constant_score' => [ //非评分模式执行
   
8.                 'filter' => [ //过滤器，不会计算相关度，速度快
   
9.                     'term' => [ //精确查找，不支持多个条件
   
10.                         'first_name' => '飞'
    
11.                     ]
    
12.                 ]
    
13.             ]
    
14.         ]
    
15.     ]
    
16. ];
    
17. 
    
18. $data = $es->search($params);
    
19. var_dump($data);

复制代码

九、测试代码

基于Laravel环境，包含删除数据库，删除文档等操作

1. <?php
   
2. use Elasticsearch\ClientBuilder;
   
3. use Faker\Generator as Faker;
   
4. 
   
5. /**
   
6. * ES 的 php 实测代码
   
7. */
   
8. class EsDemo
   
9. {
   
10.     private $EsClient = null;
    
11.     private $faker = null;
    
12. 
    
13.     /**
    
14.      * 为了简化测试，本测试默认只操作一个Index，一个Type
    
15.      */
    
16.     private $index = 'autofelix_db';
    
17.     private $type = 'autofelix_table';
    
18. 
    
19.     public function __construct(Faker $faker)
    
20.     {
    
21.         /**
    
22.          * 实例化 ES 客户端
    
23.          */
    
24.         $this->EsClient = ClientBuilder::create()->setHosts(['xxx.xxx.xxx.xxx'])->build();
    
25.         /**
    
26.          * 这是一个数据生成库
    
27.          */
    
28.         $this->faker = $faker;
    
29.     }
    
30. 
    
31.     /**
    
32.      * 批量生成文档
    
33.      * @param $num
    
34.      */
    
35.     public function generateDoc($num = 100) {
    
36.         foreach (range(1,$num) as $item) {
    
37.             $this->putDoc([
    
38.                 'first_name' => $this->faker->name,
    
39.                 'last_name' => $this->faker->name,
    
40.                 'age' => $this->faker->numberBetween(20,80)
    
41.             ]);
    
42.         }
    
43.     }
    
44. 
    
45.     /**
    
46.      * 删除一个文档
    
47.      * @param $id
    
48.      * @return array
    
49.      */
    
50.     public function delDoc($id) {
    
51.         $params = [
    
52.             'index' => $this->index,
    
53.             'type' => $this->type,
    
54.             'id' =>$id
    
55.         ];
    
56.         return $this->EsClient->delete($params);
    
57.     }
    
58. 
    
59.     /**
    
60.      * 搜索文档，query是查询条件
    
61.      * @param array $query
    
62.      * @param int $from
    
63.      * @param int $size
    
64.      * @return array
    
65.      */
    
66.     public function search($query = [], $from = 0, $size = 5) {
    
67. //        $query = [
    
68. //            'query' => [
    
69. //                'bool' => [
    
70. //                    'must' => [
    
71. //                        'match' => [
    
72. //                            'first_name' => 'Cronin',
    
73. //                        ]
    
74. //                    ],
    
75. //                    'filter' => [
    
76. //                        'range' => [
    
77. //                            'age' => ['gt' => 76]
    
78. //                        ]
    
79. //                    ]
    
80. //                ]
    
81. //
    
82. //            ]
    
83. //        ];
    
84.         $params = [
    
85.             'index' => $this->index,
    
86. //            'index' => 'm*', #index 和 type 是可以模糊匹配的，甚至这两个参数都是可选的
    
87.             'type' => $this->type,
    
88.             '_source' => ['first_name','age'], // 请求指定的字段
    
89.             'body' => array_merge([
    
90.                 'from' => $from,
    
91.                 'size' => $size
    
92.             ],$query)
    
93.         ];
    
94.         return $this->EsClient->search($params);
    
95.     }
    
96. 
    
97.     /**
    
98.      * 一次获取多个文档
    
99.      * @param $ids
    
100.      * @return array
     
101.      */
     
102.     public function getDocs($ids) {
     
103.         $params = [
     
104.             'index' => $this->index,
     
105.             'type' => $this->type,
     
106.             'body' => ['ids' => $ids]
     
107.         ];
     
108.         return $this->EsClient->mget($params);
     
109.     }
     
110. 
     
111.     /**
     
112.      * 获取单个文档
     
113.      * @param $id
     
114.      * @return array
     
115.      */
     
116.     public function getDoc($id) {
     
117.         $params = [
     
118.             'index' => $this->index,
     
119.             'type' => $this->type,
     
120.             'id' =>$id
     
121.         ];
     
122.         return $this->EsClient->get($params);
     
123.     }
     
124. 
     
125.     /**
     
126.      * 更新一个文档
     
127.      * @param $id
     
128.      * @return array
     
129.      */
     
130.     public function updateDoc($id) {
     
131.         $params = [
     
132.             'index' => $this->index,
     
133.             'type' => $this->type,
     
134.             'id' =>$id,
     
135.             'body' => [
     
136.                 'doc' => [
     
137.                     'first_name' => '张',
     
138.                     'last_name' => '三',
     
139.                     'age' => 99
     
140.                 ]
     
141.             ]
     
142.         ];
     
143.         return $this->EsClient->update($params);
     
144.     }
     
145. 
     
146.     /**
     
147.      * 添加一个文档到 Index 的Type中
     
148.      * @param array $body
     
149.      * @return void
     
150.      */
     
151.     public function putDoc($body = []) {
     
152.         $params = [
     
153.             'index' => $this->index,
     
154.             'type' => $this->type,
     
155.             // 'id' => 1, #可以手动指定id，也可以不指定随机生成
     
156.             'body' => $body
     
157.         ];
     
158.         $this->EsClient->index($params);
     
159.     }
     
160. 
     
161.     /**
     
162.      * 删除所有的 Index
     
163.      */
     
164.     public function delAllIndex() {
     
165.         $indexList = $this->esStatus()['indices'];
     
166.         foreach ($indexList as $item => $index) {
     
167.             $this->delIndex();
     
168.         }
     
169.     }
     
170. 
     
171.     /**
     
172.      * 获取 ES 的状态信息，包括index 列表
     
173.      * @return array
     
174.      */
     
175.     public function esStatus() {
     
176.         return $this->EsClient->indices()->stats();
     
177.     }
     
178. 
     
179.     /**
     
180.      * 创建一个索引 Index （非关系型数据库里面那个索引，而是关系型数据里面的数据库的意思）
     
181.      * @return void
     
182.      */
     
183.     public function createIndex() {
     
184.         $this->delIndex();
     
185.         $params = [
     
186.             'index' => $this->index,
     
187.             'body' => [
     
188.                 'settings' => [
     
189.                     'number_of_shards' => 2,
     
190.                     'number_of_replicas' => 0
     
191.                 ]
     
192.             ]
     
193.         ];
     
194.         $this->EsClient->indices()->create($params);
     
195.     }
     
196. 
     
197.     /**
     
198.      * 检查Index 是否存在
     
199.      * @return bool
     
200.      */
     
201.     public function checkIndexExists() {
     
202.         $params = [
     
203.             'index' => $this->index
     
204.         ];
     
205.         return $this->EsClient->indices()->exists($params);
     
206.     }
     
207. 
     
208.     /**
     
209.      * 删除一个Index
     
210.      * @return void
     
211.      */
     
212.     public function delIndex() {
     
213.         $params = [
     
214.             'index' => $this->index
     
215.         ];
     
216.         if ($this->checkIndexExists()) {
     
217.             $this->EsClient->indices()->delete($params);
     
218.         }
     
219.     }
     
220. 
     
221.     /**
     
222.      * 获取Index的文档模板信息
     
223.      * @return array
     
224.      */
     
225.     public function getMapping() {
     
226.         $params = [
     
227.             'index' => $this->index
     
228.         ];
     
229.         return $this->EsClient->indices()->getMapping($params);
     
230.     }
     
231. 
     
232.     /**
     
233.      * 创建文档模板
     
234.      * @return void
     
235.      */
     
236.     public function createMapping() {
     
237.         $this->createIndex();
     
238.         $params = [
     
239.             'index' => $this->index,
     
240.             'type' => $this->type,
     
241.             'body' => [
     
242.                 $this->type => [
     
243.                     '_source' => [
     
244.                         'enabled' => true
     
245.                     ],
     
246.                     'properties' => [
     
247.                         'id' => [
     
248.                             'type' => 'integer'
     
249.                         ],
     
250.                         'first_name' => [
     
251.                             'type' => 'text',
     
252.                             'analyzer' => 'ik_max_word'
     
253.                         ],
     
254.                         'last_name' => [
     
255.                             'type' => 'text',
     
256.                             'analyzer' => 'ik_max_word'
     
257.                         ],
     
258.                         'age' => [
     
259.                             'type' => 'integer'
     
260.                         ]
     
261.                     ]
     
262.                 ]
     
263.             ]
     
264.         ];
     
265.         $this->EsClient->indices()->putMapping($params);
     
266.         $this->generateDoc();
     
267.     }
     
268. }

复制代码

到此这篇关于php操作ElasticSearch搜索引擎流程详解的文章就介绍到这了,更多相关php ElasticSearch搜索引擎内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
                                                        
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！