ElasticSearch全文搜索引擎

jerry thinkphp 2015年11月19日收藏

ElasticSearch全文搜索引擎，是一款很好的搜索框架！用来做网站的搜索，可以对数据库压力起到一定的缓解作用！
之前给大家带来的是用curl来实现的大家有兴趣可以看看
http://www.thinkphp.cn/topic/29297.html
今天这里给大家带来的是官网提供的 PHP API
整合thinkphp3.2

下载文件解压到
ThinkPHP\Library\Vendor\

<?php

namespace Home\Controller;


use Think\Controller;


class EcController extends Controller

{


    public function _initialize()

    {

        Vendor('Elasticsearch.autoload');

        $params['hosts'] = array(

            '127.0.0.1:9200'

        );

        $this->client = new \Elasticsearch\Client($params);

    }


    public function create_index()

    {

        $indexParams['index'] = 'my_index';

        $indexParams['type'] = 'my_index';

        $indexParams['body']['settings']['number_of_shards'] = 2;

        $indexParams['body']['settings']['number_of_replicas'] = 0;

        $this->client->create($indexParams);

    }


    public function add_document()

    {

        $params = array();

        $params['body'] = array(

            'testField' => 'dfdsfdsf'

        );

        $params['index'] = 'my_index';

        $params['type'] = 'my_index';

        $params['id'] = 'w1231313';

        $ret = $this->client->index($params);

    }


    public function delete_index()

    {

        $deleteParams['index'] = 'my_index';

        $this->client->indices()->delete($deleteParams);

    }


    public function delete_document()

    {

        $deleteParams = array();

        $deleteParams['index'] = 'my_index';

        $deleteParams['type'] = 'my_index';

        $deleteParams['id'] = 'AU4Kmmj-WOmOrmyOj2qf';

        $retDelete = $this->client->delete($deleteParams);

    }

    public function update_document()

    {

        $updateParams = array();

        $updateParams['index'] = 'my_index';

        $updateParams['type'] = 'my_index';

        $updateParams['id'] = 'my_id';

        $updateParams['body']['doc']['asas']  = '111111';

       $response = $this->client->update($updateParams);

         

    }

    public function search()

    {

        $searchParams['index'] = 'my_index';

        $searchParams['type'] = 'my_index';

        $searchParams['from'] = 0;

        $searchParams['size'] = 100;

        $searchParams['sort'] = array(

            '_score' => array(

                'order' => 'desc'

            )

        );

        // $searchParams['body']['query']['match']['testField'] = 'abc';

        $retDoc = $this->client->search($searchParams);

        print_r($retDoc);

    }


    public function get_document()

    {

        $getParams = array();

        $getParams['index'] = 'my_index';

        $getParams['type'] = 'my_index';

        $getParams['id'] = 'AU4Kn-knWOmOrmyOj2qg';

        $retDoc = $this->client->get($getParams);

        print_r($retDoc);

    }

}

?>