diff --git a/src/Transport/Http.php b/src/Transport/Http.php index 34b984e..88ba18c 100644 --- a/src/Transport/Http.php +++ b/src/Transport/Http.php @@ -626,6 +626,10 @@ private function prepareWrite($sql, $bindings = []): CurlerRequest $query = $this->prepareQuery($sql, $bindings); + if (strpos($sql, 'ON CLUSTER') === false) { + return $this->getRequestWrite($query); + } + if (strpos($sql, 'CREATE') === 0 || strpos($sql, 'DROP') === 0 || strpos($sql, 'ALTER') === 0) { $query->setFormat('JSON'); }