62 lines
2.3 KiB
Python
62 lines
2.3 KiB
Python
from fastapi import FastAPI, HTTPException, Depends
|
|
from sqlalchemy.orm import Session
|
|
# from . import models, schemas, crud
|
|
import models
|
|
import schemas
|
|
import crud
|
|
|
|
# from .database import SessionLocal, engine
|
|
from database import SessionLocal, engine
|
|
|
|
|
|
# 创建数据库表
|
|
models.Base.metadata.create_all(bind=engine)
|
|
|
|
app = FastAPI()
|
|
|
|
# 依赖项，用于获取数据库会话
|
|
def get_db():
|
|
db = SessionLocal()
|
|
try:
|
|
yield db
|
|
finally:
|
|
db.close()
|
|
|
|
# 创建新的城市天气记录
|
|
@app.post("/city_weather/", response_model=schemas.CityWeather)
|
|
def create_city_weather(city_weather: schemas.CityWeatherCreate, db: Session = Depends(get_db)):
|
|
db_city = crud.get_city_weather_by_name(db, city_name=city_weather.city_name)
|
|
if db_city:
|
|
raise HTTPException(status_code=400, detail="City already registered")
|
|
return crud.create_city_weather(db=db, city_weather=city_weather)
|
|
|
|
# 获取城市天气记录
|
|
@app.get("/city_weather/{city_id}", response_model=schemas.CityWeather)
|
|
def read_city_weather(city_id: int, db: Session = Depends(get_db)):
|
|
db_city_weather = crud.get_city_weather(db, city_id=city_id)
|
|
if db_city_weather is None:
|
|
raise HTTPException(status_code=404, detail="City not found")
|
|
return db_city_weather
|
|
|
|
# 获取多个城市天气记录
|
|
@app.get("/city_weather/", response_model=list[schemas.CityWeather])
|
|
def read_city_weathers(skip: int = 0, limit: int = 10, db: Session = Depends(get_db)):
|
|
cities = crud.get_city_weathers(db, skip=skip, limit=limit)
|
|
return cities
|
|
|
|
# 更新城市天气记录
|
|
@app.put("/city_weather/{city_id}", response_model=schemas.CityWeather)
|
|
def update_city_weather(city_id: int, city_weather: schemas.CityWeatherCreate, db: Session = Depends(get_db)):
|
|
db_city = crud.update_city_weather(db=db, city_id=city_id, city_weather=city_weather)
|
|
if db_city is None:
|
|
raise HTTPException(status_code=404, detail="City not found")
|
|
return db_city
|
|
|
|
# 删除城市天气记录
|
|
@app.delete("/city_weather/{city_id}", response_model=schemas.CityWeather)
|
|
def delete_city_weather(city_id: int, db: Session = Depends(get_db)):
|
|
db_city = crud.delete_city_weather(db=db, city_id=city_id)
|
|
if db_city is None:
|
|
raise HTTPException(status_code=404, detail="City not found")
|
|
return db_city
|