PHP操作Elasticsearch

炒股全靠蒙 發表於 2020-1-11 15:02:00

<h2 class="title">一、安装</h2>
以下es基于6.4
1、在 composer.json 文件中引入 elasticsearch-php：
<div class="cnblogs_code">
<pre>{
"require":{
 "elasticsearch/elasticsearch":"~6.0",
 "monolog/monolog": "~1.0"
}
}</pre>
</div>
2、用 composer 安装客户端：
<div class="cnblogs_code">
<pre>curl -s http://getcomposer.org/installer | php
php composer.phar install --no-dev</pre>
</div>
<img src="https://img2018.cnblogs.com/i-beta/1084970/202001/1084970-20200111102819749-1861570714.png">
 <img src="https://img2018.cnblogs.com/i-beta/1084970/202001/1084970-20200111102924473-1425686068.png">
<h2 class="title">二、快速开始</h2>
1、创建一个test.php文件，内容如下
<div class="cnblogs_code">
<pre><?php
require 'vendor/autoload.php';

use Elasticsearch\ClientBuilder;

$hosts = [
'192.168.16.241:9200', // IP + Port
'192.168.16.241', // Just IP
'localhost:9200', // Domain + Port
'localhost', // Just Domain
'http://localhost', // SSL to localhost
'https://192.168.16.241:9200'// SSL to IP + Port
];
$client = ClientBuilder::create()->setHosts($hosts)->build(); // Instantiate a new ClientBuilder// Set the hosts

$params = [
'index'=> 'test_data',
'type' => 'users',
'id' => 100027,
'client' => [ 'ignore' => 404 ]
];
var_dump( $client->get($params));</pre>
</div>
2、浏览器访问test.php，结果如下（前提是你的es已经有数据）
<img src="https://img2018.cnblogs.com/i-beta/1084970/202001/1084970-20200111120030517-1390051478.png">
<h2 class="title">三、基本操作</h2>
1、创建索引
<div class="cnblogs_code">
<pre>$params = [
'index' => 'test_index'
];

// Create the index
print_r($client->indices()->create($params));</pre>
</div>
<img src="https://img2018.cnblogs.com/i-beta/1084970/202001/1084970-20200111183136117-955558624.png">
2、创建索引（指定模板）
<div class="cnblogs_code">
<pre>$params = [
'index' => 'test_index',
'body' => [
 'settings' => [
 'number_of_shards' => 5,
 'number_of_replicas' => 2
 ],
 'mappings' => [
 'test_type' => [
 '_source' => [
 'enabled' => true
 ],
 'properties' => [
 'name' => [
 'type' => 'text',
 'analyzer' => 'ik_max_word'
 ],
 'age' => [
 'type' => 'integer'
 ]
 ]
 ]
 ]
]
];
// Create the index with mappings and settings now
print_r($client->indices()->create($params));</pre>
</div>
<img src="https://img2018.cnblogs.com/i-beta/1084970/202001/1084970-20200113165519906-1166712781.png">
 
 3、删除索引
<div class="cnblogs_code">
<pre>$params = ['index' => 'test_index'];
print_r($client->indices()->delete($params));</pre>
</div>
<img src="https://img2018.cnblogs.com/i-beta/1084970/202001/1084970-20200113170004709-451735489.png">
 
4、更改索引的配置参数:
<div class="cnblogs_code">
<pre>$params = [
'index' => 'test_index',
'body' => [
 'settings' => [
 'number_of_replicas' => 0,
 'refresh_interval' => -1
 ]
]
];

print_r($client->indices()->putSettings($params));</pre>
</div>
<img src="https://img2018.cnblogs.com/i-beta/1084970/202001/1084970-20200113170339383-1290254452.png">
 
5、获取一个或多个索引的当前配置参数
<div class="cnblogs_code">
<pre>$params = [
'index' => [ 'test_index', 'test_data' ]
];
print_r($client->indices()->getSettings($params));</pre>
</div>
<img src="https://img2018.cnblogs.com/i-beta/1084970/202001/1084970-20200113171513270-1823321141.png">
 
 6、更改或增加一个索引的映射
