fix(admin,orm): fix user deletion and database initialization

- Add db.initialize() call before table creation
- Fix sync/async delete methods for models
- Fix user deletion calls in admin
- Add sync methods for database operations in sync mode
- Minor QuerySet improvements for sync/async first/all support

Author: ForceFledgling

example/apps/admin/urls.py

@@ -40,7 +40,7 @@ def url_for(endpoint, **kwargs):
 @router.get("/users", response_model=None)
 @requires("user_auth")
 async def users_view(request: Request):
-    users = UserModel.objects.all()  # type: ignore
+    users = UserModel.objects.all().execute_all()  # type: ignore
     # for user in users:
     #     print("user", user)
 

example/apps/groups/api.py

@@ -27,10 +27,10 @@
 # Создание таблицы при запуске приложения
 @router.on_event("startup")
 async def create_tables():
-    await GroupModel.create_table()
+    GroupModel.create_table()
     owners_group = GroupModel.objects.filter(name="Owners").first()  # type: ignore
     if not owners_group:
-        await GroupModel.objects.create(name="Owners")
+        GroupModel.objects.create(name="Owners")
 
 # # Pydantic-модель для входа пользователя
 # class UserLogin(BaseModel):

example/apps/users/api.py

@@ -14,6 +14,8 @@
     FileResponse, \
     HTMLResponse
 
+from cotlette.core.database.sqlalchemy import db
+
 ACCESS_TOKEN_EXPIRE_MINUTES = 30
 
 router = APIRouter()
@@ -38,7 +40,8 @@ class TokenData(BaseModel):
 
 @router.on_event("startup")
 async def create_tables():
-    await UserModel.create_table()
+    db.initialize()
+    UserModel.create_table()
     existing_user = UserModel.objects.filter(email="[email protected]").first()  # type: ignore
     if not existing_user:
         test_user = await create_user(UserCreate(

src/cotlette/core/database/models.py

@@ -285,7 +285,26 @@ async def all(cls):
         result = await db.execute_async(query, fetch=True)
         return [cls(**dict(row)) for row in result]
 
-    async def delete(self):
+    def delete(self):
+        """
+        Удаляет запись из базы данных.
+        """
+        from cotlette.core.database.query import should_use_async
+        if should_use_async():
+            return self._delete_async()
+        else:
+            return self._delete_sync()
+
+    def _delete_sync(self):
+        """
+        Синхронно удаляет запись из базы данных.
+        """
+        if hasattr(self, 'id') and self.id is not None:
+            table_name = self.get_table_name()
+            query = f"DELETE FROM {table_name} WHERE id = {self.id}"
+            db.execute(query)
+
+    async def _delete_async(self):
         """
         Асинхронно удаляет запись из базы данных.
         """
@@ -294,29 +313,4 @@ async def delete(self):
             query = f"DELETE FROM {table_name} WHERE id = {self.id}"
             await db.execute_async(query)
 
-    @classmethod
-    async def create_table(cls):
-        """
-        Асинхронно создает таблицу в базе данных используя SQLAlchemy.
-        """
-        columns = []
-        
-        for field_name, field in cls._fields.items():
-            column_def = {
-                'name': field_name,
-                'type': field.column_type,
-                'primary_key': field.primary_key,
-                'nullable': not field.primary_key,
-                'unique': field.unique
-            }
-            
-            # Обработка внешних ключей
-            if isinstance(field, ForeignKeyField):
-                related_model = field.get_related_model()
-                table_name = related_model.get_table_name()
-                column_def['foreign_key'] = f"{table_name}.id"
-            
-            columns.append(column_def)
 
-        # Создаем таблицу через асинхронный SQLAlchemy бэкенд
-        await db.create_table_async(cls.get_table_name(), columns)

src/cotlette/core/database/query.py

@@ -56,6 +56,20 @@ def all(self):
         # Всегда возвращает QuerySet
         return self
 
+    def execute_all(self):
+        """Выполняет запрос и возвращает все результаты."""
+        if should_use_async():
+            return self._execute_async()
+        else:
+            return self._execute_sync()
+
+    async def aexecute_all(self):
+        """Асинхронная версия execute_all() для использования в async контексте."""
+        if should_use_async():
+            return await self._execute_async()
+        else:
+            return self._execute_sync()
+
     def order_by(self, *fields):
         # Всегда возвращает QuerySet
         new_queryset = QuerySet(self.model_class)
@@ -84,6 +98,13 @@ def first(self):
         else:
             return self._first_sync()
 
+    async def afirst(self):
+        """Асинхронная версия first() для использования в async контексте."""
+        if should_use_async():
+            return await self._first_async()
+        else:
+            return self._first_sync()
+
     def count(self):
         if should_use_async():
             return self._count_async()