first commit

Author: basemkhirat

.gitignore

@@ -0,0 +1,5 @@
+.idea/
+/vendor
+composer.lock
+.gitattributes
+.DS_Store

composer.json

@@ -0,0 +1,25 @@
+{
+    "name": "basemkhirat/elasticsearch",
+    "description": "Elasticsearch query builder",
+    "keywords": ["elasticsearch", "full text", "builder", "laravel"],
+    "license": "MIT",
+    "type": "package",
+    "authors": [
+        {
+            "name": "basemkhirat",
+            "email": "basemkhirat@gmail.com"
+        }
+    ],
+
+    "autoload": {
+        "psr-4" : {
+            "Basemkhirat\\Elasticsearch\\": "src/"
+        }
+    },
+
+    "require": {
+        "elasticsearch/elasticsearch": "5.0.0",
+        "illuminate/pagination": "*",
+        "illuminate/support": "*"
+    }
+}

readme.md

@@ -0,0 +1,190 @@
+### Flexible elasticseach builder to run complex queries with an easier way.
+
+#####1) Install package via composer:
+
+	composer require basemkhirat/elasticsearch
+
+#####2) Add package service provider:
+
+	Basemkhirat\Elasticsearch\ElasticsearchServiceProvider::class
+	
+#####3) Add package alias:
+
+	'ES' => Basemkhirat\API\Facades\ES::class
+	
+#####4) Publishing:
+    
+    php artisan vendor:publish --provider="Basemkhirat\Elasticsearch\ElasticsearchServiceProvider"
+	
+### Usage:
+
+#### Setting your connections
+
+  
+  After publishing, the config file is placed here `config/es.php`
+  where you can add more than one elasticsearch server.
+
+
+#### Running queries:
+
+    $documents = ES::connection("default")
+                    ->index("my_index")
+                    ->type("my_type")
+                    ->get();    // return collection of results
+
+you can rewite the above query to
+
+    $documents = ES::get();    // return collection of results
+    
+the query builder will use the default connection, index, and type names setted in configuration file `es.php`. 
+ 
+Index and type names setted in query will override values the configuration file
+
+#### Available methods:
+
+
+    // sorting
+    
+    $documents = ES::orderBy("created_at", "desc")->get();
+    $documents = ES::orderBy("_score")->get();
+    
+    // limit and offset
+    
+    $documents = ES::take(10)->skip(5)->get();
+    
+    // select only specific fields
+    
+    $documents = ES::select("title", "content")->take(10)->skip(5)->get();
+    
+    // where clause
+    
+    ES::where("id", 150)->get(); or ES::where("id", "=", 150)->get();
+    ES::where("id", ">", 150)->get();
+    ES::where("id", ">=", 150)->get();
+    ES::where("id", "<", 150)->get();
+    ES::where("id", "<=", 150)->get();
+    ES::where("title", "like", "foo")->get();
+    ES::where("hobbies", "exists", true)->get(); or ES::whereExists("hobbies", true)->get();
+    
+    // where in clause
+    
+    ES::whereIn("id", [100, 150])->get();
+    
+    // where between clause 
+    
+    ES::whereBetween("id", 100, 150)->get();
+   
+  -
+    
+    // where not clause
+    
+    ES::whereNot("id", 150)->get(); or ES::where("id", "=", 150)->get();
+    ES::whereNot("id", ">", 150)->get();
+    ES::whereNot("id", ">=", 150)->get();
+    ES::whereNot("id", "<", 150)->get();
+    ES::whereNot("id", "<=", 150)->get();
+    ES::whereNot("title", "like", "foo")->get();
+    ES::whereNot("hobbies", "exists", true)->get(); or ES::whereExists("hobbies", true)->get();
+    
+    // where not in clause
+    
+    ES::whereNotIn("id", [100, 150])->get();
+    
+    // where not between clause 
+    
+    ES::whereNotBetween("id", 100, 150)->get();
+    
+    
+  -
+  
+    // Search the entire document
+    
+    ES::search("bar")->get();
+    
+    
+  -
+  
+    // Return only first record
+    
+    ES::search("bar")->first();
+    
+  -
+  
+    // Return only count
+    
+    ES::search("bar")->count();
+    
+  -
+    
+    // paginate results with per_page = 5
+      
+    $documents = ES::search("bar")->paginate(5);
+    
+    // getting pagination links
+    
+    $documents->links();
+    
+    
+  -
+  
+    // Executing elasticsearch raw queries
+    
+    ES::raw()->search([
+        "index" => "my_index",
+        "type"  => "my_type",
+        "body"  => [
+             "query": [
+               "bool": [
+                 "must": [
+                   [ "match": [ "address": "mill" ] ],
+                   [ "match": [ "address": "lane" ] ] 
+                 ]
+               ]
+             ]
+           ]
+        ]);
+  
+  
+   -
+   
+    // insert a new document
+    
+    ES::insert([
+        "title" => "Test document",
+        "content" => "sample content"
+    ], 3);
+    
+    
+    A new document will be inserted with _id = 3.
+  
+    [id is optional] if not specified, a unique hash key will be generated 
+
+   
+   -
+   
+   // Update an existing document
+       
+    ES::update([
+       "title" => "Test document",
+       "content" => "sample content"
+    ], 3);
+        
+        
+    Document has _id = 3 will be updated.
+    
+    [id is required]
+    
+   -
+   
+   // delete a document
+       
+    ES::delete(3);
+        
+    Document has _id = 3 will be deleted.
+    
+    [id is required]
+    
+
+`Good luck`
+
+`Dont forget to send a feedback..`

