fixed ccat executable path

Author: FacedSID

src/Transport/ClickhouseCLIClientTransport.php

@@ -28,6 +28,13 @@ class ClickhouseCLIClientTransport implements TransportInterface
      */
     protected $catExecutablePath;
 
+    /**
+     * Path to executable ccat command
+     *
+     * @var string
+     */
+    protected $ccatExecutablePath;
+
     /**
      * Last execute query
      *
@@ -47,12 +54,14 @@ class ClickhouseCLIClientTransport implements TransportInterface
      *
      * @param string|null $executablePath
      * @param string|null $catExecutablePath
+     * @param string|null $ccatExecutablePath
      * @param bool        $useCcat
      */
-    public function __construct(string $executablePath = null, string $catExecutablePath = null, bool $useCcat = false)
+    public function __construct(string $executablePath = null, string $catExecutablePath = null, string $ccatExecutablePath = null, bool $useCcat = false)
     {
         $this->setExecutablePath($executablePath);
         $this->setCatExecutablePath($catExecutablePath);
+        $this->setCcatExecutablePath($ccatExecutablePath);
         $this->useCcat = $useCcat;
     }
 
@@ -84,6 +93,20 @@ protected function setCatExecutablePath(string $catExecutablePath = null)
         $this->catExecutablePath = $catExecutablePath;
     }
 
+    /**
+     * Set path to ccat executable.
+     *
+     * @param string|null $ccatExecutablePath
+     */
+    protected function setCcatExecutablePath(string $ccatExecutablePath = null)
+    {
+        if (is_null($ccatExecutablePath)) {
+            $ccatExecutablePath = 'ccat';
+        }
+
+        $this->ccatExecutablePath = $ccatExecutablePath;
+    }
+
     /**
      * Sends query to given $server.
      *
@@ -322,7 +345,7 @@ protected function buildCommandForWriteFilesAsOne(Server $server, string $query,
         $command = [];
 
         if ($this->useCcat) {
-            $command[] = $this->catExecutablePath.' '.$file.' | ';
+            $command[] = $this->ccatExecutablePath.' '.$file.' | ';
         } else {
             $command[] = '$('.$this->catExecutablePath.' '.$file.') | ';
         }