|
@@ -30,7 +30,7 @@ class DbCreateConfig:
|
|
|
logs_dir: str = "..\\logs"
|
|
|
|
|
|
|
|
|
-class database_inspect:
|
|
|
+class DatabaseInspect:
|
|
|
tables = []
|
|
|
|
|
|
def __init__(self, dsn: DsnConfig, source=False):
|
|
@@ -172,11 +172,11 @@ def create(config_file: str = "database/CARLO.json"):
|
|
|
base_dir = str(Path(cfg.batch_dir).parent)
|
|
|
config = get_import_config(f"{base_dir}/config/{cfg.csv_file}", cfg.target_dsn.database)
|
|
|
|
|
|
- source_db = database_inspect(cfg.source_dsn, source=True)
|
|
|
+ source_db = DatabaseInspect(cfg.source_dsn, source=True)
|
|
|
source_tables = source_db.get_tables()
|
|
|
print(json.dumps(source_db.get_prefix(), indent=2))
|
|
|
|
|
|
- target_db = database_inspect(cfg.target_dsn)
|
|
|
+ target_db = DatabaseInspect(cfg.target_dsn)
|
|
|
target_tables = target_db.get_tables()
|
|
|
|
|
|
for _, current_table in config.iterrows():
|