blob: f945b6325b3767a3e9fb8ba43b1fe6d1001394a1 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
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
|
