backend/core/src/queries/budget_updates/insert.rs


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

use anyhow::{Context, Result};
use crate::{
    models::budget_update::BudgetUpdate,
    schema::budget_updates::dsl::budget_updates as budget_updates_table,
};
use diesel::prelude::*;

pub fn insert_budget_updates(
    budget_updates: &[BudgetUpdate],
    connection: &mut SqliteConnection,
) -> Result<usize> {
    let num_rows_inserted = diesel::insert_into(budget_updates_table)
        .values(budget_updates)
        .execute(connection)
        .with_context(|| err_msg(budget_updates))?;
    Ok(num_rows_inserted)
}

fn err_msg(budget_updates: &[BudgetUpdate]) -> String {
    format!(
        "failed to insert budget updates: [{}]",
        budget_updates
            .iter()
            .map(|a| a.id.to_string())
            .collect::<Vec<String>>()
            .join(", ")
    )
}