fixup!

2024-10-17 10:36:29 +02:00
parent 3d2ed02fb1
commit 881329eaa6
1 changed files with 4 additions and 6 deletions
@@ -159,16 +159,14 @@ class Connection(Compat):
        return row

    async def update(self, table_name: str, model: BaseModel, where: str = "id = :id"):
-        result = await self.conn.execute(
+        await self.conn.execute(
            text(update_query(table_name, model, where)), model.dict()
        )
-        result.close()
+        await self.conn.commit()

    async def insert(self, table_name: str, model: BaseModel):
-        result = await self.conn.execute(
-            text(insert_query(table_name, model)), model.dict()
-        )
-        result.close()
+        await self.conn.execute(text(insert_query(table_name, model)), model.dict())
+        await self.conn.commit()

    async def fetch_page(
        self,