adicao de log sql

brunobmorais · Jan 25, 2023 · fca83ba · fca83ba
1 parent 80da6c6
commit fca83ba
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 6 deletions.
diff --git a/src/Crud.php b/src/Crud.php
@@ -95,9 +95,10 @@ public function lastInsertId()
     }
 
     /**
-     * @return mixed
+     * @return string|null
      */
-    public function getLogSQL(){
+    public function getLogSQL():?string
+    {
         return $this->logSQL;
     }
 

diff --git a/src/DatalayerTrait.php b/src/DatalayerTrait.php
@@ -56,7 +56,7 @@ protected function executeSQL(String $query, ?array $params = null)
             $this->getInstance();
             $this->prepare = $this->instance->prepare($query);
             $this->prepare->execute($params);
-            $this->logSQL = $this->prepare->queryString;
+            $this->setLogSQL($query, $params);
         } catch (PDOException $e) {
             Connect::setError($e,$query);
             return false;
@@ -245,7 +245,7 @@ protected function selectDB($sql, $params = null, $class = null)
             $this->getInstance();
             $this->prepare = $this->instance->prepare($sql);
             $this->prepare->execute($params);
-            $this->logSQL = $this->prepare->queryString;
+            $this->setLogSQL($sql, $params);
 
             if (!empty($class)) {
                 $rs = $this->fetchArrayClass($this->prepare,$class);
@@ -289,7 +289,7 @@ protected function updateDB($sql, $params = null): bool
             $this->getInstance();
             $query = $this->instance->prepare($sql);
             $rs = $query->execute($params);
-            $this->logSQL = $this->prepare->queryString;
+            $this->setLogSQL($sql, $params);
         } catch (PDOException $e) {
             Connect::setError($e,$sql);
             return false;
@@ -308,7 +308,7 @@ protected function deleteDB($sql, $params = null): bool
             $this->getInstance();;
             $this->prepare = $this->instance->prepare($sql);
             $rs = $this->prepare->execute($params);
-            $this->logSQL = $this->prepare->queryString;
+            $this->setLogSQL($sql, $params);
         } catch (PDOException $e) {
             Connect::setError($e,$sql);
             return false;
@@ -334,4 +334,11 @@ protected function printErrorInfo(): array
     {
         return $this->getInstance($this->database)->errorInfo();
     }
+
+    private function setLogSQL($sql, $placeholders){
+        foreach($placeholders as $k => $v){
+            $sql = preg_replace('/:'.$k.'/',"'".$v."'",$sql);
+        }
+        $this->logSQL = $sql;
+    }
 }