詳解Laravel8 ES封裝及其使用方法

第詳解Laravel8ES封裝及其使用方法return$this-client-indices()-exists($params);

}catch(\Elasticsearch\Common\Exceptions\BadRequest400Exception$e){

$msg=$e-getMessage();

$msg=json_decode($msg,true);

return$msg;

*創(chuàng)建索引

*@paramstring$index_name

*@returnarray|mixed|string

publicfunctioncreate_index($index_name=test_ik){//只能創(chuàng)建一次

$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;

*刪除索引

*@paramstring$index_name

*@returnarray

publicfunctiondelete_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]

*@paramstring$index_name

*@paramstring$type_name

*@returnarray

publicfunctionadd_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;

*判斷文檔存在

*@paramint$id

*@paramstring$index_name

*@paramstring$type_name

*@returnarray|bool

publicfunctionexists_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;

*獲取文檔

*@paramint$id

*@paramstring$index_name

*@paramstring$type_name

*@returnarray

publicfunctionget_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;

*更新文檔

*@paramint$id

*@paramstring$index_name

*@paramstring$type_name

*@paramarray$body[doc=[title=蘋果手機iPhoneX]]

*@returnarray

publicfunctionupdate_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;

*刪除文檔

*@paramint$id

*@paramstring$index_name

*@paramstring$type_name

*@returnarray

publicfunctiondelete_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;

*搜索文檔(分頁，排序，權重，過濾)

*@paramstring$index_name

*@paramstring$type_name

*@paramarray$body

*$body=[

query=[

match=[

fang_name=[

query=$fangName

highlight=[

fields=[

fang_name=[

pre_tags=[

span>

將數據表中所有數據添加至ES

publicfunctionesAdd()

$data=Good::get()-toArray();

$es=newMyEs();

if(!$es-exists_index(goods)){

//創(chuàng)建es索引，es的索引相當于MySQL的數據庫

$es-create_index(goods

foreach($dataas$model){

$es-add_doc($model[id],$model,goods,_doc

}

每在MySQL里添加一條數據，在es里也添加一條

直接將代碼補在MySQL添加入庫的邏輯方法里即可

//添加至MySQL

$res=Good::insertGetId($arr);

$es=newMyEs();

if(!$es-exists_index(goods)){

$es-create_index(goods

//添加至es

$es-add_doc($res,$arr,goods,_doc

return$res;

進行MySQL數據修改時，也更新es的數據

直接將代碼補在MySQL修改數據的邏輯方法里即可

//修改MySQL的數據

$res=Good::where(id,$id)-update($arr);

$es=newMyEs();

if(!$es-exists_index(goods)){

$es-create_index(goods

//修改es的數據

$es-update_doc($id,goods,_doc,[doc=$arr]);

return$res;

通過ES實現(xiàn)搜索功能

publicfunctionsearch()

//獲取搜索值

$search=\request()-get(search

if(!empty($search)){

$es=newMyEs();

$body=[

query=[

match=[

title=[

query=$search

highlight=[

fields=[

title=[

pre_tags=[

span>

另，補充es分頁搜索

如果是在微信小程序中使用的話，運用上拉觸底事件即可

此功能是在上面搜索功能之上添加代碼實現(xiàn)的

1.接收前臺小程序傳遞來的當前頁