如何在CakePHP中使用Elasticsearch？- 技术经验 -卓越飞翔博客

CakePHP是一款流行的PHP框架，为开发Web应用程序提供了丰富的功能和工具。Elasticsearch是另一个流行的工具，用于全文搜索和分析。在本文中，我们将介绍如何在CakePHP中使用Elasticsearch。

安装Elasticsearch组件

首先，我们需要安装一个Elasticsearch组件来与CakePHP集成。有许多组件可用，但我们将使用elasticsearch-php组件，它是由Elasticsearch官方提供的PHP客户端。

使用Composer安装组件：

composer require elasticsearch/elasticsearch

配置连接

接下来，我们需要为Elasticsearch配置连接。在config/app.php文件中，添加以下配置：

'elastic' => [
    'host' => 'localhost',// Elasticsearch主机
    'port' => '9200',// Elasticsearch端口
],

创建模型

现在，我们需要创建模型来与Elasticsearch进行交互。在src/Model中创建一个名为ElasticsearchModel.php的文件，并编写以下代码：

<?php
namespace AppModel;

use CakeElasticSearchIndex;

class ElasticsearchModel extends Index
{
    public function initialize(array $config)
    {
        parent::initialize($config);

        $this->setIndex('my_index');// Elasticsearch索引名称
        $this->setType('my_type');// Elasticsearch类型名称
        
        $this->primaryKey('id');// 主键
        $$this->belongsTo('Parent', [
            'className' => 'Parent',
            'foreignKey' => 'parent_id',
        ]);// 关联关系
    }
}

创建索引

现在我们可以创建Elasticsearch索引。在4.x版本之前，使用以下命令：

bin/cake elasticsearch create_index ElasticsearchModel

在4.x版本之后，使用以下命令：

bin/cake elasticsearch:indices create_indexes ElasticsearchModel

添加文档

接下来，我们可以添加文档。在控制器中，我们可以编写以下代码：

public function add()
{
    $this->request->allowMethod('post');
    $data = $this->request->data;

    $document = $this->ElasticsearchModel->newDocument();
    $document->id = $data['id'];
    $document->parent_id = $data['parent_id'];
    $document->title = $data['title'];
    $document->content = $data['content'];
    $document->body = $data['body'];

    if ($this->ElasticsearchModel->save($document)) {
        $this->Flash->success(__('The document has been saved.'));
        return $this->redirect(['action' => 'index']);
    } else {
        $this->Flash->error(__('The document could not be saved. Please, try again.'));
    }
}

搜索文档

现在我们可以搜索文档了。在控制器中，我们可以编写以下代码：

public function search()
{
    $this->paginate = [
        'contain' => ['Parent'],
    ];

    $query = $this->request->getQuery('q');
    $documents = $this->ElasticsearchModel->find()
        ->contain(['Parent'])
        ->where(['title LIKE' => "%$query%"])
        ->paginate();

    $this->set(compact('documents'));
}

我们可以在View中使用Paginator来显示搜索结果。

删除文档

如果需要删除文档，我们可以使用以下代码：

public function delete($id)
{
    $this->request->allowMethod(['post', 'delete']);
    $document = $this->ElasticsearchModel->find()->where(['id' => $id])->firstOrFail();
    if ($this->ElasticsearchModel->delete($document)) {
        $this->Flash->success(__('The document has been deleted.'));
    } else {
        $this->Flash->error(__('The document could not be deleted. Please, try again.'));
    }

    return $this->redirect(['action' => 'index']);
}

结论

相关推荐