delete.rs

use diesel::*;
use schema::*;

#[test]
fn delete_records() {
    use schema::users::dsl::*;
    let connection = connection_with_sean_and_tess_in_users_table();

    let deleted_rows = delete(users.filter(name.eq("Sean"))).execute(&connection);

    assert_eq!(Ok(1), deleted_rows);

    let num_users = users.count().first(&connection);

    assert_eq!(Ok(1), num_users);
}

#[test]
fn delete_single_record() {
    use schema::users::dsl::*;
    let connection = connection_with_sean_and_tess_in_users_table();
    let data = users.load::<User>(&connection).unwrap();
    let sean = data[0].clone();
    let tess = data[1].clone();

    delete(&sean).execute(&connection).unwrap();

    assert_eq!(Ok(vec![tess]), users.load(&connection));
}

#[test]
#[cfg(not(any(feature = "sqlite", feature = "mysql")))]
fn return_deleted_records() {
    use schema::users::dsl::*;
    let connection = connection_with_sean_and_tess_in_users_table();

    let deleted_name = delete(users.filter(name.eq("Sean")))
        .returning(name)
        .get_result(&connection);
    assert_eq!(Ok("Sean".to_string()), deleted_name);

    let num_users = users.count().first(&connection);
    assert_eq!(Ok(1), num_users);
}