ljw/es

a simple es handler

es使用

• 项目要用到es，所以自己进行了一下简单的封装, _(*1)

• es版本2.3, _(*2)

安装

composer require ljw/es:dev-master, _(*3)

配置

//配置es
\Ljw\Es\Es::$hosts = '127.0.0.1';
\Ljw\Es\Es::$port = '9200';

开始使用

建立索引

• 创建一个类继承model

class Product extends \Ljw\Es\Model
{
    //指定索引
    protected $index = 'product_index';
    //指定索引别名
    protected $alias = 'product_alias';
    //指定type
    protected $type = 'products';
    /**
     * 索引设置
     * @var array
     */
    protected $setting = [];
    /**
     * 索引参数
     * @var array
     */
    protected $properties = [
        'id'             => ['type' => 'long'],
        'name'           => ['type' => 'string'],
        'description'    => ['type' => 'string'],
    ];

}

• 注：如果没有在类里面指定index，alias和type,会自动设置为, _(*4)

  {class}_index | {class}_alias | {class}_type, _(*5)

{class} 为类名小写, _(*6)

• 运行

//创建索引。会根据Product中的$setting，$properties来创建
Product::createIndex();
//删除索引
Product::deleteIndex();
//跟新索引。根据Product中的$properties来跟新，只能进行追加，不能修改和删除字段
Product::updateIndex();

查询

1. 直接查询

//简单查询,where只支持 = , > , < , >= , <= , between ; = 就相当于like了
// where ... or ... and (... or ...) order by `id` `desc` 
$query = \Ljw\Es\Es::query()
    ->index('pro_index')
    ->type('type')
    ->where(...)
    ->orWhere(...)
    ->where(function ($q) {
        $q->where(...)->orWhere(...);
    })
    ->order('id', 'desc')
    ->page($page, $page_size)
    ->search();
$list = $query->getData(); //数据列表
$count = $query->getCount(); //数据总量
// ---------------
// 聚合，支持 group,avg,sum,max,min
$query = \Ljw\Es\Es::query()
    ->index('pro_index')
    ->type('type')
    ->where(...)
    ->group('xxx', function($q){  //  group by xxx 并计算不同xxx下面aaa的和
        $q->sum('aaa');
    })
    ->sum('id') // 计算id的和
    ->search();
$data = $query->getData();

1. 创建模型查询

class Product extends \Ljw\Es\Model
{
    //指定索引
    protected $index = 'product_index';
    //指定索引别名
    protected $alias = 'product_alias';
    //指定type
    protected $type = 'products';
    protected $setting = [...];
    protected $properties = [...];

}
$re = Product::query()->where(...)->orWhere(...)->search();
$list = $re->getData(); //数据列表
$count = $re->getCount(); //数据总量
$re = Product::query()->where(...)->orWhere(...)->group(...)->search();
$data = $re->getData();

添加，修改，删除数据

• 建立模型

class Product extends \Ljw\Es\Model
{
    //指定索引
    protected $index = 'product_index';
    //指定索引别名
    protected $alias = 'product_alias';
    //指定type
    protected $type = 'products';
    protected $setting = [...];
    protected $properties = [...];

}
// $id 必须为唯一id， $data为数据，会根据 $properties 自动剔除
Product::add($id, $data);
//删除
Product::delete($id);
//跟新数据
Product::update($id, $data);

注：暂时就这些简单的功能了