@@ -24,17 +24,17 @@ |
||
24 | 24 | { |
25 | 25 | if (isset($this->cluster)) { |
26 | 26 | if (isset($params['node'])) { |
27 | - return parent::setBody(['query' => "JOIN CLUSTER ".$this->cluster." AT '".$params['node']."'"]); |
|
27 | + return parent::setBody(['query' => "JOIN CLUSTER " . $this->cluster . " AT '" . $params['node'] . "'"]); |
|
28 | 28 | } else { |
29 | - $options =[]; |
|
29 | + $options = []; |
|
30 | 30 | if (isset($params['path'])) { |
31 | - $options[] = "'".$params['path']. "' AS path"; |
|
31 | + $options[] = "'" . $params['path'] . "' AS path"; |
|
32 | 32 | } |
33 | 33 | if (isset($params['nodes'])) { |
34 | - $options[] = "'".$params['nodes']. "' AS nodes"; |
|
34 | + $options[] = "'" . $params['nodes'] . "' AS nodes"; |
|
35 | 35 | } |
36 | - return parent::setBody(['query' => "JOIN CLUSTER ".$this->cluster. |
|
37 | - ((count($options)>0)?" ".implode(',', $options):"")]); |
|
36 | + return parent::setBody(['query' => "JOIN CLUSTER " . $this->cluster . |
|
37 | + ((count($options) > 0) ? " " . implode(',', $options) : "")]); |
|
38 | 38 | } |
39 | 39 | } |
40 | 40 | throw new RuntimeException('Cluster name is missing.'); |