Remove Protobuf dependency

Author: Илья

src/QueryResult.php

@@ -3,6 +3,7 @@
 namespace YdbPlatform\Ydb;
 
 use DateTime;
+use YdbPlatform\Ydb\QueryStats\QueryStats;
 
 class QueryResult
 {

src/QueryStats.php

@@ -0,0 +1,40 @@
+<?php
+
+namespace YdbPlatform\Ydb\QueryStats;
+
+class CompilationStats
+{
+    /**
+     * @var \Ydb\TableStats\CompilationStats
+     */
+    protected $compilationStats;
+
+    public function __construct(\Ydb\TableStats\CompilationStats $compilationStats)
+    {
+        $this->compilationStats = $compilationStats;
+    }
+
+    /**
+     * @return bool
+     */
+    public function getFromCache(): bool
+    {
+        return $this->compilationStats->getFromCache();
+    }
+
+    /**
+     * @return int|string
+     */
+    public function getDurationUs()
+    {
+        return $this->compilationStats->getDurationUs();
+    }
+
+    /**
+     * @return int|string
+     */
+    public function getCpuTimeUs()
+    {
+        return $this->compilationStats->getCpuTimeUs();
+    }
+}

src/QueryStats/CompilationStats.php

@@ -0,0 +1,28 @@
+<?php
+
+namespace YdbPlatform\Ydb\QueryStats;
+
+class OperationStats
+{
+
+    public function __construct(\Ydb\TableStats\OperationStats $operationStats)
+    {
+        $this->operationStats = $operationStats;
+    }
+
+    /**
+     * @return int|string
+     */
+    public function getRows()
+    {
+        return $this->operationStats->getRows();
+    }
+
+    /**
+     * @return int|string
+     */
+    public function getBytes()
+    {
+        return $this->operationStats->getBytes();
+    }
+}

src/QueryStats/OperationStats.php

@@ -0,0 +1,61 @@
+<?php
+
+namespace YdbPlatform\Ydb\QueryStats;
+
+class QueryPhaseStats
+{
+    /**
+     * @var \Ydb\TableStats\QueryPhaseStats
+     */
+    protected $phaseStats;
+
+    public function __construct(\Ydb\TableStats\QueryPhaseStats $phaseStats)
+    {
+        $this->phaseStats = $phaseStats;
+    }
+
+
+    /**
+     * @return int|string
+     */
+    public function getDurationUs()
+    {
+        return $this->phaseStats->getDurationUs();
+    }
+
+    /**
+     * @return TableAccessStats[]
+     */
+    public function getTableAccess()
+    {
+        $result = iterator_to_array($this->phaseStats->getTableAccess());
+        foreach ($result as $key=>$item) {
+            $result[$key] = new TableAccessStats($item);
+        }
+        return $result;
+    }
+
+    /**
+     * @return int|string
+     */
+    public function getCpuTimeUs()
+    {
+        return $this->phaseStats->getCpuTimeUs();
+    }
+
+    /**
+     * @return int|string
+     */
+    public function getAffectedShards()
+    {
+        return $this->phaseStats->getAffectedShards();
+    }
+
+    /**
+     * @return bool
+     */
+    public function getLiteralPhase()
+    {
+        return $this->phaseStats->getLiteralPhase();
+    }
+}

src/QueryStats/QueryPhaseStats.php

@@ -0,0 +1,78 @@
+<?php
+
+namespace YdbPlatform\Ydb\QueryStats;
+
+class QueryStats
+{
+
+    protected $queryStats;
+    public function __construct(\Ydb\TableStats\QueryStats $queryStats)
+    {
+        $this->queryStats = $queryStats;
+    }
+
+    /**
+     * @return QueryPhaseStats[]
+     */
+    public function getQueryPhases()
+    {
+        $result = iterator_to_array($this->queryStats->getQueryPhases()->getIterator());
+        foreach ($result as $key=>$item) {
+            $result[$key] = new QueryPhaseStats($item);
+        }
+        return $result;
+    }
+
+    /**
+     * @return CompilationStats|null
+     */
+    public function getCompilation(): ?CompilationStats
+    {
+        if($this->queryStats->getQueryPhases()){
+            return new CompilationStats($this->queryStats->getCompilation());
+        } else {
+            return null;
+        }
+    }
+
+    /**
+     * @return int|string
+     */
+    public function getProcessCpuTimeUs()
+    {
+        return $this->queryStats->getProcessCpuTimeUs();
+    }
+
+    /**
+     * @return string
+     */
+    public function getQueryPlan(): string
+    {
+        return $this->queryStats->getQueryPlan();
+    }
+
+    /**
+     * @return string
+     */
+    public function getQueryAst(): string
+    {
+        return $this->queryStats->getQueryAst();
+    }
+
+    /**
+     * @return int|string
+     */
+    public function getTotalDurationUs()
+    {
+        return $this->queryStats->getTotalDurationUs();
+    }
+
+    /**
+     * @return int|string
+     */
+    public function getTotalCpuTimeUs()
+    {
+        return $this->queryStats->getTotalCpuTimeUs();
+    }
+
+}

src/QueryStats/QueryStats.php

@@ -0,0 +1,95 @@
+<?php
+namespace YdbPlatform\Ydb\QueryStats;
+class TableAccessStats
+{
+
+    /**
+     * @var \Ydb\TableStats\TableAccessStats
+     */
+    protected $accessStats;
+
+    public function __construct(\Ydb\TableStats\TableAccessStats $accessStats)
+    {
+        $this->accessStats = $accessStats;
+    }
+
+    /**
+     * @return string
+     */
+    public function getName()
+    {
+        return $this->accessStats->getName();
+    }
+
+    /**
+     * @return OperationStats|null
+     */
+    public function getReads()
+    {
+        $result = $this->accessStats->getReads();
+        if ($result){
+            $result = new OperationStats($result);
+        }
+        return $result;
+    }
+
+    public function hasReads()
+    {
+        return $this->accessStats->hasReads();
+    }
+
+    public function clearReads()
+    {
+        $this->accessStats->clearReads();
+    }
+
+    /**
+     * @return OperationStats|null
+     */
+    public function getUpdates()
+    {
+        $result = $this->accessStats->getUpdates();
+        if ($result){
+            $result = new OperationStats($result);
+        }
+        return $result;
+    }
+
+    public function hasUpdates()
+    {
+        return $this->accessStats->hasUpdates();
+    }
+
+    public function clearUpdates()
+    {
+        $this->accessStats->clearUpdates();
+    }
+
+
+    /**
+     * @return \Ydb\TableStats\OperationStats|null
+     */
+    public function getDeletes()
+    {
+        return $this->accessStats->getDeletes();
+    }
+
+    public function hasDeletes()
+    {
+        return $this->accessStats->hasDeletes();
+    }
+
+    public function clearDeletes()
+    {
+        $this->accessStats->clearDeletes();
+    }
+
+    /**
+     * @return int|string
+     */
+    public function getPartitionsCount()
+    {
+        return $this->accessStats->getPartitionsCount();
+    }
+}
+