SQLAlchemy重复提交()

// 防抖示例
function debounce(func, wait) {
    let timeout;
    return function(...args) {
        clearTimeout(timeout);
        timeout = setTimeout(() => func.apply(this, args), wait);
    };
}

document.getElementById('submit-button').addEventListener('click', debounce(() => {
    // 提交表单的逻辑
}, 1000));

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

Base = declarative_base()

class RequestLog(Base):
    __tablename__ = 'request_log'
    id = Column(Integer, primary_key=True)
    request_id = Column(String, unique=True)

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

def is_request_processed(request_id):
    session = Session()
    log = session.query(RequestLog).filter_by(request_id=request_id).first()
    if log:
        return True
    return False

def mark_request_as_processed(request_id):
    session = Session()
    log = RequestLog(request_id=request_id)
    session.add(log)
    session.commit()

def handle_request(request_id):
    if is_request_processed(request_id):
        return "Request already processed"
    # 处理请求的逻辑
    mark_request_as_processed(request_id)
    return "Request processed successfully"

from sqlalchemy.exc import IntegrityError

def handle_request(request_id):
    session = Session()
    try:
        session.begin_nested()
        if is_request_processed(request_id):
            return "Request already processed"
        # 处理请求的逻辑
        mark_request_as_processed(request_id)
        session.commit()
        return "Request processed successfully"
    except IntegrityError:
        session.rollback()
        return "Request already processed"