<?php
class search
{
public function __construct()
{
$this->esUri = $host . ':' . $port . "/" . $index . "/" . $type. "/";
}
//demo
public function demo()
{
$conditions = [
['field' => 'company', 'type' => 'like', 'value' => '春風(fēng)'],
['field' => 'groupid', 'type' => 'between', 'value' => [4, 6]],
['field' => 'email', 'type' => '=', 'value' => 'jiaogun@139.com'],
];
$page = 1;
$limit = 20;
$offset = ($page > 0) ? ($page - 1) * $limit : 0;
$columns = ['username', 'userid', 'groupid', 'company'];
$order = array('field' => 'userid', 'sort' => 'desc');
$res = $this->search($conditions, $offset, $limit, $columns, $order);
var_dump($res);die();
}
//es搜索
public function search($conditions = array(), $offset = 0, $limit = 20, $columns = array(), $order = array('field' => 'userid', 'sort' => 'desc'))
{
$params = [
"query" => [
"filtered" => [
'filter' => [
'bool' => [
'must' => [
],
],
],
"query" => [
'bool' => [
'must' => [
],
],
],
],
],
'sort' => [
$order['field'] => [
'order' => $order['sort'],
],
],
'_source' => $columns,
'from' => $offset,
'size' => $limit,
];
if (!empty($conditions)) {
foreach ($conditions as $v) {
switch ($v['type']) {
case 'between':
$params['query']['filtered']['filter']['bool']['must'][]['range'][$v['field']]['gt'] = $v['value'][0];
$params['query']['filtered']['filter']['bool']['must'][]['range'][$v['field']]['lt'] = $v['value'][1];
break;
case '>':
$params['query']['filtered']['filter']['bool']['must'][]['range'][$v['field']]['gt'] = $v['value'];
break;
case '>=':
$params['query']['filtered']['filter']['bool']['must'][]['range'][$v['field']]['gte'] = $v['value'];
break;
case '<':
$params['query']['filtered']['filter']['bool']['must'][]['range'][$v['field']]['lt'] = $v['value'];
break;
case '<=':
$params['query']['filtered']['filter']['bool']['must'][]['range'][$v['field']]['lte'] = $v['value'];
break;
case '=':
$params['query']['filtered']['filter']['bool']['must'][]['term'][$v['field']] = $v['value'];
break;
case '!=':
$params['query']['filtered']['filter']['bool']['must_not'][]['term'][$v['field']] = $v['value'];
break;
case 'in':
if (!empty($v['value']) && is_array($v['value'])) {
foreach ($v['value'] as $m => $n) {
$params['query']['filtered']['filter']['bool']['must'][] = array(
'term' => array(
$v['field'] => $n,
),
);
}
}
break;
case 'not in':
if (!empty($v['value']) && is_array($v['value'])) {
foreach ($v['value'] as $m => $n) {
$params['query']['filtered']['filter']['bool']['must_not'][] = array(
'term' => array(
$v['field'] => $n,
),
);
}
}
break;
case 'like':
$params['query']['filtered']['query']['bool']['must'][]['match'][$v['field']] = $v['value'];
unset($params['sort']);
$params['sort']['_score']['order'] = 'desc';
$params['sort']['userid']['order'] = 'desc';
break;
default:
return false;
break;
}
}
}
$res = $this->getEs($params, true, $this->esUri . '_search/');
$res = json_decode($res, true);
$reData['data'] = array();
if (!empty($res['hits']['hits'])) {
foreach ($res['hits']['hits'] as $k => $v) {
$reData['data'][$k] = $v;
}
}
$reData['count'] = !empty($res['hits']['total']) ? $res['hits']['total'] : 0;
return $reData;
}
//es搜索 解決深度分頁問題 按照userid asc排序
public function searchAll($conditions = array(), $limit = 50, $columns = array(), $userid = 0)
{
$params = [
"query" => [
"filtered" => [
'filter' => [
'bool' => [
'must' => [
],
],
],
"query" => [
'bool' => [
'must' => [
[
'range' => [
'userid' => [
'gt' => $userid,
],
],
],
],
],
],
],
],
'sort' => [
'userid' => [
'order' => 'asc',
],
],
'_source' => $columns,
'size' => $limit,
];
if (!empty($conditions)) {
foreach ($conditions as $v) {
switch ($v['type']) {
case 'between':
$params['query']['filtered']['filter']['bool']['must'][]['range'][$v['field']]['gt'] = $v['value'][0];
$params['query']['filtered']['filter']['bool']['must'][]['range'][$v['field']]['lt'] = $v['value'][1];
break;
case '>':
$params['query']['filtered']['filter']['bool']['must'][]['range'][$v['field']]['gt'] = $v['value'];
break;
case '>=':
$params['query']['filtered']['filter']['bool']['must'][]['range'][$v['field']]['gte'] = $v['value'];
break;
case '<':
$params['query']['filtered']['filter']['bool']['must'][]['range'][$v['field']]['lt'] = $v['value'];
break;
case '<=':
$params['query']['filtered']['filter']['bool']['must'][]['range'][$v['field']]['lte'] = $v['value'];
break;
case '=':
$params['query']['filtered']['filter']['bool']['must'][]['term'][$v['field']] = $v['value'];
break;
case '!=':
$params['query']['filtered']['filter']['bool']['must_not'][]['term'][$v['field']] = $v['value'];
break;
case 'in':
if (!empty($v['value']) && is_array($v['value'])) {
foreach ($v['value'] as $m => $n) {
$params['query']['filtered']['filter']['bool']['must'][] = array(
'term' => array(
$v['field'] => $n,
),
);
}
}
break;
case 'not in':
if (!empty($v['value']) && is_array($v['value'])) {
foreach ($v['value'] as $m => $n) {
$params['query']['filtered']['filter']['bool']['must_not'][] = array(
'term' => array(
$v['field'] => $n,
),
);
}
}
break;
case 'like':
$params['query']['filtered']['query']['bool']['must'][]['match'][$v['field']] = $v['value'];
break;
default:
return false;
break;
}
}
}
$res = $this->getEs($params, true, $this->esUri . '_search/');
$res = json_decode($res, true);
$reData['data'] = array();
if (!empty($res['hits']['hits'])) {
foreach ($res['hits']['hits'] as $k => $v) {
$reData['data'][$k] = $v;
}
}
$reData['count'] = !empty($res['hits']['total']) ? $res['hits']['total'] : 0;
return $reData;
}
//es統(tǒng)計數(shù)量
public function count($conditions = array())
{
$params = [
"query" => [
"filtered" => [
'filter' => [
'bool' => [
'must' => [
],
],
],
"query" => [
'bool' => [
'must' => [
],
],
],
],
],
];
if (!empty($conditions)) {
foreach ($conditions as $v) {
switch ($v['type']) {
case 'between':
$params['query']['filtered']['filter']['bool']['must'][]['range'][$v['field']]['gt'] = $v['value'][0];
$params['query']['filtered']['filter']['bool']['must'][]['range'][$v['field']]['lt'] = $v['value'][1];
break;
case '>':
$params['query']['filtered']['filter']['bool']['must'][]['range'][$v['field']]['gt'] = $v['value'];
break;
case '>=':
$params['query']['filtered']['filter']['bool']['must'][]['range'][$v['field']]['gte'] = $v['value'];
break;
case '<':
$params['query']['filtered']['filter']['bool']['must'][]['range'][$v['field']]['lt'] = $v['value'];
break;
case '<=':
$params['query']['filtered']['filter']['bool']['must'][]['range'][$v['field']]['lte'] = $v['value'];
break;
case '=':
$params['query']['filtered']['filter']['bool']['must'][]['term'][$v['field']] = $v['value'];
break;
case '!=':
$params['query']['filtered']['filter']['bool']['must_not'][]['term'][$v['field']] = $v['value'];
break;
case 'in':
if (!empty($v['value']) && is_array($v['value'])) {
foreach ($v['value'] as $m => $n) {
$params['query']['filtered']['filter']['bool']['must'][] = array(
'term' => array(
$v['field'] => $n,
),
);
}
}
break;
case 'not in':
if (!empty($v['value']) && is_array($v['value'])) {
foreach ($v['value'] as $m => $n) {
$params['query']['filtered']['filter']['bool']['must_not'][] = array(
'term' => array(
$v['field'] => $n,
),
);
}
}
break;
case 'like':
$params['query']['filtered']['query']['bool']['must'][]['match'][$v['field']] = $v['value'];
break;
default:
return false;
break;
}
}
}
$res = $this->getEs($params, true, $this->esUri . '_count/');
$res = json_decode($res, true);
$count = !empty($res['count']) ? $res['count'] : 0;
return $count;
}
private function getEs($data = [], $ispost = true, $uri = "es地址")
{
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $uri);
curl_setopt($ch, CURLOPT_HTTPHEADER, array('Accept: application/json'));
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 30);
curl_setopt($ch, CURLOPT_TIMEOUT, 30);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
if ($ispost) {
curl_setopt($ch, CURLOPT_POST, true);
curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data));
}
$result = curl_exec($ch);
$httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
curl_close($ch);
if ($httpCode != 200) {
var_dump($result);
return false;
} else {
return $result;
}
}
}
PHP操作ES使用案例
最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
- 文/潘曉璐 我一進(jìn)店門耐床，熙熙樓的掌柜王于貴愁眉苦臉地迎上來密幔，“玉大人，你說我怎么就攤上這事撩轰】杷Γ” “怎么了昧廷？”我有些...
- 文/不壞的土叔 我叫張陵，是天一觀的道長偎箫。 經(jīng)常有香客問我木柬，道長，這世上最難降的妖魔是什么淹办？ 我笑而不...
- 正文 為了忘掉前任眉枕，我火速辦了婚禮，結(jié)果婚禮上怜森，老公的妹妹穿的比我還像新娘速挑。我一直安慰自己，他們只是感情好副硅，可當(dāng)我...
- 文/花漫 我一把揭開白布姥宝。 她就那樣靜靜地躺著，像睡著了一般恐疲。 火紅的嫁衣襯著肌膚如雪腊满。 梳的紋絲不亂的頭發(fā)上，一...
- 文/蒼蘭香墨 我猛地睜開眼愕乎，長吁一口氣：“原來是場噩夢啊……” “哼！你這毒婦竟也來了壁公？” 一聲冷哼從身側(cè)響起感论，我...
- 正文 年R本政府宣布，位于F島的核電站笔呀，受9級特大地震影響幢踏，放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜凿可，卻給世界環(huán)境...
- 文/蒙蒙 一惑折、第九天 我趴在偏房一處隱蔽的房頂上張望授账。 院中可真熱鬧枯跑，春花似錦、人聲如沸白热。這莊子的主人今日做“春日...
- 文/蒼蘭香墨 我抬頭看了看天上的太陽屋确。三九已至纳击，卻和暖如春，著一層夾襖步出監(jiān)牢的瞬間攻臀，已是汗流浹背焕数。 一陣腳步聲響...
推薦閱讀更多精彩內(nèi)容
- 1.mysql語言內(nèi)部本身不區(qū)分大小寫 2.刪除數(shù)據(jù)庫: drop database if exists 數(shù)據(jù)庫名...
- （一） “世界上最遙遠(yuǎn)的距離垮卓，是入得了你的眼劈榨，卻走不進(jìn)你心底“保” “想，和想起，之間差一個字想虎，和十萬八千里∨劾洌“ 愛...
- 終于放假了磷醋，感到滿身的輕松，一學(xué)期的學(xué)習(xí)結(jié)束了胡诗。 我們從昨天開始考試邓线，上午第一節(jié)考語文淌友，第二節(jié)考生...
