Skip to content
This repository has been archived by the owner on Aug 6, 2022. It is now read-only.

Update elasticsearch.php #10

Open
wants to merge 1 commit into
base: master
Choose a base branch
from
Open

Update elasticsearch.php #10

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
63 changes: 33 additions & 30 deletions application/libraries/elasticsearch.php
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,9 +16,9 @@ class ElasticSearch
public function __construct()
{
$ci = &get_instance();
$ci -> config -> load("elasticsearch");
$this -> server = $ci -> config -> item('es_server');
$this -> index = $ci -> config -> item('index');
$ci->config->load("elasticsearch");
$this->server = $ci->config->item('es_server');
$this->index = $ci->config->item('index');
}
/**
* Handling the call for every function with curl
Expand All @@ -33,11 +33,11 @@ public function __construct()

private function call($path, $method = 'GET', $data = null)
{
if (!$this -> index) {
if (!$this->index) {
throw new Exception('$this->index needs a value');
}

$url = $this -> server . '/' . $this -> index . '/' . $path;
$url = $this->server . '/' . $this->index . '/' . $path;

$headers = array('Accept: application/json', 'Content-Type: application/json', );

Expand Down Expand Up @@ -75,15 +75,18 @@ private function call($path, $method = 'GET', $data = null)
* create a index with mapping or not
*
* @param json $map
*
* @return array
*/

public function create($map = false)
{
if (!$map) {
$this -> call(null, 'PUT');
} else {
$this -> call(null, 'PUT', $map);
}
if (!$map)
{
return $this->_call(null, 'PUT');
}

return $this->_call(null, 'PUT', $map);
}

/**
Expand All @@ -94,7 +97,7 @@ public function create($map = false)

public function status()
{
return $this -> call('_status');
return $this->call('_status');
}

/**
Expand All @@ -107,7 +110,7 @@ public function status()

public function count($type)
{
return $this -> call($type . '/_count?' . http_build_query(array(null => '{matchAll:{}}')));
return $this->call($type . '/_count?' . http_build_query(array(null => '{matchAll:{}}')));
}

/**
Expand All @@ -121,7 +124,7 @@ public function count($type)

public function map($type, $data)
{
return $this -> call($type . '/_mapping', 'PUT', $data);
return $this->call($type . '/_mapping', 'PUT', $data);
}

/**
Expand All @@ -136,7 +139,7 @@ public function map($type, $data)

public function add($type, $id, $data)
{
return $this -> call($type . '/' . $id, 'PUT', $data);
return $this->call($type . '/' . $id, 'PUT', $data);
}

/**
Expand All @@ -150,7 +153,7 @@ public function add($type, $id, $data)

public function delete($type, $id)
{
return $this -> call($type . '/' . $id, 'DELETE');
return $this->call($type . '/' . $id, 'DELETE');
}

/**
Expand All @@ -164,7 +167,7 @@ public function delete($type, $id)

public function query($type, $q)
{
return $this -> call($type . '/_search?' . http_build_query(array('q' => $q)));
return $this->call($type . '/_search?' . http_build_query(array('q' => $q)));
}

/**
Expand All @@ -178,7 +181,7 @@ public function query($type, $q)

public function advancedquery($type, $query)
{
return $this -> call($type . '/_search', 'POST', $query);
return $this->call($type . '/_search', 'POST', $query);
}

/**
Expand All @@ -193,7 +196,7 @@ public function advancedquery($type, $query)

public function query_wresultSize($type, $query, $size = 999)
{
return $this -> call($type . '/_search?' . http_build_query(array('q' => $q, 'size' => $size)));
return $this->call($type . '/_search?' . http_build_query(array('q' => $query, 'size' => $size)));
}

/**
Expand All @@ -207,7 +210,7 @@ public function query_wresultSize($type, $query, $size = 999)

public function get($type, $id)
{
return $this -> call($type . '/' . $id, 'GET');
return $this->call($type . '/' . $id, 'GET');
}

/**
Expand All @@ -220,30 +223,30 @@ public function get($type, $id)

public function query_all($query)
{
return $this -> call('_search?' . http_build_query(array('q' => $query)));
return $this->call('_search?' . http_build_query(array('q' => $query)));
}

/**
* get similar indexes for one index specified by id - send data to add filters or more
*
* @param string $type
* @param integer $id
* @param string $fields
* @param string $data
* @param string $type
* @param integer $id
* @param string|bool $fields
* @param string|bool $data
*
* @return array
*/

public function morelikethis($type, $id, $fields = false, $data = false)
{
if ($data != false && !$fields) {
return $this -> call($type . '/' . $id . '/_mlt', 'GET', $data);
return $this->call($type . '/' . $id . '/_mlt', 'GET', $data);
} else if ($data != false && $fields != false) {
return $this -> call($type . '/' . $id . '/_mlt?' . $fields, 'POST', $data);
return $this->call($type . '/' . $id . '/_mlt?' . $fields, 'POST', $data);
} else if (!$fields) {
return $this -> call($type . '/' . $id . '/_mlt');
return $this->call($type . '/' . $id . '/_mlt');
} else {
return $this -> call($type . '/' . $id . '/_mlt?' . $fields);
return $this->call($type . '/' . $id . '/_mlt?' . $fields);
}
}

Expand All @@ -257,7 +260,7 @@ public function morelikethis($type, $id, $fields = false, $data = false)
*/
public function query_all_wresultSize($query, $size = 999)
{
return $this -> call('_search?' . http_build_query(array('q' => $query, 'size' => $size)));
return $this->call('_search?' . http_build_query(array('q' => $query, 'size' => $size)));
}

/**
Expand All @@ -269,7 +272,7 @@ public function query_all_wresultSize($query, $size = 999)
*/
public function suggest($query)
{
return $this -> call('_suggest', 'POST', $query);
return $this->call('_suggest', 'POST', $query);
}

}