Spaces:
Sleeping
Sleeping
File size: 2,084 Bytes
3086703 6d6cc91 3086703 3d569d3 3086703 6d6cc91 d3addb7 6d6cc91 d3addb7 221c09e d3addb7 6d6cc91 d3addb7 6d6cc91 221c09e 6d6cc91 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 |
from library.librerias import *
from models.productos import Productos
from fastapi import APIRouter, HTTPException, Query
import urllib.parse
from typing import List
router = APIRouter(
prefix="/productos",
tags=["Productos"],
responses={404: {"description": "No encontrado"}},
)
"""CREATE TABLE productos (
ID_Producto INTEGER PRIMARY KEY AUTOINCREMENT,
Nombre TEXT,
Precio REAL
);"""
@router.get("/")
def get_productos():
try:
with DatabaseConnection().get_connection() as conn:
cursor = conn.cursor()
cursor.execute("SELECT * FROM productos")
productos = cursor.fetchall()
return productos
except Exception as e:
print(e)
return []
@router.post("/")
def post_producto(producto: Productos):
try:
with DatabaseConnection().get_connection() as conn:
cursor = conn.cursor()
cursor.execute(
"INSERT INTO productos (Nombre, Precio) VALUES (?, ?)",
(producto.Nombre, producto.Precio),
)
conn.commit()
return {"message": "Producto creado"}
except Exception as e:
print(e)
return []
# search by Nombre order by Precio
@router.get("/search", response_model=List[Productos])
def search_productos(nombre: str = Query(..., alias="Nombre")):
try:
with DatabaseConnection().get_connection() as conn:
cursor = conn.cursor()
nombre_decodificado = urllib.parse.unquote(nombre)
like_pattern = f"%{nombre_decodificado}%"
cursor.execute(
"SELECT ID_Producto, Nombre, Precio FROM productos WHERE Nombre LIKE ? ORDER BY Precio",
(like_pattern,),
)
productos = cursor.fetchall()
return [
Productos(ID_Producto=row[0], Nombre=row[1], Precio=row[2])
for row in productos
]
except Exception as e:
print(e)
raise HTTPException(status_code=500, detail="Error al buscar los productos")
|