开头先放一波官方中文手册文档：

`https://es.xiaoleilu.com/`

然后再放一波PHP扩展包的中文手册文档：

`https://www.elastic.co/guide/cn/elasticsearch/php/current/index.html`

### 1、基于ElasticSearch-PHP，二次封装CURD包
```php
// +----------------------------------------------------------------------
// | Elasticsearch 常用功能演示
// +----------------------------------------------------------------------
// | Copyright (c) 2018 https://vpsbm.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
// | Author: 小黄牛 <1731223728@qq.com>
// +----------------------------------------------------------------------

# 引入官方包
require 'vendor/autoload.php';
# 加载包
use Elasticsearch\ClientBuilder;

class MyElasticSearch
{
    // 连接实例
    private static $client;
    // 单例实例
    private static $instance = null;
    // 批量新增修改文档，分批发送数量
    private static $num = 10000;
    // 私有化构造函数，防止外部调用
    private function __construct() {}
    // 私有化克隆函数，防止外部克隆对象
    private function __clone() {}
    
    /**
     * 单例构造函数，唯一连接创建
     * @todo 这是单库的链接方式，如果是分布式的话，IP跟端口改下传参方式就好，参考官方手册
     * @author 小黄牛
     * @version v1.0.1 + 2019.08.07
     * @deprecated 暂不弃用
     * @global 无
     * @param string $ip IP地址
     * @param string $port 端口号
     * @param int $retries 失败重连次数，正常你不想重连，应该设置为0，不是1
     * @return bool|obj
    */
    public static function run($ip='127.0.0.1', $port='9200', $retries=2){
        # 只有第一次调用，才允许创建对象实例
        if (empty(self::$client)) {
            $params = [
                $ip.':'.$port
            ];
            # 连接 Elasticsearch
            self::$client = ClientBuilder::create()->setHosts($params)->setRetries($retries)->build();
            self::$instance = new \MyElasticSearch();
        }
        return self::$instance;
    }

/**
     * 查询一个或多个索引的表情况(table表)
     * @todo 无
     * @author 小黄牛
     * @version v1.0.1 + 2019.08.07
     * @deprecated 暂不弃用
     * @global 无
     * @param string|array1 $list
     * @return void
    */
    public function list_table($list) {
        $params = [
            'index' => $list
        ];

# 这扩展包问题，如果你检索不存在的表，它就会报错，监听异常都没用
        return self::$client->indices()->getSettings($params);
    }
    
    /**
     * 创建一个索引(table表)
     * @todo 无
     * @author 小黄牛
     * @version v1.0.1 + 2019.08.07
     * @deprecated 暂不弃用
     * @global 无
     * @param string $table 表名
     * @return void
    */
    public function create_table($table) {
        $params = [
            'index' => $table, // 表名
            // 表配置
            'body'  => [
                // 详细参数配置
                'settings' => [
                    'number_of_shards' => 5, // 分片值5
                    'number_of_replicas' => 0 // 分布式拷贝数量为0
                ]
            ]
        ];
        
        # 创建表比较重要，就监听下异常吧，其他地方要监听也这样放就行
        try {
            return self::$client->indices()->create($params);
        } catch (Elasticsearch\Common\Exceptions\BadRequest400Exception $e) {
            $msg = $e->getMessage();
            $msg = json_decode($msg,true);
            return $msg;
        }
    }

/**
     * 删除一个索引(table表)
     * @todo 无
     * @author 小黄牛
     * @version v1.0.1 + 2019.08.07
     * @deprecated 暂不弃用
     * @global 无
     * @param string $table 表名
     * @return void
    */
    public function delete_table($table) {
        $params = ['index' => $table];

# 如果表不存在，删除则会报错
        return self::$client->indices()->delete($params);
    }

/**
     * 修改一个索引的配置参数(table表)
     * @todo 无
     * @author 小黄牛
     * @version v1.0.1 + 2019.08.07
     * @deprecated 暂不弃用
     * @global 无
     * @param string $table 表名
     * @param array $settings 配置参数
     * @return void
    */
    public function update_table($table, $settings) {
        $params = [
            'index' => $table,
            'body' => [
                'settings' => $settings
            ]
        ];
        
        return self::$client->indices()->putSettings($params);
    }

/**
     * 添加或修改一个索引的映射(table表字段)
     * @todo 无
     * @author 小黄牛
     * @version v1.0.1 + 2019.08.07
     * @deprecated 暂不弃用
     * @global 无
     * @param string $table 表名
     * @param array $array 字段集合
     * @return void
    */
    public function update_field($table, $array) {
        $params = [
            'index' => $table,
            'type' => $table.'2',
            'body' => $array
        ];
        return self::$client->indices()->putMapping($params);
    }

/**
     * 查询一个或多个索引的字段情况(table表)
     * @todo 无
     * @author 小黄牛
     * @version v1.0.1 + 2019.08.07
     * @deprecated 暂不弃用
     * @global 无
     * @param string|array1 $list
     * @return void
    */
    public function list_field($list) {
        $params = [
            'index' => $list
        ];

# 这扩展包问题，如果你检索不存在的表，它就会报错，监听异常都没用
        return self::$client->indices()->getMapping($params);
    }

/**
     * 单条向索引里添加文档（表插入内容）
     * @todo 无
     * @author 小黄牛
     * @version v1.0.1 + 2019.08.07
     * @deprecated 暂不弃用
     * @global 无
     * @param string $table 表名
     * @param array $data 内容
     * @param int|string $id 唯一主键
     * @return void
    */
    public function insert($table, $data, $id=null) {
        $params = [
            'index' => $table,
            'type' => $table.'2',
            'body' => $data
        ];       
        if ($id) $params['id'] = $id;

return self::$client->index($params);
    }

/**
     * 批量向索引里添加文档（表插入内容）
     * @todo 无
     * @author 小黄牛
     * @version v1.0.1 + 2019.08.07
     * @deprecated 暂不弃用
     * @global 无
     * @param string $table 表名
     * @param array $data 内容，唯一id使用_id
     * @return void
    */
    public function insertAll($table, $data) {
        $params = [
            'body' => []
        ];       
        
        foreach ($data as $k=>$v) {
            $body = [
                '_index' => $table,
                '_type' => $table.'2',
            ];
            // 看看是否包含自定义主键
            if (isset($v['_id'])) {
                $body['_id'] = $v['_id'];
                unset($v['_id']);
            }
            $params['body'][] = [
                'index' => $body
            ];

$params['body'][] = $v;

if ($k % self::$num == 0) {
                $responses = self::$client->bulk($params);
                $params = ['body' => []];
                unset($responses);
            }
        }

if (!empty($params['body'])) {
            return self::$client->bulk($params);
        }
    }

/**
     * 使用ID单条记录查询（只能使用主键ID）
     * @todo 无
     * @author 小黄牛
     * @version v1.0.1 + 2019.08.07
     * @deprecated 暂不弃用
     * @global 无
     * @param string $table 表名
     * @param mixed $id 主键值
     * @return void
    */
    public function find($table, $id) {
        $params = [
            'index' => $table,
            'type' => $table.'2',
            'id' => $id
        ];
        
        return self::$client->get($params);
    }

/**
     * 多条记录检索
     * @todo 单库
     * @author 小黄牛
     * @version v1.0.1 + 2019.08.07
     * @deprecated 暂不弃用
     * @global 无
     * @param string $table 表名
     * @param array $where 查询条件
     * @param string $type 查询模式  match|match_phrase|bool|模糊查询|模糊查询(可使用分词因子)|多种查询
     * @param int $slop 分词因子 0则不分词严格查询
     * @param array $order 排序字段，可以多个
     * @param int $page 分页数，传入值会默认-1的，0和1，都会认为是1
     * @param int $size 返回长度
     * @return void
    */
    public function select($table, $where, $type='match_phrase', $slop=0, $order=[], $page=1, $size=2) {
        if ($page == 1 || $page== 0) $page = 1;
        $page -= 1;

$order_list = [];
        foreach ($order as $k=>$v) {
            if (is_array($v)) {
                $order_list[$k] = $v;
            } else {
                // 不填写排序，默认就降序
                $order_list[$v] = [
                    'order' => 'DESC'
                ];
            }
        }
        $params = [
            'index' => $table,
            'type' => $table.'2',
            'body' => [
                'query' => [],
                'sort' => $order_list,
                'from' => $page,
                'size' => $size
            ]
        ];

// 查询类型分组传参
        if ($type == 'match_phrase' || $type == 'match') {
            if (count($where) > 1) die('match模式下只允许传入一个where条件！');
            $array = [];
            foreach ($where as $k=>$v) {
                $array[$k] = [
                    'query' => $v, 'slop' => $slop
                ];
            }
            $params['body']['query'][$type] = $array;
        } else if ($type == 'bool') {
            $array = [];
            foreach ($where as $k=>$v) {
                $array[]['match'] = [$k=>[
                    'query' => $v
                ]];
            }
            $params['body']['query']['bool'] = [
                'must' => [
                    $array
                ]
            ];
        }

return self::$client->search($params);
    }

/**
     * 单条向索引里更新文档（表更新内容）
     * @todo 无
     * @author 小黄牛
     * @version v1.0.1 + 2019.08.07
     * @deprecated 暂不弃用
     * @global 无
     * @param string $table 表名
     * @param array $data 内容
     * @param int|string $id 唯一主键
     * @return void
    */
    public function update($table, $data, $id=null) {
        $params = [
            'index' => $table,
            'type' => $table.'2',
            'id' => $id,
            'body' => [
                'doc' => $data
            ]
        ];

return self::$client->update($params);
    }

/**
     * 指定单条记录自增
     * @todo 无
     * @author 小黄牛
     * @version v1.0.1 + 2019.08.07
     * @deprecated 暂不弃用
     * @global 无
     * @param string $table 表名
     * @param string $field 字段名
     * @param int|string $id 唯一主键
     * @param int $num 自增量
     * @return void
    */
    public function setInc($table, $field, $id=null, $num=1) {
        // $num 必须除以2，发现这是这个脚本的bug，会执行2次+=，没发现原因，估计是底层的问题
        $params = [
            'index' => $table,
            'type' => $table.'2',
            'id' => $id,
            'body' => [
                'script' => 'ctx._source.'.$field.' += '.($num/2)
            ]
        ];

return self::$client->update($params);
    }

/**
     * 指定单条记录自减
     * @todo 无
     * @author 小黄牛
     * @version v1.0.1 + 2019.08.07
     * @deprecated 暂不弃用
     * @global 无
     * @param string $table 表名
     * @param string $field 字段名
     * @param int|string $id 唯一主键
     * @param int $num 自减量
     * @return void
    */
    public function setDec($table, $field, $id=null, $num=1) {
        // $num 必须除以2，发现这是这个脚本的bug，会执行2次+=，没发现原因，估计是底层的问题
        $params = [
            'index' => $table,
            'type' => $table.'2',
            'id' => $id,
            'body' => [
                'script' => 'ctx._source.'.$field.' -= '.($num/2)
            ]
        ];

return self::$client->update($params);
    }

/**
     * 指定单条记录删除
     * @todo 无
     * @author 小黄牛
     * @version v1.0.1 + 2019.08.07
     * @deprecated 暂不弃用
     * @global 无
     * @param string $table 表名
     * @param int|string $id 唯一主键
     * @return void
    */
    public function delete($table, $id=null) {
        $params = [
            'index' => $table,
            'type' => $table.'2',
            'id' => $id,
        ];

return self::$client->delete($params);
    }
}
```

