def aggregate(self, cursor):
    (drop_query, drop_params) = self.drop_table_query()
    (agg_query, agg_params) = self.aggregation_query()
    cursor.execute(drop_query, drop_params)
    cursor.execute(agg_query, agg_params)
def aggregate(self, cursor):
    (drop_query, drop_params) = self.drop_table_query()
    (agg_query, agg_params) = self.aggregation_query()
    cursor.execute(drop_query, drop_params)
    cursor.execute(agg_query, agg_params)