Slo

Author: Илья

slo-workload/src/Commands/RunCommand.php

@@ -185,7 +185,7 @@ protected function readJob(string $endpoint, string $path, $tableName, int $init
         $dataGenerator = new DataGenerator($initialDataCount);
         $query = sprintf(Defaults::READ_QUERY, $tableName);
         $table = $ydb->table();
-        $table->query("SELECT 1;");
+        $table->createSession();
 
         while (microtime(true) <= $startTime + $time) {
             $begin = microtime(true);
@@ -223,7 +223,7 @@ protected function writeJob(string $endpoint, string $path, $tableName, int $ini
         $dataGenerator = new DataGenerator($initialDataCount);
         $query = sprintf(Defaults::WRITE_QUERY, $tableName);
         $table = $ydb->table();
-        $table->query("SELECT 1;");
+        $table->createSession();
         while (microtime(true) <= $startTime + $time) {
             $begin = microtime(true);
             Utils::metricsStart("write", $this->queueId);