# HG changeset patch
# User Goffi <goffi@goffi.org>
# Date 1627591861 -7200
# Node ID 2d97c695af0563f1d7f05d5464d6a5d7ae559cd1
# Parent  7510648e8e3a931d978654576c9619ed807a49c4
core (memory/sqla): generic methods to add and delete ORM objects directly

diff -r 7510648e8e3a -r 2d97c695af05 sat/memory/sqla.py
--- a/sat/memory/sqla.py	Thu Jul 29 22:51:01 2021 +0200
+++ b/sat/memory/sqla.py	Thu Jul 29 22:51:01 2021 +0200
@@ -186,6 +186,23 @@
 
         self.initialized.callback(None)
 
+    ## Generic
+
+    @aio
+    async def add(self, db_obj: DeclarativeMeta) -> None:
+        """Add an object to database"""
+        async with self.session() as session:
+            async with session.begin():
+                session.add(db_obj)
+
+    @aio
+    async def delete(self, db_obj: DeclarativeMeta) -> None:
+        """Delete an object from database"""
+        async with self.session() as session:
+            async with session.begin():
+                await session.delete(db_obj)
+                await session.commit()
+
     ## Profiles
 
     def getProfilesList(self) -> List[str]: