Commit 363eb1fa authored by mouadh's avatar mouadh

unused variable

parent e6180360
...@@ -41,7 +41,6 @@ class MdxEngine: ...@@ -41,7 +41,6 @@ class MdxEngine:
csv_files_cubes = [] csv_files_cubes = []
postgres_db_cubes = [] postgres_db_cubes = []
# to show just config file's dimensions # to show just config file's dimensions
dimension_display_name = []
def __init__(self, def __init__(self,
cube_name, cube_name,
......
...@@ -22,14 +22,13 @@ def _load_table_config_file(executer_instance, cube_obj): ...@@ -22,14 +22,13 @@ def _load_table_config_file(executer_instance, cube_obj):
memory_usage("1 - before executing query //// _load_table_config_file") memory_usage("1 - before executing query //// _load_table_config_file")
for dimension in cube_obj.dimensions: for dimension in cube_obj.dimensions:
df = psql.read_sql_query("SELECT * FROM {0}".format(dimension.name),
db.engine)
# only certain columns # only certain columns
if dimension.columns.keys(): if dimension.columns.keys():
df = psql.read_sql_query("SELECT * FROM {0}".format(dimension.name), df = df[dimension.columns.keys()]
db.engine)[dimension.columns.keys()]
else:
df = psql.read_sql_query("SELECT * FROM {0}".format(dimension.name),
db.engine)
# change table display name
if dimension.displayName: if dimension.displayName:
table_name = dimension.displayName table_name = dimension.displayName
else: else:
...@@ -42,8 +41,6 @@ def _load_table_config_file(executer_instance, cube_obj): ...@@ -42,8 +41,6 @@ def _load_table_config_file(executer_instance, cube_obj):
col for col in df.columns if col.lower()[-2:] != 'id' col for col in df.columns if col.lower()[-2:] != 'id'
]] ]]
executer_instance.dimension_display_name.append(table_name)
memory_usage("2 - after query, before fetchall /////// _load_table_config_file") memory_usage("2 - after query, before fetchall /////// _load_table_config_file")
return tables return tables
...@@ -79,6 +76,7 @@ def _construct_star_schema_config_file(executer_instance, cubes_obj): ...@@ -79,6 +76,7 @@ def _construct_star_schema_config_file(executer_instance, cubes_obj):
fusion = fusion.merge( fusion = fusion.merge(
df, left_on=fact_key, right_on=dimension_and_key.split('.')[1]) df, left_on=fact_key, right_on=dimension_and_key.split('.')[1])
# TODO CHOSE BETWEEN THOSES DF
# fusion = fusion.merge( # fusion = fusion.merge(
# df, left_on=fact_key, right_on=dimension_and_key.split('.')[1], how='left', # df, left_on=fact_key, right_on=dimension_and_key.split('.')[1], how='left',
# # remove suffixe from dimension and keep the same column name for facts # # remove suffixe from dimension and keep the same column name for facts
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment