@@ -22,18 +22,18 @@ |
||
22 | 22 | public function setBody($params = null) |
23 | 23 | { |
24 | 24 | if (isset($this->_cluster)) { |
25 | - if(isset($params['node'])) { |
|
26 | - $this->_body = ['query' => "JOIN CLUSTER ".$this->_cluster." AT ".$params['node']]; |
|
27 | - }else{ |
|
28 | - $options =[]; |
|
29 | - if(isset($params['path'])) { |
|
30 | - $options[] = "'".$params['path']. "' AS path"; |
|
25 | + if (isset($params['node'])) { |
|
26 | + $this->_body = ['query' => "JOIN CLUSTER " . $this->_cluster . " AT " . $params['node']]; |
|
27 | + } else { |
|
28 | + $options = []; |
|
29 | + if (isset($params['path'])) { |
|
30 | + $options[] = "'" . $params['path'] . "' AS path"; |
|
31 | 31 | } |
32 | - if(isset($params['nodes'])) { |
|
33 | - $options[] = "'".$params['nodes']. "' AS nodes"; |
|
32 | + if (isset($params['nodes'])) { |
|
33 | + $options[] = "'" . $params['nodes'] . "' AS nodes"; |
|
34 | 34 | } |
35 | - $this->_body = ['query' => "JOIN CLUSTER ".$this->_cluster. |
|
36 | - ((count($options)>0)?" ".implode(',', $options):"")]; |
|
35 | + $this->_body = ['query' => "JOIN CLUSTER " . $this->_cluster . |
|
36 | + ((count($options) > 0) ? " " . implode(',', $options) : "")]; |
|
37 | 37 | } |
38 | 38 | |
39 | 39 | } |
@@ -24,7 +24,7 @@ |
||
24 | 24 | if (isset($this->_cluster)) { |
25 | 25 | if(isset($params['node'])) { |
26 | 26 | $this->_body = ['query' => "JOIN CLUSTER ".$this->_cluster." AT ".$params['node']]; |
27 | - }else{ |
|
27 | + } else{ |
|
28 | 28 | $options =[]; |
29 | 29 | if(isset($params['path'])) { |
30 | 30 | $options[] = "'".$params['path']. "' AS path"; |
@@ -24,7 +24,7 @@ |
||
24 | 24 | { |
25 | 25 | if (isset($this->_index)) { |
26 | 26 | |
27 | - return parent::setBody(['query' => "SHOW INDEX ".$this->_index. " STATUS".(isset($params['pattern'])?" LIKE '".$params['pattern']."'":"")]); |
|
27 | + return parent::setBody(['query' => "SHOW INDEX " . $this->_index . " STATUS" . (isset($params['pattern']) ? " LIKE '" . $params['pattern'] . "'" : "")]); |
|
28 | 28 | } |
29 | 29 | throw new RuntimeException('Index name is missing.'); |
30 | 30 | } |
@@ -19,7 +19,7 @@ |
||
19 | 19 | public function setBody($params = null) |
20 | 20 | { |
21 | 21 | if (isset($this->_index)) { |
22 | - return parent::setBody(['query' => "DESCRIBE ".$this->_index. " ".(isset($params['pattern'])?" LIKE '".$params['pattern']."'":"")]); |
|
22 | + return parent::setBody(['query' => "DESCRIBE " . $this->_index . " " . (isset($params['pattern']) ? " LIKE '" . $params['pattern'] . "'" : "")]); |
|
23 | 23 | |
24 | 24 | } |
25 | 25 | throw new RuntimeException('Index name is missing.'); |
@@ -13,9 +13,9 @@ |
||
13 | 13 | */ |
14 | 14 | protected $_index; |
15 | 15 | |
16 | - public function setBody( $params = null) |
|
16 | + public function setBody($params = null) |
|
17 | 17 | { |
18 | - if(isset( $this->_index)) { |
|
18 | + if (isset($this->_index)) { |
|
19 | 19 | return parent::setBody(['query' => "DROP TABLE " . $this->_index]); |
20 | 20 | } |
21 | 21 | throw new RuntimeException('Missing index name in /indices/drop'); |
@@ -23,7 +23,7 @@ |
||
23 | 23 | public function setBody($params = null) |
24 | 24 | { |
25 | 25 | if (isset($this->_index)) { |
26 | - return parent::setBody(['query' => "OPTIMIZE INDEX ".$this->_index. "".(isset($params['sync'])?" OPTION sync='".$params['sync']."'":"")]); |
|
26 | + return parent::setBody(['query' => "OPTIMIZE INDEX " . $this->_index . "" . (isset($params['sync']) ? " OPTION sync='" . $params['sync'] . "'" : "")]); |
|
27 | 27 | } |
28 | 28 | throw new RuntimeException('Index name is missing.'); |
29 | 29 | } |
@@ -20,7 +20,7 @@ |
||
20 | 20 | { |
21 | 21 | |
22 | 22 | if (isset($this->_index)) { |
23 | - return parent::setBody(['query' => "FLUSH RAMCHUNK".$this->_index]); |
|
23 | + return parent::setBody(['query' => "FLUSH RAMCHUNK" . $this->_index]); |
|
24 | 24 | } |
25 | 25 | throw new RuntimeException('Index name is missing.'); |
26 | 26 | } |
@@ -24,7 +24,7 @@ |
||
24 | 24 | { |
25 | 25 | if (isset($this->_index)) { |
26 | 26 | |
27 | - return parent::setBody(['query' => "SHOW INDEX ".$this->_index. " SETTINGS"]); |
|
27 | + return parent::setBody(['query' => "SHOW INDEX " . $this->_index . " SETTINGS"]); |
|
28 | 28 | } |
29 | 29 | throw new RuntimeException('Index name is missing.'); |
30 | 30 | } |
@@ -23,7 +23,7 @@ |
||
23 | 23 | public function setBody($params = null) |
24 | 24 | { |
25 | 25 | if (isset($this->_index)) { |
26 | - return parent::setBody(['query' => "TRUNCATE RTINDEX ".$this->_index. "".(isset($params['with'])?" WITH'".strtoupper($params['with'])."'":"")]); |
|
26 | + return parent::setBody(['query' => "TRUNCATE RTINDEX " . $this->_index . "" . (isset($params['with']) ? " WITH'" . strtoupper($params['with']) . "'" : "")]); |
|
27 | 27 | } |
28 | 28 | throw new RuntimeException('Index name is missing.'); |
29 | 29 | } |
@@ -20,7 +20,7 @@ |
||
20 | 20 | { |
21 | 21 | |
22 | 22 | if (isset($this->_index)) { |
23 | - return parent::setBody(['query' => "FLUSH RTINDEX ".$this->_index]); |
|
23 | + return parent::setBody(['query' => "FLUSH RTINDEX " . $this->_index]); |
|
24 | 24 | } |
25 | 25 | throw new RuntimeException('Index name is missing.'); |
26 | 26 | } |