src/Connection.php

@@ -0,0 +1,158 @@
+<?php
+
+namespace Basemkhirat\Elasticsearch;
+
+use Elasticsearch\ClientBuilder;
+
+/**
+ * Class Builder
+ * @package Basemkhirat\Elasticsearch\Builder
+ */
+class Connection
+{
+
+    /**
+     * Laravel app instance
+     * @var \Illuminate\Foundation\Application
+     */
+    protected $app;
+
+    /**
+     * Elastic config content
+     * @var
+     */
+    protected $config;
+
+    /**
+     * The current connection
+     * @var
+     */
+    protected $connection;
+
+    /**
+     * all available connections
+     * @var array
+     */
+    protected $connections = [];
+
+
+    /**
+     * Connection constructor.
+     */
+    function __construct()
+    {
+        $this->app = app();
+
+        $this->config = $this->app['config']['es'];
+    }
+
+
+    /**
+     * Create a connection
+     * @param $name
+     * @return Query
+     */
+    function connection($name)
+    {
+
+        // Check if connection is already loaded.
+
+        if ($this->isLoaded($name)) {
+
+            $this->connection = $this->connections[$name];
+
+            return $this->query($name);
+
+        }
+
+        // Create a new connection.
+
+        if (array_key_exists($name, $this->config["connections"])) {
+
+            $config = $this->config["connections"][$name];
+
+            // Instantiate a new ClientBuilder
+            $clientBuilder = ClientBuilder::create();
+
+            $clientBuilder->setHosts($this->config["connections"][$name]["servers"]);
+
+            // Build the client object
+            $connection = $clientBuilder->build();
+
+            $this->connection = $connection;
+
+            $this->connections[$name] = $connection;
+
+            return $this->query($name);
+        }
+
+        $this->app->abort(500, "Invalid elasticsearch connection driver `" . $name . "`");
+
+    }
+
+
+    /**
+     * route the request to query class
+     * @param $connection
+     * @return Query
+     */
+    function query($connection)
+    {
+
+        $config = $this->config["connections"][$connection];
+
+        $query = new Query($this->connections[$connection]);
+
+        if (array_key_exists("index", $config) and $config["index"] != "") {
+            $query->index($config["index"]);
+        }
+
+        if (array_key_exists("type", $config) and $config["type"] != "") {
+            $query->type($config["type"]);
+        }
+
+        return $query;
+
+    }
+
+    /**
+     * Check if the connection is already loaded
+     * @param $name
+     * @return bool
+     */
+    function isLoaded($name)
+    {
+
+        if (array_key_exists($name, $this->connections)) {
+            return true;
+        }
+
+        return false;
+
+    }
+
+
+    /**
+     * Set the default connection
+     * @param $name
+     * @param $arguments
+     * @return mixed
+     */
+    function __call($name, $arguments)
+    {
+        if (method_exists($this, $name)) {
+
+            return call_user_func_array([$this, $name], $arguments);
+
+        } else {
+
+            // if no connection, use default.
+
+            $query = $this->connection($this->config["default"]);
+
+            return call_user_func_array([$query, $name], $arguments);
+
+        }
+    }
+
+}