Rollback Timestamp

Author: ilyakharev

src/QueryResult.php

@@ -194,9 +194,7 @@ protected function fillRows($rows)
                         break;
 
                     case 'TIMESTAMP':
-                        $_row[$column['name']] = is_numeric($value) ?
-                            (DateTime::createFromFormat("U.u", $value/1000000 .".".str_pad($value%1000000,6,"0", STR_PAD_LEFT)))->format('Y-m-d H:i:s.u')
-                            : $value;
+                        $_row[$column['name']] = is_numeric($value) ? date('Y-m-d H:i:s', $value/1000000) : $value;
                         break;
 
                     case 'DATETIME':

src/Types/TimestampType.php

@@ -11,8 +11,6 @@ class TimestampType extends DatetimeType
     protected $ydb_key_name = "uint64_value";
 
     protected $ydb_type = "TIMESTAMP";
-
-    protected static $datetime_format = 'Y-m-d\TH:i:s.u\Z';
     /**
      * @inherit
      */
@@ -27,8 +25,6 @@ protected function getYqlString()
     protected function getYdbValue()
     {
         $value = new DateTime($this->value);
-        $x = ($value->format("U")."000000");
-        $y = $value->format("u");
-        return $x+$y;
+        return $value->getTimestamp() * 1000000;
     }
 }

tests/CheckTypeTest.php

@@ -149,17 +149,40 @@ public function test(){
                     "2023-06-14 17:12:15"
                 ]
             ],
-//            "Timestamp" => [
-//                "class"     => TimestampType::class,
-//                "values"    => [
-//                    new TimestampType(43578634985)
-//                ]
-//            ]
+            "Timestamp" => [
+                "class"     => TimestampType::class,
+                "values"    => [
+                    "2023-06-14 17:12:15"
+                ]
+            ]
         ];
 
         $ydb = new Ydb($config);
         $table = $ydb->table();
         $session = $table->createSession();
+
+
+        $query = "DECLARE \$v as Struct<x:Int32>; SELECT \$v as val;";
+        $prepared = $session->prepare($query);
+        $result = $prepared->execute([
+            'v' => ["x"=>2],
+        ]);
+        print_r($result);
+
+        $query = "DECLARE \$v as List<Int32>; SELECT \$v as val;";
+        $prepared = $session->prepare($query);
+        $result = $prepared->execute([
+            'v' => [2],
+        ]);
+        print_r($result);
+
+//        $query = "DECLARE \$v as Optional<Int32>; SELECT \$v as val;";
+//        $prepared = $session->prepare($query);
+//        $result = $prepared->execute([
+//            'v' => 2,
+//        ]);
+//        print_r($result);
+
         foreach ($checkTypes as $type=>$data) {
             $query = "DECLARE \$v as $type; SELECT \$v as val;";
             $prepared = $session->prepare($query);