Laravel Elasticsearch

启动Elasticsearch ：进入Elasticsearch文件bin目录命令行运行elasticsearch.bat

设置Elasticsearch端口号进入Elasticsearch文件内进入config 打开图内文件进行修改

框架安装 Elasticsearch

进入项目根目录 执行composer安装 composer require 'elasticsearch/elasticsearch'

控制器引用相关类 use Elasticsearch\ClientBuilder;

创建index

$params = [

'index' => 'myindex', #index的名字不能是大写和下划线开头

'body' => [

'settings' => [

'number_of_shards' => 2,

'number_of_replicas' => 0

]

];

$client->indices()->create($params);

创建index下的表：

$params = [

'index' => 'myindex',//index索引（相当于数据库名）

'type' => 'mytype',//type值(相当于表名，一个库对应一个表)

'body' => [

'mytype' => [

'_source' => [

'enabled' => true //字段规则

],

'properties' => [

'id' => [

'type' => 'integer' //字段规则

],

'first_name' => [

'type' => 'text', //字段规则

'analyzer' => 'ik_max_word' //字段规则

],

'last_name' => [

'type' => 'text', //字段规则

'analyzer' => 'ik_max_word'

],

'age' => [

'type' => 'integer'

]

];

$client->indices()->putMapping($params);

添加数据：

$params = [

'index' => 'myindex',

'type' => 'mytype',

//'id' => 1, #可以手动指定id，也可以不指定随机生成

'body' => [

'first_name' => '张',

'last_name' => '三',

'age' => 35

]

];

$client->index($params);

然后编写方法，例：

创建索引并添加：

public function esInput($data,$id){
$client = ClientBuilder::create()->setHosts(['127.0.0.1:9301'])->build();

$params = [
       'index' => 'test',
       'type' => 'teachers',
       'id' => $id, #可以手动指定id，也可以不指定随机生成
       'body' => [
       'name' => $data['name'],
       'desc'=>$data['desc']
       ]
       ];
       $res=$client->index($params);
return $res;
}

获取数据库所有数据：

public function es(){
   $client = ClientBuilder::create()->setHosts(['127.0.0.1:9301'])->build();
       $params = [
       'index' => 'test',
       // 'index' => 'm*', #index 和 type 是可以模糊匹配的，甚至这两个参数都是可选的
       'type' => 'teachers',
       '_source' => ['name','desc'], // 请求指定的字段
       'body' => array_merge([
       'from' => 0,
       'size' => 5
       ])
       ];
       $data = $client->search($params);
       return $data['hits']['hits'];
}

//检索（$query内为检索规则，match匹配，字段名对应搜索内容）

$query = [
       'query' => [
           'match'=>[
               'name'=>'ken'
           ],
       ],
       ];

       $params = [
       'index' => 'test',
       // 'index' => 'm*', #index 和 type 是可以模糊匹配的，甚至这两个参数都是可选的
           // '_id' =>'teachers10',
       'type' => 'teachers',
       '_source' => ['name','desc'], // 请求指定的字段
       'body' => array_merge([
       'from' => 0,
       'size' => 5
       ],$query)
       ];

//高亮显示方法

public function esInput(Request $request){
//连接es
$client = ClientBuilder::create()->setHosts([config('setting.es.sethost')])->build();
//接收参数
$param=$request->input('fang_name')?:"";

if(!empty($param)){
//传入数据进行关键词搜索
$params = [
'index' => 'fang',
// 'index' => 'm*', #index 和 type 是可以模糊匹配的，甚至这两个参数都是可选的
'type' => 'fangs',
'_source' => ['fang_name','fang_addr','created_at','updated_at'], // 请求指定的字段
'body' => [
'query' => [
'match' => [
'fang_name' =>$param,
]
],
'highlight' => [
'pre_tags' => ["<span style='color: red'>"],
'post_tags' => ["</span style='color: red'>"],
'fields' => [
"fang_name" => new \stdClass()
]
]
]
];

}else{
//如果为传入数据进行查询所有
$params = [
'index' => 'fang',
// 'index' => 'm*', #index 和 type 是可以模糊匹配的，甚至这两个参数都是可选的
'type' => 'fangs',
'_source' => ['fang_name','fang_addr','created_at','updated_at'], // 请求指定的字段
'body' => array_merge([
'from' => 0,
'size' => 5
])
];
}

$arr=[];
$data = $client->search($params);

//取出搜索获得的数据进行循环处理
foreach ($data['hits']['hits'] as $value) {
//高亮显示的数据和原数据替换
$value['_source']['fang_name']=$value['highlight']['fang_name'][0];
//加入新的数组
$arr[]=$value['_source'];
}

dd($arr);
}

指定id单条查询

$params = [

'index' => 'myindex',

'type' => 'mytype',

'id' =>'zU65WWgBVD80YaV8iVMk'//此处为存储的id值

];

$data = $client->get($params);