load.py 文件源码

def load_data(p_session, p_data):
    """
    Insert the list of models instances in the current session then commit.

    :param p_session: Session object.
    :param p_data: List of models instances.
    :return: None
    """
    try:
        db_log.debug("Commiting")
        p_session.bulk_save_objects(p_data)
        p_session.commit()

    except IntegrityError as err:
        db_log.error(err)
        p_session.rollback()