From ff185954de4ab76a04cc30e5a833bf2b6ab3d0d9 Mon Sep 17 00:00:00 2001 From: Casey Peel Date: Thu, 30 Jul 2026 15:26:00 -0700 Subject: [PATCH] Close DB pool connections that we open --- libgutenberg/GutenbergDatabaseDublinCore.py | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/libgutenberg/GutenbergDatabaseDublinCore.py b/libgutenberg/GutenbergDatabaseDublinCore.py index 8063cc7..2bbed1b 100644 --- a/libgutenberg/GutenbergDatabaseDublinCore.py +++ b/libgutenberg/GutenbergDatabaseDublinCore.py @@ -247,6 +247,8 @@ def load_from_database(self, ebook): dcmitype.description = row.description self.dcmitypes.append(dcmitype) + conn.close() + self.load_files_from_database(ebook) @@ -326,6 +328,7 @@ def load_files_from_database(self, id_): if row.mediatype: self.mediatypes.add(row.mediatype) + conn.close() def remove_filetype_from_database(self, id_, type_): """ Remove filetype from PG database. """ @@ -342,6 +345,8 @@ def remove_filetype_from_database(self, id_, type_): 'fk_filetypes': type_ }) c.execute('commit') + conn.close() + def remove_file_from_database(self, filename): """ Remove file from PG database. """ @@ -354,6 +359,8 @@ def remove_file_from_database(self, filename): { 'filename': filename }) c.execute('commit') + conn.close() + def store_file_in_database(self, id_, filename, type_): """ Store file in PG database. """ @@ -400,6 +407,7 @@ def store_file_in_database(self, id_, filename, type_): 'diskstatus': diskstatus}) c.execute('commit') + conn.close() except OSError: error("Cannot stat %s", filename) @@ -407,6 +415,7 @@ def store_file_in_database(self, id_, filename, type_): except IntegrityError: error("Book number %s is not in database.", id_) c.execute('rollback') + conn.close() def register_coverpage(self, id_, url, code = 901): @@ -431,3 +440,5 @@ def register_coverpage(self, id_, url, code = 901): except DatabaseError as what: warning("Error updating coverpage in database: %s.", what) c.execute('rollback') + + conn.close()