@@ -34,6 +34,9 @@ discard block |
||
| 34 | 34 | { |
| 35 | 35 | } |
| 36 | 36 | |
| 37 | + /** |
|
| 38 | + * @param string $collection |
|
| 39 | + */ |
|
| 37 | 40 | public function drop($collection) |
| 38 | 41 | { |
| 39 | 42 | $params = ['index' => $this->index]; |
@@ -54,6 +57,9 @@ discard block |
||
| 54 | 57 | { |
| 55 | 58 | } |
| 56 | 59 | |
| 60 | + /** |
|
| 61 | + * @param string $collection |
|
| 62 | + */ |
|
| 57 | 63 | public function insert($collection, $values) |
| 58 | 64 | { |
| 59 | 65 | $params = []; |
@@ -71,6 +77,9 @@ discard block |
||
| 71 | 77 | } |
| 72 | 78 | } |
| 73 | 79 | |
| 80 | + /** |
|
| 81 | + * @param string $collection |
|
| 82 | + */ |
|
| 74 | 83 | public function get($collection, $docId) |
| 75 | 84 | { |
| 76 | 85 | $params = []; |
@@ -112,6 +121,9 @@ discard block |
||
| 112 | 121 | } |
| 113 | 122 | } |
| 114 | 123 | |
| 124 | + /** |
|
| 125 | + * @param string $collection |
|
| 126 | + */ |
|
| 115 | 127 | public function update($collection, $filter, $values) |
| 116 | 128 | { |
| 117 | 129 | $docs = $this->find($collection, $filter, ['_id']); |
@@ -138,6 +150,9 @@ discard block |
||
| 138 | 150 | return $modified_count; |
| 139 | 151 | } |
| 140 | 152 | |
| 153 | + /** |
|
| 154 | + * @param string $collection |
|
| 155 | + */ |
|
| 141 | 156 | public function delete($collection, $filter) |
| 142 | 157 | { |
| 143 | 158 | if (isset($filter['_id'])) { |
@@ -178,6 +193,9 @@ discard block |
||
| 178 | 193 | return 0; |
| 179 | 194 | } |
| 180 | 195 | |
| 196 | + /** |
|
| 197 | + * @param string[] $fields |
|
| 198 | + */ |
|
| 181 | 199 | public function find($collection, $filters, $fields = null, $sort = null, $start = 0, $limit = 25, $debug = false) |
| 182 | 200 | { |
| 183 | 201 | $return_type = '_source'; |
@@ -275,6 +293,9 @@ discard block |
||
| 275 | 293 | return $filters; |
| 276 | 294 | } |
| 277 | 295 | |
| 296 | + /** |
|
| 297 | + * @param string $is_not |
|
| 298 | + */ |
|
| 278 | 299 | private static function buildFilterForKeys($key, $value, $is_not) |
| 279 | 300 | { |
| 280 | 301 | $filters = []; |
@@ -4,7 +4,7 @@ |
||
| 4 | 4 | /* |
| 5 | 5 | Elasticsearch Adapter |
| 6 | 6 | */ |
| 7 | -Use Elasticsearch as ElasticsearchLib; |
|
| 7 | +use Elasticsearch as ElasticsearchLib; |
|
| 8 | 8 | |
| 9 | 9 | class ElasticSearch implements Base |
| 10 | 10 | { |