diff --git a/src/Appwrite/Extend/PDOStatement.php b/src/Appwrite/Extend/PDOStatement.php
index d41b028ab..b1844f4f6 100644
--- a/src/Appwrite/Extend/PDOStatement.php
+++ b/src/Appwrite/Extend/PDOStatement.php
@@ -49,7 +49,9 @@ class PDOStatement extends PDOStatementNative
         try {
             $result = $this->PDOStatement->execute($input_parameters);
         } catch (\Throwable $th) {
-            $this->pdo->reconnect();
+            $this->pdo = $this->pdo->reconnect();
+            //$this->PDOStatement = $this->pdo->prepare($this->PDOStatement->queryString, []);
+
             $result = $this->PDOStatement->execute($input_parameters);
         }