Compare commits
2 Commits
feature/la
...
lab2_shved
| Author | SHA1 | Date | |
|---|---|---|---|
| 1e7516fe7b | |||
| a63864bcaa |
@@ -1,8 +1,7 @@
|
||||
version: "3.9"
|
||||
name: "road_vision__database"
|
||||
services:
|
||||
postgres_db:
|
||||
image: postgres:latest
|
||||
image: postgres:17
|
||||
container_name: postgres_db
|
||||
restart: always
|
||||
environment:
|
||||
|
||||
@@ -152,41 +152,7 @@ def list_processed_agent_data():
|
||||
)
|
||||
def update_processed_agent_data(processed_agent_data_id: int, data: ProcessedAgentData):
|
||||
# Update data
|
||||
session = SessionLocal()
|
||||
|
||||
try:
|
||||
query = select(processed_agent_data).where(
|
||||
processed_agent_data.c.id == processed_agent_data_id
|
||||
)
|
||||
result = session.execute(query).fetchone()
|
||||
|
||||
if not result:
|
||||
raise HTTPException(status_code=404, detail="Data not found")
|
||||
|
||||
update_query = (
|
||||
processed_agent_data.update()
|
||||
.where(processed_agent_data.c.id == processed_agent_data_id)
|
||||
.values(
|
||||
road_state=data.road_state,
|
||||
user_id=data.agent_data.user_id,
|
||||
x=data.agent_data.accelerometer.x,
|
||||
y=data.agent_data.accelerometer.y,
|
||||
z=data.agent_data.accelerometer.z,
|
||||
latitude=data.agent_data.gps.latitude,
|
||||
longitude=data.agent_data.gps.longitude,
|
||||
timestamp=data.agent_data.timestamp,
|
||||
)
|
||||
)
|
||||
|
||||
session.execute(update_query)
|
||||
session.commit()
|
||||
|
||||
updated_result = session.execute(query).fetchone()
|
||||
|
||||
return ProcessedAgentDataInDB(**updated_result._mapping)
|
||||
|
||||
finally:
|
||||
session.close()
|
||||
pass
|
||||
|
||||
|
||||
@app.delete(
|
||||
@@ -195,28 +161,8 @@ def update_processed_agent_data(processed_agent_data_id: int, data: ProcessedAge
|
||||
)
|
||||
def delete_processed_agent_data(processed_agent_data_id: int):
|
||||
# Delete by id
|
||||
session = SessionLocal()
|
||||
pass
|
||||
|
||||
try:
|
||||
query = select(processed_agent_data).where(
|
||||
processed_agent_data.c.id == processed_agent_data_id
|
||||
)
|
||||
result = session.execute(query).fetchone()
|
||||
|
||||
if not result:
|
||||
raise HTTPException(status_code=404, detail="Data not found")
|
||||
|
||||
delete_query = processed_agent_data.delete().where(
|
||||
processed_agent_data.c.id == processed_agent_data_id
|
||||
)
|
||||
|
||||
session.execute(delete_query)
|
||||
session.commit()
|
||||
|
||||
return ProcessedAgentDataInDB(**result._mapping)
|
||||
|
||||
finally:
|
||||
session.close()
|
||||
|
||||
if __name__ == "__main__":
|
||||
import uvicorn
|
||||
|
||||
Binary file not shown.
Reference in New Issue
Block a user