提示：文章寫(xiě)完后，目錄可以自動(dòng)生成，如何生成可參考右邊的幫助文檔
前言
提示：thinkphp中使用Elasticsearch 7.0進(jìn)行多表的搜索：
thinkphp數(shù)據(jù)庫(kù)配置文件
// Elasticsearch數(shù)據(jù)庫(kù)配置信息
'elasticsearch' => [
'scheme' =>'http',
'host' => '127.0.0.1',
'port' => '9200',
'user' => '',
'pass' => '',
'timeout' => 2,
],
提示：以下是本篇文章正文內(nèi)容，下面案例可供參考
一、thinkphp中使用Elasticsearch 7.0進(jìn)行多表的搜索
示例：thinkphp中使用Elasticsearch 7.0進(jìn)行多表的搜索
二、使用步驟
1.引入庫(kù)
直接上代碼如下（示例）：
composer require "elasticsearch/elasticsearch": "7.0.*"
2.讀入數(shù)據(jù)
代碼如下（示例）：
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) {
// 輸出連接錯(cuò)誤信息
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 作為文檔的唯一標(biāo)識(shí)
'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;
}
}
<?php
/**
* 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) {
// 輸出連接錯(cuò)誤信息
echo $e->getMessage();
exit;
}
}
// 添加文檔到Elasticsearch
public function addDocument()
{
$books = Db::name('book')->select();
foreach ($books as $book) {
$data = [
'id' => $book['id'], // 書(shū)籍表的 ID
'user_id' => $book['user_id'], // 書(shū)籍表作者ID
'book' => $book['book'],
];
$params = [
'index' => 'books', // 索引名稱
'id' => $data['id'], // 文章 ID 作為文檔的唯一標(biāo)識(shí)
'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;
}
}
<?php
/**
* 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) {
// 輸出連接錯(cuò)誤信息
echo $e->getMessage();
exit;
}
}
public function globalSearch($keyword)
{
// 搜索articles索引
$articles = $this->searchIndex('articles', $keyword);
// 搜索books索引
$books = $this->searchIndex('books', $keyword);
// 合并搜索結(jié)果
$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'],
],
],
],
];
// 執(zhí)行搜索請(qǐng)求
$response = $this->client->search($params);
// 解析結(jié)果
$result = [];
if (isset($response['hits']['hits'])) {
foreach ($response['hits']['hits'] as $hit) {
$result[] = $hit['_source'];
$result['index'] = $index;
}
}
return $result;
}
}
<?php
/**
* 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
{
//全局搜索個(gè)表間的數(shù)據(jù)
public function search($keyword)
{
$searchModel = new ElasticsearchModel();
$result = $searchModel->globalSearch($keyword);
return json($result);
}
}
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));
}
/**
* 單獨(dú)搜索文章表例子
*/
public function search(Request $request)
{
$keyword = $request->param('keyword');
$elasticsearchModel = new ElasticArticle();
$index = 'articles';
$query = '你';
$response = $elasticsearchModel->searchDocuments($index, $query);
return json($response);
}
//單獨(dú)搜搜書(shū)籍表
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 '索引刪除失敗';
}
}
}
使用的表
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 '創(chuàng)建時(shí)間',
`updated_time` int(11) NOT NULL DEFAULT '0' COMMENT '更新時(shí)間',
PRIMARY KEY (`id`),
UNIQUE KEY `index_name_unique` (`index_name`)
) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8mb4 COMMENT='Elasticsearch 模型配置表';
結(jié)果
windwos 上記住 安裝 Elasticsearch 7.0 庫(kù), 和 kibana-7.0.0-windows-x86_64 圖像管理工具
文章來(lái)源：http://www.zghlxwxcb.cn/news/detail-691430.html
總結(jié)
提示：這是簡(jiǎn)單例子, 注意’fields’ => [‘title’, ‘content’], 嘗試使用搜索number型字段,索引報(bào)錯(cuò), 貌似只支持txt類型字段搜索
例如：以上就是今天要講的內(nèi)容，本文僅僅簡(jiǎn)單介紹了Elasticsearch的使用文章來(lái)源地址http://www.zghlxwxcb.cn/news/detail-691430.html
到了這里，關(guān)于thinkphp中使用Elasticsearch 7.0進(jìn)行多表的搜索的文章就介紹完了。如果您還想了解更多內(nèi)容，請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
