archivo main.py

 from fastapi import FastAPI, HTTPException, Depends, status

from pydantic import BaseModel

from typing import Annotated

import models

from database import engine, SessionLocal

from sqlalchemy.orm import Session

app = FastAPI()

class IngresoBase(BaseModel):

    documentoingreso:str

    nombrepersona:str

class IngresoBase2(BaseModel):

    idregistro:int

    documentoingreso:str

    nombrepersona:str

def get_db():

    db=SessionLocal()

    try:

        yield db

    finally:

        db.close()

db_dependency = Annotated[Session, Depends(get_db)]

@app.post("/registro/", status_code=status.HTTP_201_CREATED)

async def crear_registro(registro:IngresoBase, db:db_dependency):

    db_registro = models.Ingreso(**registro.dict())

    db.add(db_registro)

    db.commit()

    return "El registro se realizo exitosamente"

@app.get("/listarregistros/", status_code=status.HTTP_200_OK)

async def consultar_registros(db:db_dependency):

    registros = db.query(models.Ingreso).all()

    return registros

@app.get("/consultaregistro/{documento_ingreso}", status_code=status.HTTP_200_OK)

async def consultar_registros_por_documento(documento_ingreso, db:db_dependency):

    registro = db.query(models.Ingreso).filter(models.Ingreso.documentoingreso==documento_ingreso).first()

    if registro is None:

        HTTPException(status_code=404, detail="Registro no encontrado")

    return registro

@app.delete("/borrarregisro/{id_registro}", status_code=status.HTTP_200_OK)

async def borrar_registro(id_registro, db:db_dependency):

    registroborrar = db.query(models.Ingreso).filter(models.Ingreso.idregistro==id_registro).first()

    if registroborrar is None:

        HTTPException(status_code=404, detail="No se puede borrar no exite el registro")

    db.delete(registroborrar)

    db.commit()

    return "EL registro de elimino exitosamente"

@app.post("/actualizarregistro/", status_code=status.HTTP_200_OK)

async def actualizar_registro (registro:IngresoBase2, db:db_dependency):

     registroactualizar = db.query(models.Ingreso).filter(models.Ingreso.idregistro==registro.idregistro).first()

     if registroactualizar is None:

         HTTPException(status_code=404, detail="No se encuentra el registro")

     registroactualizar.documentoingreso = registro.documentoingreso

     registroactualizar.nombrepersona = registro.nombrepersona

     db.commit()

     return "Registro actualizado exitosamente"