### 二、使用说明
```
------------------------------------- 表操作相关 ----------------------------------
1、创建一个表
MyElasticSearch::run()->create_table('demo2');
2、查询一个表或多个表的配置参数
MyElasticSearch::run()->list_table('demo2');
MyElasticSearch::run()->list_table(['demo2', 'test']);
3、删除一个表
MyElasticSearch::run()->delete_table('demo2');
4、修改表的配置参数 - 这个有bug，官方说不允许更改索引的配置，但又提供了这个接口，有点无解
MyElasticSearch::run()->update_table('demo2', [
    'number_of_shards' => 5, // 分片值5
    'number_of_replicas' => 0 // 分布式拷贝数量为0
]);
5、修改表的字段结构
MyElasticSearch::run()->update_field('demo2', [
    '_source' => [
        'enabled' => true
    ],
    'properties' => [
        'name' => [// 字段名
            "type" => "text", // 类型，注意类型创建之后将不能修改，否则会报错
            "store" => true // 支持全文检索
        ],
        'age' => [
            'type' => 'integer'
        ]
    ]
]);
6、查询一个表或多个表的字段结构     
MyElasticSearch::run()->list_field('demo2');
MyElasticSearch::run()->list_field(['demo2', 'test']);

------------------------------------- 数据操作相关 --------------------------------
1、单条记录新增
MyElasticSearch::run()->insert('demo2', ['name'=>'小黄牛', 'age' => 18]);
2、批量记录新增
MyElasticSearch::run()->insertAll('demo2', [
    ['name'=>'小黄牛2', 'age' => 18],
    ['name'=>'小黄牛3', 'age' => 19, '_id'=>2],
    ['name'=>'小黄牛4', 'age' => 20, '_id'=>3],
]);
3、使用主键单条记录查询
MyElasticSearch::run()->find('demo2', 3);
// 模糊查询
MyElasticSearch::run()->select('demo2', ['name'=>'小黄牛']);
// 模糊查询，可以指定分词次数
MyElasticSearch::run()->select('demo2', ['name'=>'小黄牛'], 'match_phrase', 1);
// 联合查询，可多条件
MyElasticSearch::run()->select('demo2', ['name'=>'小黄牛', 'age'=> 2], 'bool');
// 全条件查询
// 解释：查询demo2表，条件为name like 小黄牛 match_phrase模式下分词匹配1次 age字段降序 第2页，只读2条
MyElasticSearch::run()->select('demo2', ['name'=>'小黄牛'], 'match_phrase', 1, ['age'], 2, 2)
4、单条记录更新
MyElasticSearch::run()->update('demo2', ['name'=>'小黄猪', 'age' => 18], 2);
5、指定单条记录自增
MyElasticSearch::run()->setInc('demo2', 'age', 2, 10);
6、指定单条记录自减
MyElasticSearch::run()->setDec('demo2', 'age', 2, 10);
7、单条记录删除
MyElasticSearch::run()->delete('demo2', 1);
```

已有0条评论

添加新评论☺

如果认为本文对您有所帮助请赞助本站

支付宝扫一扫赞助

已有0条评论

添加新评论☺