feat: MyPdo log query given and executing time (milisecond) (#288)

Author: SonyPradana

src/System/Database/MyPDO.php

@@ -18,6 +18,19 @@ class MyPDO
      */
     protected $configs;
 
+    /**
+     * Query prepare statment;.
+     */
+    protected string $query;
+
+    /**
+     * Log query when execute and fatching.
+     * - query.
+     *
+     * @var array<int, array<string, mixed>>
+     */
+    protected $logs = [];
+
     /**
      * @param array<string, string> $configs
      */
@@ -89,7 +102,7 @@ public function configs()
      */
     public function query(string $query): self
     {
-        $this->stmt = $this->dbh->prepare($query);
+        $this->stmt = $this->dbh->prepare($this->query = $query);
 
         return $this;
     }
@@ -135,7 +148,13 @@ public function bind($param, $value, $type = null): self
      */
     public function execute()
     {
-        return $this->stmt->execute();
+        $start    = microtime(true);
+        $execute  = $this->stmt->execute();
+        $elapsed  = round((microtime(true) - $start) * 1000, 2);
+
+        $this->addLog($this->query, $elapsed);
+
+        return $execute;
     }
 
     /**
@@ -234,4 +253,30 @@ public function cancelTransaction(): bool
     {
         return $this->dbh->rollBack();
     }
+
+    protected function addLog(string $query, float $elapsed_time): void
+    {
+        $this->logs[] = [
+            'query' => $query,
+            'time'  => $elapsed_time,
+        ];
+    }
+
+    /**
+     * Flush logs query.
+     */
+    public function flushLogs(): void
+    {
+        $this->logs = [];
+    }
+
+    /**
+     * Get logs query.
+     *
+     * @return array<int, array<string, mixed>>
+     */
+    public function getLogs(): array
+    {
+        return $this->logs;
+    }
 }

tests/DataBase/MyPdoTest.php

@@ -0,0 +1,49 @@
+<?php
+
+declare(strict_types=1);
+
+namespace System\Test\Database;
+
+final class MyPdoTest extends BaseConnection
+{
+    protected function setUp(): void
+    {
+        $this->createConnection();
+        $this->createUserSchema();
+        $this->createUser([
+            [
+                'user'     => 'taylor',
+                'password' => password_hash('password', PASSWORD_DEFAULT),
+                'stat'     => 100,
+            ],
+        ]);
+    }
+
+    protected function tearDown(): void
+    {
+        $this->dropConnection();
+    }
+
+    /**
+     * @test
+     *
+     * @group database
+     */
+    public function itCanLogExcutionConnention()
+    {
+        $this->pdo->flushLogs();
+        $this->pdo->query('select * from users where user = :user')->bind('user', 'taylor')->resultset();
+        $this->pdo->query('select * from users where user = :user')->bind('user', 'taylor')->single();
+        $this->pdo->query('delete from users where user = :user')->bind('user', 'taylor')->execute();
+
+        $logs = [
+            'select * from users where user = :user',
+            'select * from users where user = :user',
+            'delete from users where user = :user',
+        ];
+
+        foreach ($this->pdo->getLogs() as $key => $log) {
+            $this->assertEquals($log['query'], $logs[$key]);
+        }
+    }
+}