product, category create get query model routes created

Author: ajaysharmadeveloper

BaseApp/BlogApp/models.py

@@ -0,0 +1,31 @@
+from sqlalchemy import Boolean, Column, Integer, String, ForeignKey
+from sqlalchemy.orm import relationship
+# Import Base variable of database from database
+from BaseApp.database import Base
+
+
+class Product(Base):
+    __tablename__ = "products"
+    id = Column(Integer, primary_key=True)
+    name = Column(String(50), nullable=True)
+    detail = Column(String(100), nullable=False)
+    category_id = Column(Integer, ForeignKey('category.id'), nullable=False)
+    is_delete = Column(Boolean, default=False, nullable=False)
+    created_on = Column(String(100), nullable=True)
+    updated_on = Column(String(100), nullable=True)
+
+    def __repr__(self):
+        return 'Product name : %r' % self.name
+
+
+class Category(Base):
+    __tablename__ = "category"
+    id = Column(Integer, primary_key=True)
+    name = Column(String(50), nullable=True)
+    is_delete = Column(Boolean, default=False, nullable=False)
+    created_on = Column(String(100), nullable=True)
+    updated_on = Column(String(100), nullable=True)
+    product = relationship("Product", backref="category", lazy=True)
+
+    def __repr__(self):
+        return 'Category name : %r' % self.name

BaseApp/BlogApp/query.py

@@ -0,0 +1,45 @@
+from BaseApp.ProductApp.models import Product, Category
+import datetime
+
+
+def getCategory(id, db):
+    return db.query(Category).filter_by(id=id, is_delete=False).first()
+
+
+def getAllCategory(db):
+    return db.query(Category).all()
+
+
+def addCategory(data, db):
+    dateTime = str(datetime.datetime.timestamp(datetime.datetime.now()))
+    category = Category(
+        name=data.name,
+        created_on=dateTime,
+        updated_on=dateTime
+    )
+    db.add(category)
+    db.commit()
+    return category
+
+
+def getProduct(id, db):
+    return db.query(Product).filter_by(id=id, is_delete=False).first()
+
+
+def getAllProducts(db):
+    return db.query(Product).all()
+
+
+def addProduct(data, db):
+    dateTime = str(datetime.datetime.timestamp(datetime.datetime.now()))
+    category = getCategory(data.category, db)
+    product = Product(
+        name=data.name,
+        detail=data.detail,
+        category_id=category.id,
+        created_on=dateTime,
+        updated_on=dateTime
+    )
+    db.add(product)
+    db.commit()
+    return product

BaseApp/BlogApp/router.py

@@ -0,0 +1,40 @@
+from typing import List
+from fastapi import Depends, APIRouter
+from sqlalchemy.orm import Session
+# get_db method from dependencies
+from BaseApp.UserApp.schemas import UserResponse
+from BaseApp.dependencies import get_db, get_current_user
+from BaseApp.ProductApp.schemas import ProductResponse, CategoryResponse, ProductCreate, CategoryCreate
+from BaseApp.ProductApp.query import addProduct, addCategory, getAllProducts, getAllCategory
+
+# Create Router Instance of FastApi to create api's
+api = APIRouter(tags=['Products'])
+
+
+# Tag name for this app is blog || use tags=['blog']
+
+# API's created here
+@api.get("/products", response_model=List[ProductResponse], status_code=200)
+async def allProducts(db: Session = Depends(get_db), current_user: UserResponse = Depends(get_current_user)):
+    data = getAllProducts(db)
+    return data
+
+
+@api.post("/product-create", response_model=ProductResponse, status_code=201)
+async def createProduct(data: ProductCreate, db: Session = Depends(get_db),
+                        current_user: UserResponse = Depends(get_current_user)):
+    data = addProduct(data, db)
+    return data
+
+
+@api.get("/categories", response_model=List[CategoryResponse], status_code=200)
+async def allCategory(db: Session = Depends(get_db), current_user: UserResponse = Depends(get_current_user)):
+    data = getAllCategory(db)
+    return data
+
+
+@api.post("/create-category", response_model=CategoryResponse, status_code=201)
+async def createCategory(data: CategoryCreate, db: Session = Depends(get_db),
+                         current_user: UserResponse = Depends(get_current_user)):
+    data = addCategory(data, db)
+    return data

