utils.py 文件源码

def delete_report_data(report_id):
    PlotData.query.filter(PlotData.report_id==report_id).delete()
    db.session.commit()
    PlotCategory.query.filter(PlotCategory.plot_category_id.in_(db.session.query(PlotCategory.plot_category_id).outerjoin(PlotData).filter(PlotData.plot_data_id==None))).delete(synchronize_session='fetch')
    db.session.commit()
    db.session.execute(user_plotconfig_map.delete().where(user_plotconfig_map.c.plot_config_id.in_(db.session.query(PlotConfig.config_id).outerjoin(PlotData).filter(PlotData.plot_data_id==None))))
    db.session.commit()
    #user_plotconfig_map.query.filter(user_plotconfig_map.plot_config_id.in_(db.session.query(PlotConfig.plot_config_id).outerjoin(PlotData).filter(PlotData.plot_data_id==None))).delete(synchronize_session='fetch')
    PlotConfig.query.filter(PlotConfig.config_id.in_(db.session.query(PlotConfig.config_id).outerjoin(PlotData).outerjoin(PlotCategory, PlotCategory.config_id==PlotConfig.config_id).filter(and_(PlotData.plot_data_id==None, PlotCategory.plot_category_id==None)))).delete(synchronize_session='fetch')
    db.session.commit()
    SampleData.query.filter(SampleData.report_id==report_id).delete()
    db.session.commit()
    SampleDataType.query.filter(SampleDataType.sample_data_type_id.in_(db.session.query(SampleDataType.sample_data_type_id).outerjoin(SampleData).filter(SampleData.sample_data_id==None))).delete(synchronize_session='fetch')
    db.session.commit()
    ReportMeta.query.filter(ReportMeta.report_id==report_id).delete()
    db.session.commit()
    Sample.query.filter(Sample.report_id==report_id).delete()
    db.session.commit()
    Report.query.filter(Report.report_id==report_id).delete()
    db.session.commit()