• thinkphp中使用Elasticsearch 7.0进行多表的搜索

    提示：文章写完后，目录可以自动生成，如何生成可参考右边的帮助文档

    文章目录

    前言

    提示：thinkphp中使用Elasticsearch 7.0进行多表的搜索：

    thinkphp数据库配置文件

     // Elasticsearch数据库配置信息
        'elasticsearch' => [
            'scheme' =>'http',
            'host' => '127.0.0.1',
            'port' => '9200',
            'user' => '',
            'pass' => '',
            'timeout' => 2,
        ],

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9

    提示：以下是本篇文章正文内容，下面案例可供参考

    一、thinkphp中使用Elasticsearch 7.0进行多表的搜索

    示例：thinkphp中使用Elasticsearch 7.0进行多表的搜索

    二、使用步骤

    1.引入库

    直接上代码如下（示例）：

    composer require "elasticsearch/elasticsearch": "7.0.*"

    • 1

    2.读入数据

    代码如下（示例）：

    
namespace app\common\model;
use think\facade\Db;
use think\Model;
use Elasticsearch\ClientBuilder;
class Article extends Model
{
    protected $client;

    public function __construct($data = [])
    {
        parent::__construct($data);

        try {	
            $this->client = ClientBuilder::create()
                ->setHosts([config('database.connections.elasticsearch.host') . ':' . config('database.connections.elasticsearch.port')])
                ->build();
        } catch (\Exception $e) {
            // 输出连接错误信息
            echo $e->getMessage();
            exit;
        }
    }

    // 添加文档到Elasticsearch
    public function addDocument()
    {
        $articles = Db::name('article')->select();
        foreach ($articles as $article) {
            $data = [
                'id' => $article['id'], // 文章表的 ID
                'title' => $article['title'],
                'content' => $article['content'],
                'category_id' => $article['category_id'], // 文章表的 ID
            ];

            $params = [
                'index' => 'articles', // 索引名称
                'id' => $data['id'], // 文章 ID 作为文档的唯一标识
                'body' => $data,
            ];

            $response = $this->client->index($params);
        }
        return $response;
    }

    // 搜索文档
    public function searchDocuments($index,$query)
    {
        $params = [
            'index' => $index,
            'body' => [
                'query' => [
                    'multi_match' => [
                        'query' => $query,
                        'fields' => ['title', 'content'],
                    ],
                ],
            ],
        ];

        $response = $this->client->search($params);
        return $response;
    }
}

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36
    • 37
    • 38
    • 39
    • 40
    • 41
    • 42
    • 43
    • 44
    • 45
    • 46
    • 47
    • 48
    • 49
    • 50
    • 51
    • 52
    • 53
    • 54
    • 55
    • 56
    • 57
    • 58
    • 59
    • 60
    • 61
    • 62
    • 63
    • 64
    • 65
    • 66
    
/**
 * Created by PhpStorm.
 * User: wangkxin@foxmail.com
 * Date: 2023/9/2
 * Time: 17:55
 */

namespace app\common\model;
use think\facade\Db;
use think\Model;
use Elasticsearch\ClientBuilder;

class Book extends Model
{
    protected $client;

    public function __construct($data = [])
    {
        parent::__construct($data);

        try {
            // $host = config('database.connections.elasticsearch.host');
            // $port = config('database.connections.elasticsearch.port');
            $this->client = ClientBuilder::create()
                ->setHosts([config('database.connections.elasticsearch.host') . ':' . config('database.connections.elasticsearch.port')])
                ->build();
        } catch (\Exception $e) {
            // 输出连接错误信息
            echo $e->getMessage();
            exit;
        }
    }

    // 添加文档到Elasticsearch
    public function addDocument()
    {
        $books = Db::name('book')->select();
        foreach ($books as $book) {
            $data = [
                'id' => $book['id'], // 书籍表的 ID
                'user_id' => $book['user_id'], // 书籍表作者ID
                'book' => $book['book'],
            ];

            $params = [
                'index' => 'books', // 索引名称
                'id' => $data['id'], // 文章 ID 作为文档的唯一标识
                'body' => $data,
            ];

            $response = $this->client->index($params);
        }
        return $response;
    }

