Not able handle "on_conflict_do_nothing" in Sqlalchemy in Mysql

Viewed 7

I am using sqlalchemy my backend DB is Mysql. while inserting data in bulk, i am not able to skip the conflict. My ocde:

from sqlalchemy.orm import Session
from sqlalchemy import insert

from app.config import config
from app.datastores.mysql.db import get_db
from app.datastores.mysql.models import models, schemas

async def adding_cronjob_alerts(
    alert: schemas.CreateAlert, generate_uuid, db: Session = Depends(get_db)
):
    logger.debug(f"[{generate_uuid}] - Customer Alert Doesn't Exist In DB => Storing")
    new_alerts = []
    for to_be_saved_alerts in alert:
        new_alert = models.ReaqtaAlerts(**to_be_saved_alerts.dict())
        new_alerts.append(new_alert)
    logger.debug(f"[{generate_uuid}] - Adding Customer Alerts Record To DB")
    db.add_all(new_alerts)
    logger.debug(f"[{generate_uuid}] - Alerts Added Successfully")
    logger.debug(f"[{generate_uuid}] - Committing DB Session To MySQL Database")
    db.commit()
    logger.debug(f"[{generate_uuid}] - {CLOSING_DB_SESSION_STRING}")
    db.close()
0 Answers
Related