Merge pull request #4 from nagels-tech/create-result-counters-1951105551

wired up result counters

Author: transistive

queryCounters/Neo4jBookmarkIntegration.php

@@ -6,6 +6,7 @@
 use GuzzleHttp\Client;
 use GuzzleHttp\Exception\GuzzleException;
 use GuzzleHttp\Exception\RequestException;
+use Neo4j\QueryAPI\Objects\ResultCounters;
 use Neo4j\QueryAPI\Results\ResultRow;
 use Neo4j\QueryAPI\Results\ResultSet;
 use Neo4j\QueryAPI\Exception\Neo4jException;
@@ -42,13 +43,14 @@ public static function login(string $address, string $username, string $password
      * @throws Neo4jException
      * @throws RequestExceptionInterface
      */
-    public function run(string $cypher, array $parameters, string $database = 'neo4j'): ResultSet
+    public function run(string $cypher, array $parameters = [], string $database = 'neo4j'): ResultSet
     {
         try {
             // Prepare the payload for the request
             $payload = [
                 'statement' => $cypher,
                 'parameters' => empty($parameters) ? new stdClass() : $parameters,
+                'includeCounters' => true
             ];
 
             // Execute the request to the Neo4j server
@@ -71,7 +73,22 @@ public function run(string $cypher, array $parameters, string $database = 'neo4j
                 return new ResultRow($data);
             }, $values);
 
-            return new ResultSet($rows);
+            return new ResultSet($rows, new ResultCounters(
+                containsUpdates: $data['counters']['containsUpdates'],
+                nodesCreated: $data['counters']['nodesCreated'],
+                nodesDeleted: $data['counters']['nodesDeleted'],
+                propertiesSet: $data['counters']['propertiesSet'],
+                relationshipsCreated: $data['counters']['relationshipsCreated'],
+                relationshipsDeleted: $data['counters']['relationshipsDeleted'],
+                labelsAdded: $data['counters']['labelsAdded'],
+                labelsRemoved: $data['counters']['labelsRemoved'],
+                indexesAdded: $data['counters']['indexesAdded'],
+                indexesRemoved: $data['counters']['indexesRemoved'],
+                constraintsAdded: $data['counters']['constraintsAdded'],
+                constraintsRemoved: $data['counters']['constraintsRemoved'],
+                containsSystemUpdates: $data['counters']['containsSystemUpdates'],
+                systemUpdates: $data['counters']['systemUpdates']
+            ));
         } catch (RequestExceptionInterface $e) {
             $response = $e->getResponse();
             if ($response !== null) {

queryCounters/queryCounters3.php

@@ -18,10 +18,8 @@ public function __construct(
         private readonly int  $constraintsAdded,
         private readonly int $constraintsRemoved,
         private readonly bool $containsSystemUpdates,
-        private readonly int $systemUpdates,
-//        array $bookmarks = []
+        private readonly int $systemUpdates
     ) {
-        $this->bookmarks = $bookmarks;
     }