Heim >PHP-Framework >Laravel >Detaillierte Erklärung der Laravel8 ES-Verpackung und ihrer Verwendung
Detaillierte Erklärung der Laravel8 ES-Verpackung und ihrer Verwendung
- 藏色散人nach vorne
- 2022-11-23 17:03:552111Durchsuche
Dieser Artikel führt Sie in das relevante Wissen über Laravel8 ein, einschließlich der Erläuterung der Laravel8 ES-Verpackung und ihrer Verwendung. Ich hoffe, dass er für alle hilfreich ist!
【Verwandte Empfehlung: Laravel-Video-Tutorial】
Composer-Installation
composer require elasticsearch/elasticsearch
ES-Paket
<?php
namespace App\Es;
use Elasticsearch\ClientBuilder;
class MyEs
{
//ES客户端链接
private $client;
/**
* 构造函数
* MyElasticsearch constructor.
*/
public function __construct()
{
$this->client = ClientBuilder::create()->setHosts(['127.0.0.1:9200'])->build();
}
/**
* 判断索引是否存在
* @param string $index_name
* @return bool|mixed|string
*/
public function exists_index($index_name = 'test_ik')
{
$params = [
'index' => $index_name
];
try {
return $this->client->indices()->exists($params);
} catch (\Elasticsearch\Common\Exceptions\BadRequest400Exception $e) {
$msg = $e->getMessage();
$msg = json_decode($msg,true);
return $msg;
}
}
/**
* 创建索引
* @param string $index_name
* @return array|mixed|string
*/
public function create_index($index_name = 'test_ik') { // 只能创建一次
$params = [
'index' => $index_name,
'body' => [
'settings' => [
'number_of_shards' => 5,
'number_of_replicas' => 1
]
]
];
try {
return $this->client->indices()->create($params);
} catch (\Elasticsearch\Common\Exceptions\BadRequest400Exception $e) {
$msg = $e->getMessage();
$msg = json_decode($msg,true);
return $msg;
}
}
/**
* 删除索引
* @param string $index_name
* @return array
*/
public function delete_index($index_name = 'test_ik') {
$params = ['index' => $index_name];
$response = $this->client->indices()->delete($params);
return $response;
}
/**
* 添加文档
* @param $id
* @param $doc ['id'=>100, 'title'=>'phone']
* @param string $index_name
* @param string $type_name
* @return array
*/
public function add_doc($id,$doc,$index_name = 'test_ik',$type_name = 'goods') {
$params = [
'index' => $index_name,
'type' => $type_name,
'id' => $id,
'body' => $doc
];
$response = $this->client->index($params);
return $response;
}
/**
* 判断文档存在
* @param int $id
* @param string $index_name
* @param string $type_name
* @return array|bool
*/
public function exists_doc($id = 1,$index_name = 'test_ik',$type_name = 'goods') {
$params = [
'index' => $index_name,
'type' => $type_name,
'id' => $id
];
$response = $this->client->exists($params);
return $response;
}
/**
* 获取文档
* @param int $id
* @param string $index_name
* @param string $type_name
* @return array
*/
public function get_doc($id = 1,$index_name = 'test_ik',$type_name = 'goods') {
$params = [
'index' => $index_name,
'type' => $type_name,
'id' => $id
];
$response = $this->client->get($params);
return $response;
}
/**
* 更新文档
* @param int $id
* @param string $index_name
* @param string $type_name
* @param array $body ['doc' => ['title' => '苹果手机iPhoneX']]
* @return array
*/
public function update_doc($id = 1,$index_name = 'test_ik',$type_name = 'goods', $body=[]) {
// 可以灵活添加新字段,最好不要乱添加
$params = [
'index' => $index_name,
'type' => $type_name,
'id' => $id,
'body' => $body
];
$response = $this->client->update($params);
return $response;
}
/**
* 删除文档
* @param int $id
* @param string $index_name
* @param string $type_name
* @return array
*/
public function delete_doc($id = 1,$index_name = 'test_ik',$type_name = 'goods') {
$params = [
'index' => $index_name,
'type' => $type_name,
'id' => $id
];
$response = $this->client->delete($params);
return $response;
}
/**
* 搜索文档 (分页，排序，权重，过滤)
* @param string $index_name
* @param string $type_name
* @param array $body
* $body = [
'query' => [
'match' => [
'fang_name' => [
'query' => $fangName
]
]
],
'highlight'=>[
'fields'=>[
'fang_name'=>[
'pre_tags'=>[
'<span style="color: red">'
],
'post_tags'=>[
'</span>'
]
]
]
]
];
* @return array
*/
public function search_doc($index_name = "test_ik",$type_name = "goods",$body=[]) {
$params = [
'index' => $index_name,
'type' => $type_name,
'body' => $body
];
$results = $this->client->search($params);
return $results;
}
}Fügen Sie alle Daten in der Datentabelle zu ES hinzu
public function esAdd()
{
$data = Good::get()->toArray();
$es = new MyEs();
if (!$es->exists_index('goods')) {
//创建es索引，es的索引相当于MySQL的数据库
$es->create_index('goods');
}
foreach ($data as $model) {
$es->add_doc($model['id'], $model, 'goods', '_doc');
}
}Jedes Mal ein Stück Daten wird in MySQL hinzugefügt, fügen Sie auch eine Zeile in es hinzu
Fügen Sie den Code direkt zur Logikmethode zum Hinzufügen von MySQL zur Datenbank hinzu
//添加至MySQL
$res=Good::insertGetId($arr);
$es = new MyEs();
if (!$es->exists_index('goods')) {
$es->create_index('goods');
}
//添加至es
$es->add_doc($res, $arr, 'goods', '_doc');
return $res;Beim Ändern von MySQL-Daten werden auch die Daten von es aktualisiert
Fügen Sie den Code direkt hinzu MySQL-Logik zum Ändern der Daten In der Methode können Sie die Suchfunktion über ES implementieren.
//修改MySQL的数据
$res=Good::where('id',$id)->update($arr);
$es = new MyEs();
if (!$es->exists_index('goods')) {
$es->create_index('goods');
}
//修改es的数据
$es->update_doc($id, 'goods', '_doc',['doc'=>$arr]);
return $res; Funktion ist die obige Suchfunktion. Wird durch Hinzufügen des obigen Codes implementiert 1. Übergeben Sie beim Aufrufen der Suchmethode der es-Paketklasse zwei weitere Parameter 3 die Suchmethode der es-Paketklasse Zwei formale Parameter Nach der Suche wird der Suchwert hervorgehoben Bei Verwendung in einem WeChat-Applet werden die Beschriftung und der Wert direkt zusammen auf der Seite ausgegeben. Fügen Sie eine Beschriftung hinzu, die Rich-Text analysieren kann Wandeln Sie das Etikett in ein Format um, um einen Hervorhebungseffekt zu erzielenDas obige ist der detaillierte Inhalt vonDetaillierte Erklärung der Laravel8 ES-Verpackung und ihrer Verwendung. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!
Stellungnahme：
Dieser Artikel ist reproduziert unter:learnku.com. Bei Verstößen wenden Sie sich bitte an admin@php.cn löschen
Vorheriger Artikel：Analysieren Sie das Schnittstellenkommunikationsproblem zwischen internen Servern unter zwei GesichtspunktenNächster Artikel：Analysieren Sie das Schnittstellenkommunikationsproblem zwischen internen Servern unter zwei Gesichtspunkten
In Verbindung stehende Artikel
Mehr sehen- Empfehlung zur Laravel-Erweiterung: Das Vite-Plugin-Paket verwendet Vite, um das Hot-Reloading zu implementieren
- 6 Laravel Eloquent-Tipps, die Ihnen helfen, die Lesbarkeit des Codes zu verbessern!
- Erfahren Sie in einem Artikel mehr über Pipeline in Laravel
- So erhöhen Sie die Geschwindigkeit Ihrer Laravel-Anwendung
- Ausführliche Erklärung zur schnellen Installation von Bootstrap in Laravel9.x