Merge branch 'workinprogress'

Author: transistive

.phpunit.result.cache

@@ -5,6 +5,7 @@
 use GuzzleHttp\Client;
 use GuzzleHttp\Exception\GuzzleException;
 use GuzzleHttp\Exception\RequestException;
+use Neo4j\QueryAPI\Results\ResultSet;
 use RuntimeException;
 use stdClass;
 
@@ -36,17 +37,24 @@ public static function login(string $address, string $username, string $password
     /**
      * @throws GuzzleException
      */
-    public function run(string $cypher, array $parameters, string $database = 'neo4j'): array
+    public function run(string $cypher, array $parameters, string $database = 'neo4j'): ResultSet
     {
         $payload = [
             'statement' => $cypher,
-            'parameters' => $parameters  === [] ? new  stdClass() : $parameters,
+            'parameters' => $parameters === [] ? new stdClass() : $parameters,
         ];
 
         $response = $this->client->post('/db/' . $database . '/query/v2', [
             'json' => $payload,
         ]);
-        return json_decode($response->getBody()->getContents(), true);
+
+
+        $data = json_decode($response->getBody()->getContents(), true);
+
+
+        $ogm = new OGM();
+
+        return new ResultSet($data['data']['fields'], $data['data']['values'], $ogm);
     }
 
 

composer.lock

@@ -17,6 +17,7 @@ public function map(array $object): mixed
             'String' => $object['_value'],
             'Boolean' => $object['_value'],
             'Point' => $this->parseWKT($object['_value']),
+            default => $object['_value'],
         };
     }
 

src/Neo4jQueryAPI.php

@@ -0,0 +1,73 @@
+<?php
+
+//namespace Neo4j\QueryAPI\Results;
+//
+//use Neo4j\QueryAPI\OGM;
+//
+//class ResultRow
+//{
+//    public function __construct(private array $keys, private array $resultRow, private OGM $ogm)
+//    {
+//        $this->values = [];
+//        foreach ($this->resultRow as $index => $value) {
+//            $this->values[$this->keys[$index]] = $value['_value'];
+//        }
+//    }
+//
+//    public function get(string $column): mixed
+//    {
+//        return $this->values[$column] ?? null;
+//    }
+//}
+
+
+
+
+namespace Neo4j\QueryAPI\Results;
+
+
+use BadMethodCallException;
+use Neo4j\QueryAPI\OGM;
+use OutOfBoundsException;
+use ArrayAccess;
+
+class ResultRow implements ArrayAccess
+{
+    public function __construct(private array $data)
+    {
+    }
+
+
+    public function offsetExists($offset): bool
+    {
+        return isset($this->data[$offset]);
+    }
+
+    public function offsetGet($offset): mixed
+    {
+        if (!$this->offsetExists($offset)) {
+            throw new OutOfBoundsException("Column {$offset} not found.");
+        }
+        return $this->data[$offset];
+    }
+
+    public function offsetSet($offset, $value): void
+    {
+        throw new BadMethodCallException("You cant set the value of column {$offset}.");
+    }
+    public function offsetUnset($offset): void
+    {
+            throw new BadMethodCallException("You cant Unset {$offset}.");
+
+    }
+
+
+    public function get(string $row): mixed
+    {
+        return $this->offsetGet($row);
+    }
+
+
+}
+
+