Skip to content
Snippets Groups Projects
Commit bcc8e3cc authored by jvfpw18's avatar jvfpw18
Browse files

_aggregate accepts foreign_key from the called table as a clause

parent 7850a261
No related branches found
No related tags found
2 merge requests!13v1.1.0,!7Add denormalizations to run aggregations
...@@ -881,7 +881,12 @@ class DatabaseTable(Table): ...@@ -881,7 +881,12 @@ class DatabaseTable(Table):
referred_table.map_from_database() referred_table.map_from_database()
selecter = select([getattr(func, aggregation)(source_column)]) selecter = select([getattr(func, aggregation)(source_column)])
for fk_column, fkey in referred_table.get_relations(self): try:
fk_dict = [(fk_column, fkey) for fk_column, fkey in referred_table.get_relations(self)]
except MissingForeignKeyError:
fk_dict = [(fk_column, fkey) for fk_column, fkey in self.get_relations(referred_table)]
for fk_column, fkey in fk_dict:
selecter = selecter.where(fk_column == fkey) selecter = selecter.where(fk_column == fkey)
if year: if year:
selecter = selecter.where(self.c.ano_censo == year) selecter = selecter.where(self.c.ano_censo == year)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment