Explication détaillée de l'emballage de Laravel8 ES et comment l'utiliser
- 藏色散人avant
- 2022-11-23 17:03:552108parcourir
Cet article vous présente les connaissances pertinentes sur Laravel8, notamment en expliquant L'emballage de Laravel8 ES et comment l'utiliser J'espère qu'il sera utile à tout le monde !
【Recommandation connexe: Laravel Video Tutorial】
🎜🎜 🎜🎜🎜Red Installation Package 🎜🎜
composer require elasticsearch/elasticsearch🎜add Toutes les données de la table de données à Es🎜
<?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;
}
}🎜 Time Time Un élément de données est ajouté dans MySQL, ajoutez également une ligne dans es 🎜🎜 Ajoutez directement le code à la méthode logique d'ajout de MySQL à la base de données 🎜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');
}
}🎜 Lors de la modification des données MySQL, les données de es sont également mises à jour 🎜🎜 Ajoutez directement le code au logique de MySQL modifiant les données Dans la méthode, vous pouvez implémenter la fonction de recherche via ES🎜 //添加至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;🎜De plus, ajoutez la recherche de pagination🎜🎜S'il est utilisé dans l'applet WeChat, utilisez simplement l'événement pull-up bottom🎜🎜Ceci La fonction est la fonction de recherche ci-dessus Implémentée en ajoutant du code ci-dessus 🎜🎜1 Recevez la page actuelle transmise par l'applet front-end 🎜🎜2 Lors de l'appel de la méthode de recherche de la classe du package es, transmettez deux paramètres supplémentaires 🎜🎜3. la méthode de recherche de la classe de package es Deux paramètres formels 🎜🎜Après la recherche, la valeur de recherche est mise en surbrillance 🎜🎜Si elle est utilisée dans une applet WeChat, l'étiquette et la valeur sont directement affichées ensemble sur la page. L'ajout d'une étiquette qui analyse le texte riche peut être ajouté. convertir l'étiquette en format, obtenant un effet de surbrillance🎜 //修改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;🎜🎜Auteur original : amateur🎜🎜Reposté à partir du lien : https://learnku.com/articles/66177🎜🎜Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!
Déclaration：
Cet article est reproduit dans:. en cas de violation, veuillez contacter admin@php.cn Supprimer
Article précédent：Analyser le problème de communication d'interface entre les serveurs internes sous deux aspectsArticle suivant：Analyser le problème de communication d'interface entre les serveurs internes sous deux aspects
Articles Liés
Voir plus- Recommandation d'extension Laravel : le package vite-plugin utilise Vite pour implémenter le rechargement à chaud
- 6 astuces Laravel Eloquent pour vous aider à améliorer la lisibilité du code !
- Découvrez Pipeline dans Laravel dans un article
- Comment augmenter la vitesse de votre application Laravel
- Explication détaillée de la façon d'installer rapidement Bootstrap dans Laravel9.x