Function insert_allocations

indexer/src/database.rs:221–231

(
    db: &Database,
    allocations: impl Iterator<Item = allocation::ActiveModel>,
)

}

pub async fn insert_allocations(
    db: &Database,
    allocations: impl Iterator<Item = allocation::ActiveModel>,
) -> Result<(), DbErr> {
    let res = Allocation::insert_many(allocations)
        .on_empty_do_nothing()
        .exec(db.db())
        .await?;
    log::debug!("Allocation::insert_many: {:?}", res);
    Ok(())
}