jap_learn/src/data_provider/words.rs

use crate::data::entities::WordData;
use crate::data::repositories::{DataRepository, DataRepositoryInner};
use crate::data_provider::{SqliteDbLayer, TableAccessQuerySet};
use rusqlite::{Error, Params, Row};

pub type WordRepository = DataRepository<WordData, WordDataLayer>;
pub type WordRepositoryInner = DataRepositoryInner<WordData, WordDataLayer>;
pub type WordDataLayer = SqliteDbLayer<WordData, WordQuerySet>;
#[derive(Clone)]
pub struct WordQuerySet;
impl TableAccessQuerySet<WordData> for WordQuerySet {
    fn load() -> &'static str {
        "SELECT id, key, value, tags, more, group_id FROM words"
    }

    fn save() -> &'static str {
        "UPDATE words SET key = ?1, value = ?2, tags = ?3, more = ?4 WHERE id = ?5"
    }

    fn add() -> &'static str {
        "INSERT INTO words (key, value, tags, more, group_id) VALUES (?1, ?2, ?3, ?4, ?5)"
    }

    fn name() -> &'static str {
        "words"
    }

    fn from_sql(row: &Row) -> Result<WordData, Error> {
        let additional: String = row.get(4)?;
        Ok(WordData {
            id: row.get(0)?,
            key: row.get(1)?,
            value: row.get(2)?,
            tags: row.get(3)?,
            additional: serde_json::from_str(&additional).unwrap_or_default(),
            group_id: row.get(5)?,
        })
    }

    fn insert_params(entity: &WordData) -> impl Params {
        (
            &entity.key,
            &entity.value,
            &entity.tags,
            serde_json::to_string(&entity.additional).unwrap_or_default(),
            entity.group_id,
        )
    }

    fn update_params(entity: &WordData) -> impl Params {
        (
            &entity.key,
            &entity.value,
            &entity.tags,
            serde_json::to_string(&entity.additional).unwrap_or_default(),
            entity.id,
        )
    }
}