Migration and DB Import Upgrades

Author: Fredrick Peter

README.md

@@ -554,7 +554,7 @@ AutoloadEnv::configurePagination([
 ]);
 ```
 
-- or Helpers Function
+- or -- `Helpers Function`
 ```
 configure_pagination([
     'allow' => true,
@@ -1215,8 +1215,6 @@ $db->repair('tb_wallet');
 | $db->getConnection()  | get_connection() |
 
 ## Database Import
-<details><summary>Read more...</summary>
-
 - You can use this class to import .sql into a database programatically
 
 ```
@@ -1232,7 +1230,12 @@ $response = $import->DatabaseImport('orm.sql');
 ->response == 400 (Query to database error
 ->response == 200 (Success importing to database
 ```
-</details>
+
+- or -- `Helpers Function`
+
+```
+import()->DatabaseImport('orm.sql');
+```
 
 ## Update Env Variable
 - You can use this class to import .sql into a database programatically

src/DBImport.php

@@ -61,6 +61,33 @@ public function DatabaseImport($path_to_sql = NULL)
                         // get content
                         $sql = file_get_contents($this->realpath);
 
+                        // Replace Creation of tables
+                        $sql = str_replace("CREATE TABLE", "CREATE TABLE IF NOT EXISTS", $sql);
+
+                        // Replace Insert into
+                        $sql = str_replace("INSERT INTO", "INSERT IGNORE INTO", $sql);
+
+                        // Replace Creation of triggers
+                        $sql = str_replace("CREATE TRIGGER", "CREATE TRIGGER IF NOT EXISTS", $sql);
+
+                        // Replace delimiter
+                        $sql = str_replace(['DELIMITER', '$$'], "", $sql);
+
+                        // Check if table exists and remove ALTER TABLE queries
+                        $matches = [];
+                        preg_match_all('/ALTER TABLE `(\w+)`/i', $sql, $matches);
+                        $tableNames = $matches[1];
+
+                        // loop through to check if table exist already and ignore ALTER queries
+                        foreach ($tableNames as $tableName) {
+                            $tableExistsQuery = "SHOW TABLES LIKE '{$tableName}'";
+                            $tableExists = $Driver->query($tableExistsQuery)->rowCount() > 0;
+                        
+                            if ($tableExists) {
+                                $sql = preg_replace("/ALTER TABLE `{$tableName}`.*?;/is", "", $sql);
+                            }
+                        }
+
                         // execute query
                         $Driver->exec($sql);