1.   本网站所有源码包解压密码:www.youhutong.com
会员登录  帮助问答

Composer安装和使用教程 - Windows版( PHP 的一个依赖管理工具)

小川 PHP

Composer安装教程 - Windows

1、下载Composer: Composer-Setup.exe 。然后运行就行了。唯一注意的就是安装时要选择php.exe   

  

        这是安装Composer 最简单的方法,

        它将安装最新版本的 Composer ,并设置好系统的环境变量。

        因此你可以在任何目录下    直接使用 composer 命令。


Composer使用教程

案例1:用Composer来生成php版的elasticsearch框架

1、声明依赖关系:

        比方说,你的项目中需要一个php版的elasticsearch框架。为了将它添加到你的项目中(下载),你所需要做的就是创建一个 composer.json 文件,其中描述了项目的依赖关系。注意文件要放在你执行composer命令的目录中

{
	"require":{
		"elasticsearch/elasticsearch":"~2.0"
	}
}


2、cmd切换到要下载elasticsearch框架的目录,然后执行命令:composer install

     如有出错误信息:

      [Composer\Downloader\TransportException]

      Content-Length mismatch, received 583439 bytes out of the expected 1215108

     解决办法:切换国内镜像地址,再执行操作

      1、通过命令切换如下:(最终修改的是composer.json

      composer config -g repo.packagist composer https://packagist.phpcomposer.com

      2、直接修改 composer.json (其实跟方法1是一样的。

{
	"require":{
		"elasticsearch/elasticsearch":"~2.0"
	},
	"repositories": {
		"packagist": {
			"type": "composer",
			"url": "https://packagist.phpcomposer.com"
		}
	}
}


001.png


3、PHP使用:


下面我们讲一下基本使用方法,需要获取更多使用教程和方法请看官方文档:https://www.elastic.co/guide/en/elasticsearch/client/php-api/current/_overview.html


想直接通过文件查看其他方法可以打开以下文件查看(基本使用的方法都在里面):

1、\elasticsearch\src\Elasticsearch\Client.php中的方法

2、\elasticsearch\Namespaces\IndicesNamespace.php中的方法



ThinkPHP用法:

<?php
/**
 * Elasticsearch检索引擎模型
 */
namespace app\index\model;
use Elasticsearch\ClientBuilder;  
  
class Elasticsearch
{
    //配置
    private $config = [
        'hosts' => ['http://127.0.0.1:9200']
    ];
    private $api;
    public function __construct()
    {
        #include(APP_PATH .'/vendor/autoload.php');
        #require_once EXTEND_PATH . 'org/elasticsearch/autoload.php';
        import('org.elasticsearch.autoload', EXTEND_PATH);
        $this->api = ClientBuilder::create()->setHosts($this->config['hosts'])->build(); 
    }

    /*************************************************************
    /**
     * 索引一个文档
     * 说明:索引没有被创建时会自动创建索引
     */
    public function addOne()
    {
        $params = [];  
		$params['index'] = 'xiaochuan';  
		$params['type']  = 'cat';  
		$params['id']  = '20180407001';  # 不指定就是es自动分配
		$params['body']  = array('name' => '小川编程');  
		return $this->api->index($params);
    }

    /**
     * 索引多个文档
     * 说明:索引没有被创建时会自动创建索引
     */
    public function addAll()
    {
    	$params = [];
        for($i = 1; $i < 21; $i++) {  
		    $params['body'][] = [
		        'index' => [
					'_index' => 'test_index'.$i,
					'_type'  => 'cat_test',
					'_id'	 => $i,
				]
		    ];  
		    $params['body'][] = [  
		        'name' => '小川编程'.$i,  
		        'content' => '内容'.$i  
		    ];
		}  
		return $this->api->bulk($params);  
    }

    /**
     * 获取一个文档
     */
    public function getOne()
    {
    	$params = [];  
		$params['index'] = 'xiaochuan';  
		$params['type']  = 'cat';  
		$params['id']    = '20180407001';  
		return $this->api->get($params); 
    }

    /**
     * 搜索文档
     */
    public function search()
    {
    	$params = [];
    	$params['index'] = 'xiaochuan';  
		$params['type']  = 'cat';  
		$params['body']['query']['match']['name'] = '小川编程';  
		return $this->api->search($params); 
    }

    /**
     * 删除文档
     * 说明:文档删除后,不会删除对应索引。
     */
    public function delete()
    {
    	$params = [];  
		$params['index'] = 'xiaochuan';  
		$params['type'] = 'cat';  
		$params['id'] = '20180407001';  
		return $this->api->delete($params);  
    }

    /*************************************************************
    /**
     * 创建索引
     */
    public function createIndex()
    {
    	$params = [];
		$params['index']  = 'xiaochuan'; 
		return $this->api->indices()->create($params);  
    }
  	
  	/**
     * 删除索引:匹配单个 | 匹配多个
     * 说明: 索引删除后,索引下的所有文档也会被删除
     */
  	public function deleteIndex()
  	{	
  		$params = [];
  		$params['index'] = 'test_index';  # 删除test_index单个索引
  		#$params['index'] = 'test_index*'; # 删除以test_index开始的所有索引
		return $this->api->indices()->delete($params);  
  	}

  	/*************************************************************
  	/**
     * 设置索引配置
     */
  	public function setIndexConfig()
  	{	
  		$params = [];
  		$params['index'] = 'xiaochuan';  
		$params['body']['index']['number_of_replicas'] = 0;  
		$params['body']['index']['refresh_interval'] = -1;  
		return $this->api->indices()->putSettings($params);  
  	}

  	/**
     * 获取索引配置
     */
  	public function getIndexConfig()
  	{
  		# 单个获取条件写法
		$params['index'] = 'xiaochuan';  
		# 多个获取条件写法
		//$params['index'] = ['xiaochuan', 'test_index'];  
		return $this->api->indices()->getSettings($params);  
  	}

	/**
     * 设置索引映射
     */
  	public function setIndexMapping()
  	{
  		#  设置索引和类型 
		$params['index'] = 'xiaochuan';  
		$params['type']  = 'cat';  
		  
		#  向现有索引添加新类型
		$myTypeMapping = array(  
		    '_source' => array(  
		        'enabled' => true  
		    ),  
		    'properties' => array(  
		        'first_name' => array(  
		            'type' => 'string',  
		            'analyzer' => 'standard'  
		        ),  
		        'age' => array(  
		            'type' => 'integer'  
		        )  
		    )  
		);  
		$params['body']['cat'] = $myTypeMapping;  
		  
		#  更新索引映射 
		$this->api->indices()->putMapping($params);  
  	}

  	/**
     * 获取索引映射
     */
  	public function getIndexMapping()
  	{	
  		#  获取所有索引和类型的映射  
		$ret = $this->api->indices()->getMapping();  
		
		/*  
		#  获取索引为:xiaochuan的映射
		$params['index'] = 'xiaochuan';  
		$ret = $this->api->indices()->getMapping($params);  
		  
		#  获取类型为:cat的映射
		$params['type'] = 'cat';  
		$ret = $this->api->indices()->getMapping($params);  
		  
		#  获取(索引为:xiaochuan和 类型为:cat)的映射
		$params['index'] = 'xiaochuan';  
		$params['type']  = 'cat'  
		$ret = $this->api->indices()->getMapping($params);  
		  
		#  获取索引为:xiaochuan和test_index的映射
		$params['index'] = ['xiaochuan', 'test_index'];  
		$ret = $this->api->indices()->getMapping($params); 
		*/

		return $ret;
  	}


}


其他形式用法测试:

test.php

<?php   
require_once('vendor/autoload.php');  
use Elasticsearch\ClientBuilder;  
  
  
function get_conn(){  
    $host = 'localhost';  
    $dbname = 'mraz';  
    $user = 'root';  
    $passwd = '111111';  
  
  
    $conn = new PDO("mysql:dbname=$dbname;host=$host",$user,$passwd);  
    return $conn;  
}  
  
  
function create_index(){  
    //Elastic search php client  
  
  
  
  
    $client = Elasticsearch\ClientBuilder::create()->build();  
    $sql    = "SELECT * FROM emp";  
    $conn   = get_conn();  
    $stmt   = $conn->query($sql);  
    $rtn    = $stmt->fetchAll();  
  
  
    //delete index which already created  
    $params = array();  
    $params['index'] = 'emp_index';  
    $client->indices()->delete($params);  
      
    //create index on log_date,src_ip,dest_ip  
    $rtnCount = count($rtn);  
    for($i=0;$i<$rtnCount;$i++){  
        $params = array();  
        $params['body'] = array(  
            'id'       => $rtn[$i]['id'],  
            'fdName'   => $rtn[$i]['fdName'],  
            'fdAge'    => $rtn[$i]['fdAge'],  
            'fdStatus' => $rtn[$i]['fdStatus']  
        );  
        $params['index'] = 'emp_index';  
        $params['type']  = 'emp_type';  
          
        //Document will be indexed to log_index/log_type/autogenerate_id          
        $client->index($params);  
    }  
    echo 'create index done!';  
}  
  
  
function search(){  
    //Elastic search php client  
    $client = Elasticsearch\ClientBuilder::create()->build();  
    $params = array();  
    $params['index'] = 'emp_index';  
    $params['type'] = 'emp_type';  
    $params['body']['query']['match']['fdStatus'] = '1';  
    $params['body']['sort'] = array('fdAge'=>array('order'=>'desc'));  
    $params['size'] = 3;    
    $params['from'] = 1;    
    $rtn = $client->search($params);  
    var_dump($rtn);  
}  
  
  
set_time_limit(0);  
// create_index();  
search();  
?>


1)创建:

include('./vendor/autoload.php');  
$elastic = new Elasticsearch\Client();  
$index['index'] = 'log';  //索引名称  
$index['type'] = 'ems_run_log'; //类型名称  
$data['body']['settings']['number_of_shards'] = 5;  //主分片数量  
$data['body']['settings']['number_of_replicas'] = 0; //从分片数量  
$elastic->indices()->create($index);

2)插入索引数据:

