pdo try catch issue fix

composer.json

@@ -1,7 +1,7 @@
 {
     "name": "codesvault/howdy-qb",
     "description": "Mysql Query Builder for WordPress",
-    "version": "1.5.2",
+    "version": "1.5.3",
     "minimum-stability": "stable",
     "scripts": {
         "test": "phpunit",

src/Statement/Alter.php

@@ -222,7 +222,11 @@ private function driver_exicute($sql)
             return $driver->query($sql);
         }
 
-        return $driver->exec($sql);
+		try {
+			return $driver->exec($sql);
+        } catch (\PDOException $exception) {
+            Utilities::throughException($exception);
+        }
     }
 
     public function execute()
@@ -234,10 +238,6 @@ public function execute()
             return;
         }
 
-        try {
-            $this->driver_exicute($query);
-        } catch (\PDOException $exception) {
-            Utilities::throughException($exception);
-        }
+    	$this->driver_exicute($query);
     }
 }

src/Statement/Create.php

@@ -171,7 +171,11 @@ private function driver_exicute($sql)
             return $driver->query($sql);
         }
 
-        return $driver->exec($sql);
+		try {
+			return $driver->exec($sql);
+        } catch (\PDOException $exception) {
+            Utilities::throughException($exception);
+        }
     }
 
     public function execute()
@@ -180,10 +184,6 @@ public function execute()
         $query = SqlGenerator::create($this->sql);
         // return dump($query);
 
-        try {
-            $this->driver_exicute($query);
-        } catch (\PDOException $exception) {
-            Utilities::throughException($exception);
-        }
+        $this->driver_exicute($query);
     }
 }

src/Statement/Delete.php

@@ -70,18 +70,18 @@ private function driver_exicute($sql)
         }
 
         $data = $driver->prepare($sql);
-        return $data->execute($this->params);
+		try {
+			return $data->execute($this->params);
+        } catch (\PDOException $exception) {
+            Utilities::throughException($exception);
+        }
     }
 
     private function delete_data()
     {
         $query = SqlGenerator::delete($this->sql);
 
-        try {
-            return $this->driver_exicute($query);
-        } catch (\Exception $exception) {
-            Utilities::throughException($exception);
-        }
+        return $this->driver_exicute($query);
     }
 
     // get only sql query string

src/Statement/Drop.php

@@ -41,17 +41,17 @@ private function driver_exicute($sql)
         }
 
         $data = $driver->prepare($sql);
-        return $data->execute($this->params);
+		try {
+			return $data->execute($this->params);
+        } catch (\Exception $exception) {
+            Utilities::throughException($exception);
+        }
     }
 
     private function drop_table()
     {
         $query = trim($this->sql['drop']);
 
-        try {
-            $this->driver_exicute($query);
-        } catch (\Exception $exception) {
-            Utilities::throughException($exception);
-        }
+        $this->driver_exicute($query);
     }
 }

src/Statement/Insert.php

@@ -35,11 +35,7 @@ private function insert_data()
     {
         $query = SqlGenerator::insert($this->sql);
 
-        try {
-            $this->driver_exicute($query);
-        } catch (\Exception $exception) {
-            Utilities::throughException($exception);
-        }
+        $this->driver_exicute($query);
     }
 
     private function driver_exicute($sql)
@@ -50,7 +46,11 @@ private function driver_exicute($sql)
         }
 
         $data = $driver->prepare($sql);
-        return $data->execute($this->params);
+		try {
+			return $data->execute($this->params);
+        } catch (\Exception $exception) {
+            Utilities::throughException($exception);
+        }
     }
 
     private function start()

src/Statement/Update.php

@@ -32,18 +32,18 @@ private function driver_exicute($sql)
         }
 
         $data = $driver->prepare($sql);
-        return $data->execute($this->params);
+		try {
+			return $data->execute($this->params);
+        } catch (\Exception $exception) {
+            Utilities::throughException($exception);
+        }
     }
 
     private function update_data()
     {
         $query = SqlGenerator::update($this->sql);
 
-        try {
-            $this->driver_exicute($query);
-        } catch (\Exception $exception) {
-            Utilities::throughException($exception);
-        }
+        $this->driver_exicute($query);
     }
 
     public function execute()