    // 搜索文档
    public function searchDocuments($index,$query)
    {
        $params = [
            'index' => $index,
            'body' => [
                'query' => [
                    'multi_match' => [
                        'query' => $query,
                        'fields' => ['book'],
                    ],
                ],
            ],
        ];

        $response = $this->client->search($params);
        return $response;
    }
}

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36
    • 37
    • 38
    • 39
    • 40
    • 41
    • 42
    • 43
    • 44
    • 45
    • 46
    • 47
    • 48
    • 49
    • 50
    • 51
    • 52
    • 53
    • 54
    • 55
    • 56
    • 57
    • 58
    • 59
    • 60
    • 61
    • 62
    • 63
    • 64
    • 65
    • 66
    • 67
    • 68
    • 69
    • 70
    • 71
    • 72
    • 73
    • 74
    • 75
    
/**
 * Created by PhpStorm.
 * User: wangkxin@foxmail.com
 * Date: 2023/9/2
 * Time: 15:27
 * 全局搜素模型
 */

namespace app\common\model;

use think\Model;
use Elasticsearch\ClientBuilder;

class ElasticsearchModel extends Model
{
    protected $client;

    public function __construct($data = [])
    {
        parent::__construct($data);

        try {
            $this->client = ClientBuilder::create()
                ->setHosts([config('database.connections.elasticsearch.host') . ':' . config('database.connections.elasticsearch.port')])
                ->build();
        } catch (\Exception $e) {
            // 输出连接错误信息
            echo $e->getMessage();
            exit;
        }
    }

    public function globalSearch($keyword)
    {
        // 搜索articles索引
        $articles = $this->searchIndex('articles', $keyword);

        // 搜索books索引
        $books = $this->searchIndex('books', $keyword);

        // 合并搜索结果
        $result = array_merge($articles, $books);

        return $result;
    }

    protected function searchIndex($index, $keyword)
    {
        $params = [
            'index' => $index,
            'body' => [
                'query' => [
                    'multi_match' => [
                        'query' => $keyword,
                        'fields' => ['title', 'content','book'],
                    ],
                ],
            ],
        ];

        // 执行搜索请求
        $response = $this->client->search($params);

        // 解析结果
        $result = [];
        if (isset($response['hits']['hits'])) {
            foreach ($response['hits']['hits'] as $hit) {
                $result[] = $hit['_source'];
                $result['index'] = $index;
            }
        }

        return $result;
    }


}

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36
    • 37
    • 38
    • 39
    • 40
    • 41
    • 42
    • 43
    • 44
    • 45
    • 46
    • 47
    • 48
    • 49
    • 50
    • 51
    • 52
    • 53
    • 54
    • 55
    • 56
    • 57
    • 58
    • 59
    • 60
    • 61
    • 62
    • 63
    • 64
    • 65
    • 66
    • 67
    • 68
    • 69
    • 70
    • 71
    • 72
    • 73
    • 74
    • 75
    • 76
    • 77
    • 78
    
/**
 * Created by PhpStorm.
 * User: wangkxin@foxmail.com
 * Date: 2023/9/2
 * Time: 18:53
 */

namespace app\index\controller;

use app\common\model\ElasticsearchModel;

class SearchController
{
	//全局搜索个表间的数据
    public function search($keyword)
    {
        $searchModel = new ElasticsearchModel();
        $result = $searchModel->globalSearch($keyword);
        return json($result);
    }
}

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    

namespace app\index\controller;
use app\BaseController;
use app\common\model\Article as ElasticArticle;
use app\common\model\Book as ElasticBook;
use app\Request;
use Elasticsearch\ClientBuilder;


