update

Author: tamedevelopers

src/Connectors/Connector.php

@@ -118,11 +118,11 @@ public function table(string $table)
     /**
      * Check if table exists
      * 
-     * @param string|null $table
+     * @param mixed $table
      * 
      * @return bool
      */
-    public function tableExists($table)
+    public function tableExists(...$table)
     {
         return $this->table('')->tableExists($table);
     }

src/Schema/Builder.php

@@ -1268,23 +1268,37 @@ public function orHavingRaw($sql, array $bindings = [])
     /**
      * Check if table exists
      * 
-     * @param string $table
+     * @param mixed $table
      * 
      * @return bool
      */
-    public function tableExists($table)
+    public function tableExists(...$table)
     {
+        $tables = Forge::flattenValue($table);
+        
         try{
             $pdo = $this->connection->pdo;
 
             // check if Database connection has been established 
-            if(!$this->isPDO($pdo)){
+            if(!$this->isPDO($pdo) || empty($tables)){
                 return false;
             }
 
-            $pdo->query("
-                select exists (select 1 from `{$table}` limit 1) as 'exists'
-            ")->execute();
+            // Get the database driver (mysql, pgsql, sqlite)
+            $driver = $pdo->getAttribute(PDO::ATTR_DRIVER_NAME);
+
+            if ($driver === 'sqlite') {
+                $selectQueries = array_map(fn($table) => "(SELECT 1 FROM \"{$table}\" LIMIT 1)", $tables);
+                $sql = "SELECT COALESCE(" . implode(", ", $selectQueries) . ", 0) AS \"exists\"";
+            } elseif($driver === 'mysql') {
+                $caseQueries = array_map(fn($table) => "WHEN EXISTS (SELECT 1 FROM `{$table}` LIMIT 1) THEN 1", $tables);
+                $sql = "SELECT CASE " . implode(" ", $caseQueries) . " ELSE 0 END AS `exists`";
+            } else{
+                $caseQueries = array_map(fn($table) => "WHEN EXISTS (SELECT 1 FROM \"{$table}\" LIMIT 1) THEN 1", $tables);
+                $sql = "SELECT CASE " . implode(" ", $caseQueries) . " ELSE 0 END AS \"exists\"";
+            }
+
+            $pdo->query($sql)->execute();
 
             $this->close();
 

src/Schema/Traits/BuilderTrait.php

@@ -1032,6 +1032,9 @@ protected function decrementEach(array $columns, array $extra = [])
      */
     protected function insertBuilder(array $values, $ignore = false)
     {
+        $createdAT = 'created_at';
+        $updatedAT = 'updated_at';
+
         // Since every insert gets treated like a batch insert, we will make sure the
         // bindings are structured in a way that is convenient when building these
         // inserts statements by verifying these elements are actually an array.
@@ -1040,12 +1043,21 @@ protected function insertBuilder(array $values, $ignore = false)
         }
 
         // check if timestamps is available in table
-        // if yes then add time stamdps to columns
+        // if yes then add time stamps to columns
         // with this helper, developers dont need to worry adding them
         $stampData = $this->timeStampData();
 
         if (! is_array(reset($values))) {
-            $values = [array_merge($values, $stampData)];
+            
+            if(!isset($values[$createdAT]) && $this->isTimeStampsReady){
+                $values[$createdAT] = $stampData[$createdAT];
+            }
+            
+            if(!isset($values[$updatedAT]) && $this->isTimeStampsReady){
+                $values[$updatedAT] = $stampData[$updatedAT];
+            }
+
+            $values = [$values];
         }
 
         // Here, we will sort the insert keys for every record so that each insert is
@@ -1055,7 +1067,15 @@ protected function insertBuilder(array $values, $ignore = false)
             foreach ($values as $key => $value) {
                 ksort($value);
 
-                $values[$key] = array_merge($values, $stampData);
+                if(!isset($value[$createdAT]) && $this->isTimeStampsReady){
+                    $value[$createdAT] = $stampData[$createdAT];
+                }
+                
+                if(!isset($value[$updatedAT]) && $this->isTimeStampsReady){
+                    $value[$updatedAT] = $stampData[$updatedAT];
+                }
+
+                $values[$key] = $value;
             }
         }
 
@@ -1276,11 +1296,11 @@ protected function isTimeStampsReady()
 
             // get results data
             $result = $stmt->fetchAll(PDO::FETCH_COLUMN);
-            
-            if(is_array($result) && count($result) === 2){
-                return true;
-            }
-            return false;
+
+            // if columns exists in the table
+            $this->isTimeStampsReady = is_array($result) && count($result) === 2;
+
+            return $this->isTimeStampsReady;
         } catch (\PDOException $th) {
             return false;
         }
@@ -1334,6 +1354,7 @@ protected function fetchAll(int $mode = PDO::FETCH_ASSOC)
      */
     protected function close($table = true)
     {
+        $this->isTimeStampsReady = false;
         $this->bindings = [
             'select'    => [],
             'from'      => [],

src/Schema/Traits/MySqlProperties.php

@@ -70,6 +70,13 @@ trait MySqlProperties{
      */
     public $distinct = false;
 
+    /**
+     * Indicates if the timestamps is available in the database table.
+     *
+     * @var bool
+     */
+    public $isTimeStampsReady = false;
+
     /**
      * @var string
      */

src/Traits/DBSetupTrait.php

@@ -28,11 +28,11 @@ public static function table($table)
     /**
      * Check if table exists
      * 
-     * @param string $table
+     * @param mixed $table
      * 
      * @return bool
      */
-    public static function tableExists($table)
+    public static function tableExists(...$table)
     {
         return (new Connector)->table('')->tableExists($table);
     }