new database system

items/models.py

@@ -4,11 +4,12 @@ from sqlalchemy import DateTime
 from pydantic import BaseModel
 from fastapi import Depends
 from sqlalchemy.orm import Session, relationship, mapped_column, Mapped
-from sqlalchemy import ForeignKey, Column, Integer, String, Float
+from sqlalchemy import String, Float, Integer, ForeignKey
 from sqlalchemy.dialects.postgresql import ARRAY
-from ..config import Base, get_session_db
+from ..config import Base, get_session_db, collection_item
 from typing import TYPE_CHECKING
-from ..auth.models import Role, Status, UserBase, DBUser
+from ..auth.models import Role, Status, UserBase
+from ..collectionObj.models import CollectionsDB
 
 
 class UserProfileBase(UserBase): 
@@ -56,61 +57,23 @@ class Item(BaseItem):
 # Tüm modeller AUTH'da veri tabanına işlendi yukardaki
 #modeller veri tabanında mevcuttur. Değiştirmek için AUTH'daki
 # DBUser modelini değiştirip tekrar veri tabanına işleyebilirsin
-'''
-'''
+
 class Items(Base):
     __tablename__ = "items_table"
 
     item_id : Mapped[int] = mapped_column(primary_key=True, index=True, autoincrement=True)
-    user_id : Mapped[int] = mapped_column(ForeignKey('users_table.user_id'), nullable=False, index=True)
+    #collection_id : Mapped[list[int]] = mapped_column(Integer, ForeignKey("collections_table.collection_id"), nullable=True) # collection_id ile ilişki
     item_created_date : Mapped[datetime] = mapped_column(DateTime, default=datetime.now())
-    item_location = Column(String, default="No location")
-    item_type = Column(String, default="No type")
-    item_content = Column(String, default="No content")
-    item_score = Column(Float, default=0.0)
+    item_location: Mapped[str] = mapped_column(String, default="No location")
+    item_type: Mapped[str] = mapped_column(String, default="No type")
+    item_content: Mapped[str] = mapped_column(String, default="No content")
+    item_score: Mapped[float] = mapped_column(Float, default=0.0)
 
-    # ilişkiler
-    
-    user : Mapped['DBUser'] = relationship("DBUser", back_populates="items", lazy='select')
-    #collection = relationship("Collections", back_populates="items")
-    
-    
-'''
-'''
-def is_user_exsist_get(username : str, session : Annotated[Session, Depends(get_session_db)]) -> bool | UserProfilePrivate:
-     #DBUser veritabanındaki nesnedir her niteliğe sahiptir
-    user = session.query(DBUser).filter(DBUser.username == username).first()
-    return user
-
-
-def all_users(session: Annotated[Session, Depends(get_session_db)]) -> list[UserProfilePrivate]:
-    users = session.query(DBUser).all()
-
-    return [UserProfilePrivate(
-        username=user.username,
-        bio=user.bio,
-        created_date=user.created_date,
-        items = [Item.model_validate(item) for item in user.items],
-        collections=user.collections,
-        role=user.role,
-        status=user.status
-    ) for user in users]
-
-
-def add_Item_user(
-        user: Annotated[UserProfileID, Depends(get_session_db)], 
-        session: Annotated[Session, Depends(get_session_db)],
-        item: ItemCreate) -> bool:
-    # DBUser veritabanındaki nesnedir her niteliğe sahiptir
-
-    item = Items(
-        user_id=user.user_id,
-        item_location=item.item_location,
-        item_type=item.item_type,
-        item_content=item.item_content,
-        item_created_date=item.item_created_date
-    )
-
-    session.add(item)
-    session.commit()
-    return True
+    # ilişkiler 
+    collections : Mapped['CollectionsDB']= relationship(
+        "CollectionsDB",
+        secondary=collection_item,
+        back_populates="items", 
+        lazy='select'
+    )  #back_populates karşı tarafın ismi
+    

items/router.py

@@ -1,4 +1,4 @@
-from .models import ItemCreate, UserProfileBase, UserProfileID, UserProfilePrivate, UserProfilePublic, add_Item_user, all_users, is_user_exsist_get
+from .models import ItemCreate, UserProfileBase, UserProfileID, UserProfilePrivate, UserProfilePublic
 from fastapi import APIRouter, Depends
 from sqlalchemy.orm import Session
 from ..config import get_session_db
@@ -12,44 +12,7 @@ router = APIRouter(
     dependencies=[],
 )
 
-@router.get('/all_profiles')
-async def get_user_profile(session: Annotated[Session, Depends(get_session_db)]) -> list[UserProfilePrivate]:
-    
-    return all_users(session=session)
-
-
-@router.get('/profile/{username}')
-async def get_user_profile_by_username(
-    username: str,
-    session: Annotated[Session, Depends(get_session_db)],
-) -> UserProfilePublic | dict:
-    
-    user : UserProfilePublic = is_user_exsist_get(username, session)
-    if user is None:
-        return {"error": "User not found"}
-    
-    return user
-
-@router.get('/profile/me')
-async def get_user_profile_me(
-    current_user: Annotated[UserProfilePrivate, Depends(get_current_active_user)],
-    session : Annotated[Session, Depends(get_session_db)], #dependtek kaynaklı UserPublic doner
-    ) -> UserProfilePrivate:
-    
-    return is_user_exsist_get(current_user.username, session)
-    
-
-@router.post('/create')
-async def create_user_profile(
-    user : Annotated[UserProfileID, Depends(get_current_active_user)],
-    session: Annotated[Session, Depends(get_session_db)],
-    item : Annotated[ItemCreate , None] = None
-) -> dict:
-    
-    if add_Item_user(user, session, item) :
-        return {"message": "User item created successfully"}
-    
-    return {"error": "User item creation failed"}
+#tüm crud işlemleri yeni veri tabanı modeli ile yapılacak