Method start

middle/data_importer.py:88–120

(self)

        AnsiPrint.print(f"Imported [cyan]{file_name}[green] [Success][reset]"+' '*40)

    def start(self):
        old_db = SqlMapSetting().database
        try:
            stopwatch = Stopwatch()
            stopwatch.start()
            
            self._summary = {
                "databases":[],
                "tables":[],
                "rows":0,
                "files":[],
                "elapsed":""

            }
            self._bind_config()
            databases = SqlMapSetting().get_databases()
            if databases is not None:
                for name in databases:
                    SqlMapSetting().database=name
                    self._summary["databases"].append(name.lower())
                    AnsiPrint.print(f"\r\nCreating database [yellow][bold]{name.lower()}[reset]")

                    db = self._get_connection(Settings.get_principal_db(self._dbConfig.dbms))
                    db.create_database(name)
                    self.create_tables(name)
            
            stopwatch.stop()
            self._summary["elapsed"]= str(stopwatch)
            self._print_summary()
        except Exception as e:
            AnsiPrint.print_error(e)
        finally:
            SqlMapSetting().database = old_db