validação de conexão de banco

app/Core/Model.php

@@ -62,10 +62,6 @@ abstract class Model
         }
     }
 
-    ################################################################################################
-    ################################################################################################
-    ################################################################################################
-
     protected function create($query, $data)
     {
         try {
@@ -75,7 +71,9 @@ abstract class Model
             return Connect::getInstance()->lastInsertId();
         } catch (PDOException $ex) {
             Connect::setInstance(null);
+            sleep(5);
             logger('PDOExcep')->error('PDOException: ' . $ex->getMessage(), debug_backtrace());
+            $this->create($query, $data);
             return null;
         }
     }
@@ -89,7 +87,9 @@ abstract class Model
             return $stmt;
         } catch (PDOException $ex) {
             Connect::setInstance(null);
+            sleep(5);
             logger('PDOExcep')->error('PDOException: ' . $ex->getMessage(), debug_backtrace());
+            $this->read($query, $data);
             return null;
         }
     }
@@ -103,7 +103,9 @@ abstract class Model
             return ($stmt->rowCount() ? 1 : 0);
         } catch (PDOException $ex) {
             Connect::setInstance(null);
+            sleep(5);
             logger('PDOExcep')->error('PDOException: ' . $ex->getMessage(), debug_backtrace());
+            $this->delete($query, $data);
             return null;
         }
     }
@@ -118,7 +120,9 @@ abstract class Model
             return ($stmt->rowCount() ? 1 : 0);
         } catch (PDOException $ex) {
             Connect::setInstance(null);
+            sleep(5);
             logger('PDOExcep')->error('PDOException: ' . $ex->getMessage(), debug_backtrace());
+            $this->update($query, $data);
             return null;
         }
     }