使用

定义模块

创建文件XXXElasticsearch 继承 app\elasticsearch\model\elasticsearch\index\ElasticsearchBase 即可

table 为需要对应的表名称
pk 为表主键
key 为该表中的字段 type中的具体内容需要对应定义中的映射

analyzer 可以定义使用的分词器

namespace app\elasticsearch\model\elasticsearch\index;
class DemoElasticsearch extends \app\elasticsearch\model\elasticsearch\index\ElasticsearchBase
{
    protected $table = 'elasticsearch_demo';
    protected $pk = 'elasticsearch_demo_id';
    protected $key = [
        'elasticsearch_demo_id' =>[
            'type' => 'keyword'
        ],
        'elasticsearch_demo_content' => [
            'type' => 'text',
            'analyzer' => 'ik_max_word'
        ],
        'create_time' => [
            'type' => 'long',
        ],
        'update_time' => [
            'type' => 'long',
        ]
    ];
    public function __construct($table = '',$pk = '',$key = [])
    {
        if($table) $this->table = $table;
        if($pk) $this->pk = $pk;
        if($key) $this->key = $key;
    }
}

同步单条记录（syncTableId）

只需要传一个ID即可自动同步单条记录 （建议做好事务操作，避免数据不统一）

基础使用

 try {
   (new DemoElasticsearch())->syncTableId($details->elasticsearch_demo_id);
 } catch (\Exception $e) {
   throw new Exception($e->getMessage());
 }

案例

 public function submit($post = [])
 {
     $elasticsearch_demo_id = $post['elasticsearch_demo_id'] ?? 0;
     $elasticsearch_demo_content = $post['elasticsearch_demo_content'] ?? '';
     $details = self::where('elasticsearch_demo_id', '=', $elasticsearch_demo_id)
       ->findOrEmpty();
     if ($details->isEmpty()) {
       $details->create_time = time();
     }
     $details->elasticsearch_demo_content = $elasticsearch_demo_content;
     $details->update_time = time();
     $details->save();
     try {
       (new DemoElasticsearch())->syncTableId($details->elasticsearch_demo_id);
     } catch (\Exception $e) {
       throw new Exception($e->getMessage());
     }
     return true;
 }

删除单条记录（delTableId）

基础使用

try {
    (new DemoElasticsearch())->delTableId($elasticsearch_demo_id);
} catch (Exception $e) {
  throw new Exception($e->getMessage());
}

案例

public function remove($elasticsearch_demo_id){
  self::where('elasticsearch_demo_id','=',$elasticsearch_demo_id)
    ->findOrEmpty()
    ->delete();
  try {
    (new DemoElasticsearch())->delTableId($elasticsearch_demo_id);
  } catch (Exception $e) {
    throw new Exception($e->getMessage());
  }
  return json(createReturn(true, '', '操作成功'));
}

批量同步数据（syncTable）

基础使用

$where[] = ['is_elasticsearch_syn','=',0];
$sync_data = (new DemoElasticsearch())->syncTable($where,'create_time desc');

案例

set_time_limit(0);
try {
  $DemoModel = new DemoModel();
  $sync_res['pk_count'] = 1;
  while($sync_res['pk_count']){
    //批量同步数据
    $where[] = ['delete_time','=',0];
    $where[] = ['is_elasticsearch_syn','=',0];
    $sync_data = (new DemoElasticsearch())->syncTable($where,'create_time desc');
    if($sync_data['status']) {
      $sync_res = $sync_data['data'];
      //将已同步内容变为已同步
      $DemoModel
        ->where('elasticsearch_demo_id','in',$sync_res['pk_ids'])
        ->update(['is_elasticsearch_syn' => 1]);
    } else {
      $sync_res['pk_count'] = 0;
    }
  }
  return json(createReturn(true, '', '同步成功'));
} catch (ValidateException $e) {
  return json(createReturn(false, '', $e->getError()));
} catch (\Exception $e) {
  return createReturn(false,'',$e->getMessage());
}

进行分词查询

语法具体可查看查询语句篇

setMustCondition

返回的文档必须满足must子句的条件,并且参与计算分值

$group_content = [];
if($elasticsearch_demo_group_id) {
  $group_content['term'] = [
    'elasticsearch_demo_group_id' => $elasticsearch_demo_group_id
  ];
}
$DemoElasticsearch->setMustCondition($group_content);

setShouldCondition

should 返回的文档可能满足should子句的条件.在一个bool查询中,如果没有must或者filter,有一个或者多个should子句,那么只要满足一个就可以返回

$keywords_content = [];
if($keywords) {
  $keywords_content['multi_match'] = [
    'query' => $keywords,
    'fields' => ['elasticsearch_demo_content','elasticsearch_demo_about']
  ];
}
$DemoElasticsearch->setShouldCondition($keywords_content);

setMustNotCondition

返回的文档必须不满足定义的条件

  $DemoElasticsearch->setMustNotCondition([
    'multi_match' => [
      'query' => $not_keywords,
      'fields' => ['elasticsearch_demo_content','elasticsearch_demo_about']
    ]
  ]);

setSortCondition

进行排序控制

 $DemoElasticsearch->setSortCondition([
   'update_time' => [
     'order' => 'desc',
   ],
   '_score' => [
     "order" => "desc"
   ]
 ]);

setSourceCondition

对返回的字段进行筛选

$DemoElasticsearch->setSourceCondition([
  'excludes' => ['create_time']
]);

searchTable

执行筛选

$DemoElasticsearch->searchTable(input('page'),input('limit'));

案例

$keywords = input('keywords','','trim');
$not_keywords = input('not_keywords','','trim');
$elasticsearch_demo_group_id = input('elasticsearch_demo_group_id','','trim');
//筛选的内容
$DemoElasticsearch = (new DemoElasticsearch());
if($elasticsearch_demo_group_id) {
  $group_content = [];
  if($elasticsearch_demo_group_id) {
    $group_content['term'] = [
      'elasticsearch_demo_group_id' => $elasticsearch_demo_group_id
    ];
  }
  $DemoElasticsearch->setMustCondition($group_content);
}

if($keywords) {
  $keywords_content = [];
  if($keywords) {
    $keywords_content['multi_match'] = [
      'query' => $keywords,
      'fields' => ['elasticsearch_demo_content','elasticsearch_demo_about']
    ];
  }
  $DemoElasticsearch->setShouldCondition($keywords_content);
}

if($not_keywords) {
  $DemoElasticsearch->setMustNotCondition([
    'multi_match' => [
      'query' => $not_keywords,
      'fields' => ['elasticsearch_demo_content','elasticsearch_demo_about']
    ]
  ]);
}

//根据排序进行评分
$DemoElasticsearch->setSortCondition([
  'update_time' => [
    'order' => 'desc',
  ],
  '_score' => [
    "order" => "desc"
  ]
]);

$DemoElasticsearch->setSourceCondition([
  'excludes' => ['create_time']
]);

$list =  $DemoElasticsearch->searchTable(input('page'),input('limit'));
return  json(self::createReturn(true,[
  'list' => $list
]));