class Demo1 extends BaseController
{
//新增索引,建议在模型中新增 ,删除, 修改 或者使用观察者模式更新ES索引
 public function addDocument()
    {
        $elasticsearchArticle = new ElasticArticle();
        $response = $elasticsearchArticle->addDocument();
        $elasticsearchBook = new ElasticBook();
        $response1 = $elasticsearchBook->addDocument();
        return json($response);
        // print_r(json($response));
        // print_r(json($response1));
    }


 /**
     * 单独搜索文章表例子
     */
    public function search(Request $request)
    {
        $keyword = $request->param('keyword');
        $elasticsearchModel = new ElasticArticle();
        $index = 'articles';
        $query = '你';

        $response = $elasticsearchModel->searchDocuments($index, $query);
        return json($response);
    }

	//单独搜搜书籍表
    public function searchBook(Request $request)
    {
        $keyword = $request->param('keyword');
        $elasticsearchModel = new ElasticBook();
        $index = 'books';
        $query = '巴黎';

        $response = $elasticsearchModel->searchDocuments($index, $query);
        return json($response);
    }




    public function deleteIndex()
    {
        $client = ClientBuilder::create()->build();

        $params = [
            'index' => 'my_index', // 索引名称
        ];

        $response = $client->indices()->delete($params);

        if ($response['acknowledged']) {
            return '索引删除成功';
        } else {
            return '索引删除失败';
        }
    }

}

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36
    • 37
    • 38
    • 39
    • 40
    • 41
    • 42
    • 43
    • 44
    • 45
    • 46
    • 47
    • 48
    • 49
    • 50
    • 51
    • 52
    • 53
    • 54
    • 55
    • 56
    • 57
    • 58
    • 59
    • 60
    • 61
    • 62
    • 63
    • 64
    • 65
    • 66
    • 67
    • 68
    • 69
    • 70
    • 71
    • 72

    使用的表

    CREATE TABLE `article` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `category_id` int(11) DEFAULT NULL,
  `title` varchar(255) COLLATE utf8_unicode_ci DEFAULT NULL,
  `content` varchar(255) COLLATE utf8_unicode_ci DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=MyISAM AUTO_INCREMENT=107 DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;


CREATE TABLE `book` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `user_id` int(11) DEFAULT NULL,
  `book` varchar(255) COLLATE utf8_unicode_ci DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=MyISAM AUTO_INCREMENT=21 DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;


CREATE TABLE `elasticsearch_model` (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键',
  `model_name` varchar(255) NOT NULL DEFAULT '' COMMENT '模型名称',
  `index_name` varchar(255) NOT NULL DEFAULT '' COMMENT '索引名称',
  `created_time` int(11) NOT NULL DEFAULT '0' COMMENT '创建时间',
  `updated_time` int(11) NOT NULL DEFAULT '0' COMMENT '更新时间',
  PRIMARY KEY (`id`),
  UNIQUE KEY `index_name_unique` (`index_name`)
) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8mb4 COMMENT='Elasticsearch 模型配置表';



    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28

    结果
    在这里插入图片描述
    在这里插入图片描述

    windwos 上记住 安装 Elasticsearch 7.0 库, 和 kibana-7.0.0-windows-x86_64 图像管理工具
    在这里插入图片描述
    在这里插入图片描述

    在这里插入图片描述

    在这里插入图片描述

    总结

    提示：这是简单例子, 注意’fields’ => [‘title’, ‘content’], 尝试使用搜索number型字段,索引报错, 貌似只支持txt类型字段搜索
    例如：以上就是今天要讲的内容，本文仅仅简单介绍了Elasticsearch的使用

  • 相关阅读:
    【语音识别】在Win11使用Docker部署FunASR服务器
    私藏！资深数据专家SQL效率优化技巧 ⛵
    Web框架开发-Form组件和ajax实现注册
    mysql超全语法大全
    YbtOJ「基础算法」第4章 深度搜索
    4 | Nikto使用
    鲲鹏开发者峰会2022丨冲量携手鲲鹏，共赢数字新时代
    网页黑白滤镜
    1.8 faker简单应用
    PRML 概率分布
  • 原文地址：https://blog.csdn.net/qq_27878777/article/details/132643924