Spaces:
Sleeping
Sleeping
File size: 3,057 Bytes
01be862 0845323 01be862 0845323 01be862 0845323 01be862 0845323 01be862 |
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 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 |
from library.librerias import *
from models.pedidos_proveedor import PedidosProveedor
router = APIRouter(
prefix="/pedidos_proveedor",
tags=["Pedidos_proveedor"],
responses={404: {"description": "No encontrado"}},
)
"""CREATE TABLE pedidos_proveedor (
ID_Pedido INTEGER PRIMARY KEY AUTOINCREMENT,
ID_Proveedor INTEGER,
Fecha DATE,
Total REAL,
FOREIGN KEY (ID_Proveedor) REFERENCES clientes (ID_Proveedor)
);
"""
@router.get("/")
def get_pedidos_proveedor():
try:
with DatabaseConnection().get_connection() as conn:
cursor = conn.cursor()
cursor.execute("SELECT * FROM pedidos_proveedor")
pedidos_proveedor = cursor.fetchall()
return pedidos_proveedor
except Exception as e:
print(e)
return []
@router.post("/")
def post_pedido_proveedor(pedido_proveedor: PedidosProveedor):
try:
with DatabaseConnection().get_connection() as conn:
cursor = conn.cursor()
cursor.execute(
"INSERT INTO pedidos_proveedor (ID_Proveedor, Fecha, Total) VALUES (?, ?, ?)",
(
pedido_proveedor.ID_Proveedor,
pedido_proveedor.Fecha,
pedido_proveedor.Total,
),
)
conn.commit()
return {"message": "Pedido_proveedor creado"}
except Exception as e:
print(e)
return []
@router.put("/")
def put_pedido_proveedor(pedido_proveedor: PedidosProveedor):
try:
with DatabaseConnection().get_connection() as conn:
cursor = conn.cursor()
cursor.execute(
"UPDATE pedidos_proveedor SET ID_Proveedor = ?, Fecha = ?, Total = ? WHERE ID_Pedido = ?",
(
pedido_proveedor.ID_Proveedor,
pedido_proveedor.Fecha,
pedido_proveedor.Total,
pedido_proveedor.ID_Pedido,
),
)
conn.commit()
return {"message": "Pedido_proveedor actualizado"}
except Exception as e:
print(e)
return []
@router.delete("/{ID_Pedido}")
def delete_pedido_proveedor(ID_Pedido: int):
try:
with DatabaseConnection().get_connection() as conn:
cursor = conn.cursor()
cursor.execute(
"DELETE FROM pedidos_proveedor WHERE ID_Pedido = ?", (ID_Pedido,)
)
conn.commit()
return {"message": "Pedido_proveedor eliminado"}
except Exception as e:
print(e)
return []
@router.get("/{ID_Pedido}")
def get_pedido_proveedor(ID_Pedido: int):
try:
with DatabaseConnection().get_connection() as conn:
cursor = conn.cursor()
cursor.execute(
"SELECT * FROM pedidos_proveedor WHERE ID_Pedido = ?", (ID_Pedido,)
)
pedido_proveedor = cursor.fetchall()
return pedido_proveedor
except Exception as e:
print(e)
return []
|