initial setup for test

Author: p123-stack

src/Profile.php

@@ -0,0 +1,62 @@
+<?php
+
+namespace Neo4j\QueryAPI;
+require __DIR__ . '/../vendor/autoload.php';
+
+
+use GuzzleHttp\Client;
+
+class Profile
+{
+    private $neo4jUrl;
+    private $username;
+    private $password;
+    private $client;
+
+    public function __construct($url, $username, $password)
+    {
+        $this->neo4jUrl = $url;
+        $this->username = $username;
+        $this->password = $password;
+        $this->client = new Client();
+    }
+
+    public function executeQuery($query ,$parameters=[])
+    {
+        $response = $this->client->post($this->neo4jUrl, [
+            'auth' => [$this->username, $this->password],
+            'json' => [
+                'statement' => $query,
+                'parameters'=>$parameters
+            ]
+        ]);
+
+        return json_decode($response->getBody(), true);
+    }
+
+    public function formatResponse($data): array
+    {
+        $output = [
+            "data" => [
+                "fields" => [],
+                "values" => []
+            ],
+            "profiledQueryPlan" => [],
+            "bookmarks" => $data['bookmarks'] ?? []
+        ];
+
+        if (isset($data['result']['columns']) && isset($data['result']['rows'])) {
+            $output["data"]["fields"] = $data['result']['columns'];
+            foreach ($data['result']['rows'] as $row) {
+                $output["data"]["values"][] = $row;
+            }
+        }
+
+        if (isset($data['profiledQueryPlan'])) {
+            $output["profiledQueryPlan"] = $data['profiledQueryPlan'];
+        }
+
+        return $output;
+    }
+}
+

src/Query_Profile.php

@@ -0,0 +1,45 @@
+<?php
+require __DIR__ . '/../vendor/autoload.php';
+
+use GuzzleHttp\Client;
+
+$neo4jUrl = 'https://6f72daa1.databases.neo4j.io/db/neo4j/query/v2';
+$username = 'neo4j';
+$password = '9lWmptqBgxBOz8NVcTJjgs3cHPyYmsy63ui6Spmw1d0';
+
+$client = new Client();
+
+$query = "PROFILE MATCH (n:Person) RETURN n";
+
+$response = $client->post($neo4jUrl, [
+    'auth' => [$username, $password],
+    'json' => [
+        'statement' => $query
+    ]
+]);
+
+$body = $response->getBody();
+$data = json_decode($body, true);
+
+$output = [
+    "data" => [
+        "fields" => [],
+        "values" => []
+    ],
+    "profiledQueryPlan" => [],
+    "bookmarks" => $data['bookmarks'] ?? []
+];
+
+if (isset($data['result']['columns']) && isset($data['result']['rows'])) {
+    $output["data"]["fields"] = $data['result']['columns'];
+    foreach ($data['result']['rows'] as $row) {
+        $output["data"]["values"][] = $row;
+    }
+}
+
+if (isset($data['profiledQueryPlan'])) {
+    $output["profiledQueryPlan"] = $data['profiledQueryPlan'];
+}
+
+echo json_encode($output, JSON_PRETTY_PRINT);
+

src/Query_Profile_run.php

@@ -0,0 +1,22 @@
+<?php
+
+use Neo4j\QueryAPI\Profile;
+
+require __DIR__ . '/../vendor/autoload.php';
+
+$neo4jUrl = 'https://6f72daa1.databases.neo4j.io/db/neo4j/query/v2';
+$username = 'neo4j';
+$password = '9lWmptqBgxBOz8NVcTJjgs3cHPyYmsy63ui6Spmw1d0';
+
+$client = new Profile($neo4jUrl, $username, $password);
+
+$params = ['name' => 'Alice'];
+
+$query = "PROFILE MATCH (n:Person {name: \$name}) RETURN n.name";
+
+$data = $client->executeQuery($query, $params);
+
+
+$formattedResponse = $client->formatResponse($data);
+
+echo json_encode($formattedResponse, JSON_PRETTY_PRINT);

src/runtransaction.php

@@ -0,0 +1,21 @@
+<?php
+
+require __DIR__ . '/../vendor/autoload.php';
+
+use Neo4j\QueryAPI\Neo4jQueryAPI;
+
+$neo4jUrl = 'https://6f72daa1.databases.neo4j.io/';
+$username = 'neo4j';
+$password = '9lWmptqBgxBOz8NVcTJjgs3cHPyYmsy63ui6Spmw1d0';
+
+$api = Neo4jQueryAPI::login($neo4jUrl, $username, $password);
+
+$transaction = $api->beginTransaction();
+
+$query = 'CREATE (n:Person {name: "Bobby"}) RETURN n';
+
+$response = $transaction->run($query, []);
+
+print_r($response);
+
+$transaction->commit();

tests/Integration/Neo4jQueryAPIIntegrationTest.php

@@ -44,6 +44,13 @@ public function testCounters(): void
         $this->assertEquals(1, $result->getQueryCounters()->getNodesCreated());
     }
 
+    public function testProfileExistence(): void
+    {
+        $result = $this->api->run('PROFILE MATCH (x) RETURN x');
+
+        $this->assertNotNull($result->getProfiledQueryPlan());
+    }
+
     public function testTransactionCommit(): void
     {
         // Begin a new transaction