backend/core/src/queries/accounts/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::account::Account,
    schema::accounts::dsl::accounts as accounts_table,
};
use diesel::prelude::*;

pub fn insert_accounts(
    accounts: &[Account],
    connection: &mut SqliteConnection,
) -> Result<usize> {
    let num_accounts_inserted = diesel::insert_into(accounts_table)
        .values(accounts)
        .execute(connection)
        .with_context(|| err_msg(accounts))?;
    Ok(num_accounts_inserted)
}

fn err_msg(accounts: &[Account]) -> String {
    format!(
        "failed to insert accounts: [{}]",
        accounts
            .iter()
            .map(|a| format!("\"{}\": \"{}\"", a.id, a.name))
            .collect::<Vec<String>>()
            .join(", ")
    )
}