sqlb 0.4.0

Simple, expressive, and progressive SQL Builder for Rust.
Documentation 
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
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109

mod utils;

use sqlb::{HasFields, SqlBuilder};
use std::error::Error;
use utils::{init_db, util_fetch_all_todos, util_insert_todo};

use crate::utils::Todo;
use serial_test::serial;

#[serial]
#[test]
#[should_panic]
fn sb_delete_err_all() {
	let sb = sqlb::delete().table("todo");
	sb.sql();
	// should panic
}

#[serial]
#[test]
fn sb_delete_ok_all() {
	let sb = sqlb::delete_all().table("todo");
	sb.sql();
	// should pass
}

#[serial]
#[tokio::test]
async fn sb_delete_ok_exec() -> Result<(), Box<dyn Error>> {
	let db_pool = init_db().await?;

	// -- Fixtures
	let test_title_1 = "test - title 01";
	let test_title_2 = "test - title 02";
	let todo_id_1 = util_insert_todo(&db_pool, test_title_1).await?;
	let _ = util_insert_todo(&db_pool, test_title_2).await?;

	// -- Exec
	// Note: test schema and fully qualified column name.
	let sb = sqlb::delete().table("public.todo").and_where("todo.id", "=", todo_id_1);
	let row_affected = sb.exec(&db_pool).await?;
	assert_eq!(1, row_affected, "row_affected");

	// -- Check - if only one todo_1 was deleted
	let todos = util_fetch_all_todos(&db_pool).await?;
	assert_eq!(1, todos.len());
	assert_eq!(test_title_2, todos[0].title);

	Ok(())
}

#[serial]
#[tokio::test]
async fn sb_delete_ok_return_one() -> Result<(), Box<dyn Error>> {
	let db_pool = init_db().await?;

	// -- Fixtures
	let test_title_1 = "test - title 01";
	let test_title_2 = "test - title 02";
	let todo_id_1 = util_insert_todo(&db_pool, test_title_1).await?;
	let _ = util_insert_todo(&db_pool, test_title_2).await?;

	// -- Exec
	let sb = sqlb::delete().table("todo").and_where("id", "=", todo_id_1);
	let sb = sb.returning(&["id", "title"]);
	let (deleted_todo_1_id, deleted_todo_1_title) = sb.fetch_one::<_, (i64, String)>(&db_pool).await?;

	// -- Check - deleted returns
	assert_eq!(test_title_1, deleted_todo_1_title);
	assert_eq!(todo_id_1, deleted_todo_1_id);

	// -- Check - check with fetch all
	let todos = util_fetch_all_todos(&db_pool).await?;
	assert_eq!(1, todos.len());
	assert_eq!(test_title_2, todos[0].title);

	Ok(())
}

#[serial]
#[tokio::test]
async fn sb_delete_ok_return_many() -> Result<(), Box<dyn Error>> {
	let db_pool = init_db().await?;

	// -- Fixtures
	let test_title_1 = "test - title 01";
	let test_title_2 = "test - title 02";
	let todo_id_1 = util_insert_todo(&db_pool, test_title_1).await?;
	let todo_id_2 = util_insert_todo(&db_pool, test_title_2).await?;

	// -- Exec
	let sb = sqlb::delete().table("todo").and_where("id", ">", 0);
	let sb = sb.returning(Todo::field_names());

	let deleted: Vec<Todo> = sb.fetch_all(&db_pool).await?;

	// -- Check - deleted returns
	assert_eq!(2, deleted.len());
	assert_eq!(todo_id_1, deleted[0].id);
	assert_eq!(test_title_1, deleted[0].title);
	assert_eq!(todo_id_2, deleted[1].id);
	assert_eq!(test_title_2, deleted[1].title);

	// -- Check - empty table
	let todos = util_fetch_all_todos(&db_pool).await?;
	assert_eq!(0, todos.len());

	Ok(())
}