include('./vendor/autoload.php');  
$elastic = new Elasticsearch\Client();  
$index['index'] = 'log'; //索引名称  
$index['type'] = 'ems_run_log'; //类型名称  
$index['id'] = 1   //不指定id,系统会自动生成唯一id  
$index['body'] = array(  
  'mac' => 'fcd5d900beca',  
  'customer_id' => 3,  
  'product_id' => 5,  
  'version' => 2  
);  
$elastic->index($index);

3)查询:

include('./vendor/autoload.php');  
$elastic = new Elasticsearch\Client();  
$index['index'] = 'log'; //索引名称  
$index['type'] = 'ems_run_log'; //类型名称  
$index['body']['query']['match']['mac'] = 'fcd5d900beca';  
$index['size'] = 10;  
$index['from'] = 200;  
$elastic->search($index);  

#相当于sql语句:select*from ems_run_log where mac='fcd5d900beca' limit 200,10;
include('./vendor/autoload.php');  
$elastic = new Elasticsearch\Client();  
$index['index'] = 'log'; //索引名称  
$index['type'] = 'ems_run_log'; //类型名称  
$index['body']['query']['bool']['must'] = array(  
    array('match' => array('mac' => 'fcd5d900beca')),  
    array('match' => array('product_id' => 20))  
   );  
