Parallelize Import Process

service/db/base.py

@@ -83,6 +83,19 @@ async def add_store(self, store: Store) -> int:
         """
         pass
 
+    @abstractmethod
+    async def add_many_stores(self, stores: list[Store]) -> dict[str, int]:
+        """
+        Add multiple stores in a batch operation.
+
+        Args:
+            stores: List of Store objects to add or update.
+
+        Returns:
+            Dictionary mapping store codes to their database IDs.
+        """
+        pass
+
     @abstractmethod
     async def update_store(
         self,
@@ -191,6 +204,19 @@ async def add_ean(self, ean: str) -> int:
         """
         pass
 
+    @abstractmethod
+    async def add_many_eans(self, eans: list[str]) -> dict[str, int]:
+        """
+        Add multiple empty products with only EAN codes in a batch operation.
+
+        Args:
+            eans: List of EAN codes to add.
+
+        Returns:
+            Dictionary mapping EAN codes to their database IDs.
+        """
+        pass
+
     @abstractmethod
     async def get_products_by_ean(self, ean: list[str]) -> list[ProductWithId]:
         """