def insert_new_from_log(self, **kwargs): try: session = self.Session() entry_data = { 'last_accessed': kwargs["last_accessed"], 'address': kwargs['address'], 'times_accessed': 1, 'times_dumped': 0, 'deleted': 0 } session.add(Iasdfus(**entry_data)) session.commit() session.close() except Exception as e: self.log_error("Unable to commit database entry") self.log_error(str(e)) def update_existing(self, last_accessed=None, address=None, logfile=None): session = self.Session() results = session.query(Iasdfus).filter_by(**{'address': address}) if results.count() == 0: session.close() return False if last_accessed > results[0].last_accessed: results.update({"last_accessed": last_accessed}) results.update({"times_accessed": results[0].times_accessed + 1}) session.commit() session.close() return True