$index['size'] = 10;  
$index['from'] = 200;  
$elastic->search($index);  

#相当于sql语句:select*from ems_run_log where mac='fcd5d900beca' and product_id=20 limit 200,10;
include('./vendor/autoload.php');  
$elastic = new Elasticsearch\Client();  
$index['index'] = 'log'; //索引名称  
$index['type'] = 'ems_run_log'; //类型名称  
$index['body']['query']['bool']['should'] = array(  
      array('match' => array('mac' => 'fcd5d900beca')),  
      array('match' => array('product_id' => 20))  
     );  
$index['size'] = 10;  
$index['from'] = 200;  
$elastic->search($index);  

#当于sql语句:select*from ems_run_log where mac='fcd5d900beca' or product_id=20 limit 200,10;
include('./vendor/autoload.php');  
$elastic = new Elasticsearch\Client();  
$index['index'] = 'log'; //索引名称  
$index['type'] = 'ems_run_log'; //类型名称  
$index['body']['query']['bool']['must_not'] = array(  
   array('match' => array('mac' => 'fcd5d900beca')),  
   array('match' => array('product_id' => 20))  
  );  
$index['size'] = 10;  
$index['from'] = 200;  
$elastic->search($index);  

#相当于sql语句:select*from ems_run_log where mac!='fcd5d900beca' and product_id!=20 limit 200,10;
include('./vendor/autoload.php');  
$elastic = new Elasticsearch\Client();  
$index['index'] = 'log'; //索引名称  
$index['type'] = 'ems_run_log'; //类型名称  
$index['body']['query']['range'] = array(  
   'id' => array('gte' => 20,'lt' => 30);  
 );  
$index['size'] = 10;  
$index['from'] = 200;  
$elastic->search($index);  

#相当于sql语句:select*from ems_run_log where id>=20 and id<30  limit 200,10;

4删除文档:

include('./vendor/autoload.php');  
$elastic = new Elasticsearch\Client();  
$index['index'] = 'test';  //索引名称  
$index['type'] = 'ems_test'; //类型名称  
$index['id'] = 2;   
$elastic->delete($index);


升级为VIP会员,有效期内免费下载本站所有VIP源码  点击升级为VIP

转载请注明来源地址:小川编程 » http://www.youhutong.com/index.php/article/index/211.html

( 0 )个小伙伴在吐槽
    登录帐号  如果已经登录请刷新! 发表我的评论
    表情