Bitmessage/MiNode
3
0
Fork 1
Code Pull Requests 9 Actions Activity

Set the row_factory for the sqlite3.Connection

Browse Source
This commit is contained in:
Lee Miller 2024-09-13 06:14:21 +03:00
parent 5cddaf0861
commit 959b635ccf
Signed by: lee.miller
GPG Key ID: 4F97A5EA88F4AB63
1 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
minode/sql.py
View File

@ -39,18 +39,17 @@ class Inventory():
cur.execute('VACUUM') cur.execute('VACUUM')
cur.execute("INSERT INTO status VALUES ('lastvacuumtime', ?)", (now,)) cur.execute("INSERT INTO status VALUES ('lastvacuumtime', ?)", (now,))
self._db.commit() self._db.commit()
self._db.row_factory = self.__object
@staticmethod @staticmethod
def __object(cursor, row): def __object(cursor, row):
if len(cursor.description) != 8:
return row
vector, expires, obj_type, version, stream, tag, data, offset = row vector, expires, obj_type, version, stream, tag, data, offset = row
return structure.Object( return structure.Object(
expires, obj_type, version, stream, data, offset, expires, obj_type, version, stream, data, offset,
tag=tag, vector=vector) tag=tag, vector=vector)
def __objects(self, cur):
cur.row_factory = self.__object
return cur
def cleanup(self): def cleanup(self):
with shared.objects_lock: with shared.objects_lock:
self._db.execute( self._db.execute(
@ -74,7 +73,7 @@ class Inventory():
cur = self._db.execute( cur = self._db.execute(
'SELECT * FROM objects WHERE ' # nosec B608 'SELECT * FROM objects WHERE ' # nosec B608
+ ' AND '.join(clauses), params) + ' AND '.join(clauses), params)
return self.__objects(cur) return cur
def vectors_to_send(self, stream=None): def vectors_to_send(self, stream=None):
cur = self._db.execute( cur = self._db.execute(
@ -95,8 +94,7 @@ class Inventory():
return (v for v, in cur) return (v for v, in cur)
def values(self): def values(self):
cur = self._db.execute('SELECT * FROM objects') return self._db.execute('SELECT * FROM objects')
return self.__objects(cur)
def popitem(self): def popitem(self):
if not self.rowid: if not self.rowid: