FastAPI列products.category_id不存在

from pydantic import BaseModel

class Product(BaseModel):
    id: int
    name: str
    category_id: int  # 确保这里定义了category_id

from sqlalchemy import Column, Integer, String, create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker

Base = declarative_base()

class Product(Base):
    __tablename__ = 'products'
    id = Column(Integer, primary_key=True)
    name = Column(String)
    category_id = Column(Integer)  # 确保这里定义了category_id

engine = create_engine('sqlite:///example.db')
Base.metadata.create_all(engine)
Session = sessionmaker(bind=engine)

import csv
from sqlalchemy.orm import Session

def import_products(session: Session):
    with open('products.csv', newline='') as csvfile:
        reader = csv.DictReader(csvfile)
        for row in reader:
            product = Product(**row)
            session.add(product)
    session.commit()

from pydantic import BaseModel
from sqlalchemy import Column, Integer, String, create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker

# 定义Pydantic模型
class Product(BaseModel):
    id: int
    name: str
    category_id: int

# 定义SQLAlchemy模型
Base = declarative_base()

class ProductModel(Base):
    __tablename__ = 'products'
    id = Column(Integer, primary_key=True)
    name = Column(String)
    category_id = Column(Integer)

# 创建数据库引擎
engine = create_engine('sqlite:///example.db')
Base.metadata.create_all(engine)

# 创建会话
Session = sessionmaker(bind=engine)
session = Session()

# 导入数据
import_products(session)

def import_products(session: Session):
    with open('products.csv', newline='') as csvfile:
        reader = csv.DictReader(csvfile)
        for row in reader:
            product = Product(**row)
            session.add(ProductModel(**product.dict()))
    session.commit()