<div class="cnblogs_code">
<pre>$params = [
'index' => 'test_index',
'type' => 'test_type',
'body' => [
 'test_type' => [
 '_source' => [
 'enabled' => true
 ],
 'properties' => [
 'name' => [
 'type' => 'text',
 'analyzer' => 'ik_max_word'
 ],
 'age' => [
 'type' => 'integer'
 ],
 'createtime' => [
 'type' => 'date'//加了一个时间
 ]

 ]
 ]
]
];

// Update the index mapping
print_r($client->indices()->putMapping($params));</pre>
</div>
<img src="https://img2018.cnblogs.com/i-beta/1084970/202001/1084970-20200113181341153-125884057.png">
 
 7、返回索引和类型的映射细节
<div class="cnblogs_code">
<pre>$response = $client->indices()->getMapping();

// Get mappings for all types in 'my_index'
$params = ['index' => 'my_index'];
$response = $client->indices()->getMapping($params);

// Get mappings for all types of 'my_type', regardless of index
$params = ['type' => 'my_type' ];
$response = $client->indices()->getMapping($params);

// Get mapping 'my_type' in 'my_index'
$params = [
'index' => 'my_index'
'type' => 'my_type'
];
$response = $client->indices()->getMapping($params);

// Get mappings for two indexes
$params = [
'index' => [ 'my_index', 'my_index2' ]
];
$response = $client->indices()->getMapping($params);</pre>
</div>
 
8、索引一个文档（提供id，则会更新对应id的记录。若没有提供，则会生成一条文档）
<div class="cnblogs_code">
<pre>$params = [
'index' => 'test_data',
'type' => 'users',
'id' => '100027',
'body' => [ 'nickname' => 'update222']
];

// Document will be indexed to my_index/my_type/my_id
print_r($client->index($params));</pre>
</div>
 
9、获取文档
<div class="cnblogs_code">
<pre>$params = [
'index' => 'test_data',
'type' => 'users',
'id' => '100027'
];

// Get doc at /my_index/my_type/my_id
print_r($client->get($params));</pre>
</div>
<img src="https://img2018.cnblogs.com/i-beta/1084970/202001/1084970-20200114111128994-1212052085.png">
 
10、更新文档（doc指定要更新的字段内容）
<div class="cnblogs_code">
<pre>$params = [
'index' => 'test_data',
'type' => 'users',
'id' => '100027',
'body' => [
 'doc' => [
 'nickname' => 'abc',
 'mobile' => '13800138000'
 ]
]
];
// Update doc at /my_index/my_type/my_id
print_r($client->update($params));</pre>
</div>
<img src="https://img2018.cnblogs.com/i-beta/1084970/202001/1084970-20200114112854115-105614548.png">
 
11、执行一个脚本进行更新，对某个字段的数据进行拼接或自增
<div class="cnblogs_code">
<pre>$params = [
"index" => "test_data",
"type" => "users",
"id" => "100027",
"body" => [
 "script" => "ctx._source.nickname += 'hahh'"
]
];

print_r($client->update($params));</pre>
</div>
 
 
12、删除文档
<div class="cnblogs_code">
<pre>$params = [
'index' => 'test_data',
'type' => 'users',
'id' => '100027'
];

// Delete doc at /my_index/my_type/my_id
print_r($client->delete($params));</pre>
</div>
 
 
13、搜索内容
<div class="cnblogs_code">
<pre>$json = '{
"query" : {
 "match" : {
 "id" : "100073"
 }
}
}';

$params = [
'index' => 'test_data',
'type' => 'users',
'body' => $json
];
print_r($client->search($params));
 
$params = [
'index' => 'test_data',
'type' => 'users',
'body' => [
 'query' => [
 'bool' => [
 'should' => [
 [ 'match' => [ 'nickname' => [
 'query' => 'user440032',
 'boost' => 3, // 权重大
 ]]]
 ],
 ],
 ],
 'sort' => ['id'=>['order'=>'desc']] //排序分页
 , 'from' => 0, 'size' => 10
]
];

print_r($client->search($params));</pre>
</div> 
来源：https://www.cnblogs.com/killer21/p/12179936.html

頁: [1]

琼殿技术论坛's Archiver

PHP操作Elasticsearch