BaseApp/BlogApp/schemas.py

@@ -0,0 +1,35 @@
+from typing import List
+
+from pydantic import BaseModel
+
+
+class CategoryResponse(BaseModel):
+    id: int
+    name: str
+    created_on: str
+
+    # Required for ORM based response data to enable ORM mode
+    class Config:
+        orm_mode = True
+
+
+class ProductResponse(BaseModel):
+    id: int
+    name: str
+    detail: str
+    category_id: int
+    created_on: str
+
+    # Required for ORM based response data to enable ORM mode
+    class Config:
+        orm_mode = True
+
+
+class ProductCreate(BaseModel):
+    name: str
+    detail: str
+    category: int
+
+
+class CategoryCreate(BaseModel):
+    name: str

BaseApp/BlogApp/__init__.py renamed to BaseApp/ProductApp/__init__.py

@@ -4,14 +4,15 @@
 from BaseApp.database import engine
 # Import Apps module
 from BaseApp import UserApp
-from BaseApp import BlogApp
+from BaseApp import ProductApp
 # Import models and router from App
 from BaseApp.UserApp import models, router
-from BaseApp.BlogApp import models, router
+from BaseApp.ProductApp import models, router
 
+# No need to add or bind to database engine to our models here alembic do this
 # Binding Apps models to database engine
 # UserApp.models.Base.metadata.create_all(bind=engine)
-# BlogApp.models.Base.metadata.create_all(bind=engine)
+# ProductApp.models.Base.metadata.create_all(bind=engine)
 
 # FastApi Instance
 app = FastAPI(
@@ -22,8 +23,6 @@
 
 # Include App to FastApi Instance
 app.include_router(UserApp.router.api, prefix="/auth")
-app.include_router(BlogApp.router.api, prefix="/blog")
+app.include_router(ProductApp.router.api, prefix="/product")
+
 
-# Run FastApi to main
-# if __name__ == "__main__":
-#     uvicorn.run(app, host="0.0.0.0", port=8000)

BaseApp/ProductApp/models.py

@@ -21,6 +21,7 @@
 
 # This helps alembic auto generation
 from BaseApp.UserApp.models import *
+from BaseApp.ProductApp.models import *
 from BaseApp.database import Base
 
 target_metadata = Base.metadata

BaseApp/ProductApp/query.py

@@ -0,0 +1,47 @@
+"""product and category model
+
+Revision ID: 9a397463dcbf
+Revises: 12db141fd663
+Create Date: 2021-06-19 17:36:33.007047
+
+"""
+from alembic import op
+import sqlalchemy as sa
+
+
+# revision identifiers, used by Alembic.
+revision = '9a397463dcbf'
+down_revision = '12db141fd663'
+branch_labels = None
+depends_on = None
+
+
+def upgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.create_table('category',
+    sa.Column('id', sa.Integer(), nullable=False),
+    sa.Column('name', sa.String(length=50), nullable=True),
+    sa.Column('is_delete', sa.Boolean(), nullable=False),
+    sa.Column('created_on', sa.String(length=100), nullable=True),
+    sa.Column('updated_on', sa.String(length=100), nullable=True),
+    sa.PrimaryKeyConstraint('id')
+    )
+    op.create_table('products',
+    sa.Column('id', sa.Integer(), nullable=False),
+    sa.Column('name', sa.String(length=50), nullable=True),
+    sa.Column('detail', sa.String(length=100), nullable=False),
+    sa.Column('category_id', sa.Integer(), nullable=False),
+    sa.Column('is_delete', sa.Boolean(), nullable=False),
+    sa.Column('created_on', sa.String(length=100), nullable=True),
+    sa.Column('updated_on', sa.String(length=100), nullable=True),
+    sa.ForeignKeyConstraint(['category_id'], ['category.id'], ),
+    sa.PrimaryKeyConstraint('id')
+    )
+    # ### end Alembic commands ###
+
+
+def downgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_table('products')
+    op.drop_table('category')
+    # ### end Alembic commands ###