@@ -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.'); |