PHP 中运用 elasticsearch

• 2024-03-15
• 443 View

PHP扩展安装

 

1. 环境要求：PHP_VERSION >= 5.3.9，composer工具

 

 

2. 在E盘新建文件夹命名为elastic,，拷贝composer.phar到

     E:/elastic目录下面

 

 

3. 打开命令行窗口，进入E:/elastic

 

 

4. 在命令行运行：

      php composer.phar require elasticsearch/elasticsearch

 

 

5. 此时E:/elastic目录下会出现一个vendor目录，安装成功

 

 

6. 使用方法：

       require 'vendor/autoload.php'; 

      $client = new Elasticsearch\Client();

 

 

 

 

 

创建索引

 

 

 

 

 

include('./vendor/autoload.php');  

$elastic = new Elasticsearch\Client();  

$index[‘index’] = ‘log’;  //索引名称  

$index[‘type’] = ‘ems_run_log’; //类型名称  

$data[‘body’][‘settings’][‘number_of_shards’] = 5;  //主分片数量  

$data[‘body’][‘settings’][‘number_of_replicas’] = 0; //从分片数量  

$elastic->indices()->create($index);  

 

 

 

 

插入索引数据

 

 

 

include('./vendor/autoload.php');  

  $elastic = new Elasticsearch\Client();  

  $index[‘index’] = ‘log’; //索引名称  

  $index[‘type’] = ‘ems_run_log’; //类型名称  

  $index[‘id’] = 1   //不指定id，系统会自动生成唯一id  

  $index[‘body’] = array(  

      ‘mac’ => 'fcd5d900beca',  

      ‘customer_id’ => 3,  

      ‘product_id’ => 5,  

      ‘version’ => 2  

  );  

  $elastic->index($index);  

 

 

 

 

查询

 

 

 

include('./vendor/autoload.php');  

   $elastic = new Elasticsearch\Client();  

   $index[‘index’] = ‘log’; //索引名称  

   $index[‘type’] = ‘ems_run_log’; //类型名称  

   $index[‘body’][‘query’][‘match’][‘mac’] = ‘fcd5d900beca’;  

   $index[‘size’] = 10;  

   $index[‘from’] = 200;  

   $elastic->search($index);  

  

  

  相当于sql语句：  

   select*from ems_run_log where mac=‘fcd5d900beca’  

   limit 200,10;<strong>  

</strong>  

 

 

 

 

 

 

include('./vendor/autoload.php');  

  $elastic = new Elasticsearch\Client();  

  $index[‘index’] = ‘log’; //索引名称  

  $index[‘type’] = ‘ems_run_log’; //类型名称  

  $index[‘body’][‘query’][‘bool’][‘must’] = array(  

        array(‘match’ => array(‘mac’ => ‘fcd5d900beca’)),  

        array(‘match’ => array(‘product_id’ => 20))  

       );  

  $index[‘size’] = 10;  

  $index[‘from’] = 200;  

  $elastic->search($index);  

  

  

 相当于sql语句：  

  select*from ems_run_log where mac=‘fcd5d900beca’  

  and product_id = 20 limit 200,10;  

 

 

 

 

 

 

include('./vendor/autoload.php');  

$elastic = new Elasticsearch\Client();  

$index[‘index’] = ‘log’; //索引名称  

$index[‘type’] = ‘ems_run_log’; //类型名称  

$index[‘body’][‘query’][‘bool’][‘should’] = array(  

      array(‘match’ => array(‘mac’ => ‘fcd5d900beca’)),  

      array(‘match’ => array(‘product_id’ => 20))  

     );  

$index[‘size’] = 10;  

$index[‘from’] = 200;  

$elastic->search($index);  

  

  

当于sql语句：  

select*from ems_run_log where mac=‘fcd5d900beca’  

or product_id = 20 limit 200,10;  

 

 

include('./vendor/autoload.php');  

 $elastic = new Elasticsearch\Client();  

 $index[‘index’] = ‘log’; //索引名称  

 $index[‘type’] = ‘ems_run_log’; //类型名称  

 $index[‘body’][‘query’][‘bool’][‘must_not’] = array(  

       array(‘match’ => array(‘mac’ => ‘fcd5d900beca’)),  

       array(‘match’ => array(‘product_id’ => 20))  

      );  

 $index[‘size’] = 10;  

 $index[‘from’] = 200;  

 $elastic->search($index);  

  

  

相当于sql语句：  

 select*from ems_run_log where mac!=‘fcd5d900beca’  

 and product_id != 20 limit 200,10;  

 

 

 

 

include('./vendor/autoload.php');  

   $elastic = new Elasticsearch\Client();  

   $index[‘index’] = ‘log’; //索引名称  

   $index[‘type’] = ‘ems_run_log’; //类型名称  

   $index[‘body’][‘query’][‘range’] = array(  

       ‘id’ => array(‘gte’ => 20,’lt’ => 30);  

     );  

   $index[‘size’] = 10;  

   $index[‘from’] = 200;  

   $elastic->search($index);  

  

  

  相当于sql语句：  

   select*from ems_run_log where id>=20  

   and id<30  limit 200,10;  

 

 

 

 

 

 

删除文档

 

 

 

<pre name="code" class="php">include('./vendor/autoload.php');  

$elastic = new Elasticsearch\Client();  

$index['index'] = 'test';  //索引名称  

$index['type'] = 'ems_test'; //类型名称  

$index['id'] = 2;   

$elastic->delete($index);