zippa-db 0.1.0

A fast, lightweight, cross-platform database client for PostgreSQL, MySQL, and SQLite.
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
110
111
112
113
114
115
116
117
118
119
120

//! The console tab: every statement this connection has sent, read from
//! `Connection::query_log`.

use super::*;

#[gpui_kit::test]
fn a_user_run_shows_up_in_the_console(cx: &mut TestAppContext) {
    let (_database, handle) = session_with_objects(cx);

    prepare_editor(cx, handle, "select 1", 8);
    press(cx, handle, "secondary-enter");
    cx.run_until_parked();

    handle
        .update(cx, |session, window, cx| {
            session.open_console_for_test(window, cx)
        })
        .unwrap();
    // The refresh snapshots the log on the background executor.
    cx.run_until_parked();

    let console = handle
        .update(cx, |session, _, cx| session.active_console_view(cx))
        .unwrap()
        .expect("the active tab should be the console");
    let grid = console.read_with(cx, |console, _| console.grid_for_test());

    // Newest first, so the run just sent is row 0.
    let sql = grid.read_with(cx, |grid, cx| grid.column_values_for_test(3, cx));
    let source = grid.read_with(cx, |grid, cx| grid.column_values_for_test(1, cx));
    assert_eq!(sql[0].as_deref(), Some("select 1"));
    assert_eq!(source[0].as_deref(), Some("User"));
}

#[gpui_kit::test]
fn opening_a_table_logs_its_reads_as_internal(cx: &mut TestAppContext) {
    let (_database, handle, _view) = table_view(cx);
    cx.run_until_parked();

    handle
        .update(cx, |session, window, cx| {
            session.open_console_for_test(window, cx)
        })
        .unwrap();
    // The refresh snapshots the log on the background executor.
    cx.run_until_parked();

    let console = handle
        .update(cx, |session, _, cx| session.active_console_view(cx))
        .unwrap()
        .expect("the active tab should be the console");
    let entries = console.read_with(cx, |console, _| console.entry_count());
    assert!(entries > 0, "opening a table sends its own reads");

    let grid = console.read_with(cx, |console, _| console.grid_for_test());
    let source = grid.read_with(cx, |grid, cx| grid.column_values_for_test(1, cx));
    assert!(
        source
            .iter()
            .any(|value| value.as_deref() == Some("Internal")),
        "the table's own reads are not the user's own SQL"
    );
}

#[gpui_kit::test]
fn opening_the_console_twice_brings_the_same_tab_forward(cx: &mut TestAppContext) {
    let (_database, handle) = session_with_objects(cx);

    let before = handle
        .update(cx, |session, _, cx| session.tab_titles(cx))
        .unwrap();

    handle
        .update(cx, |session, window, cx| {
            session.open_console_for_test(window, cx);
            session.open_console_for_test(window, cx);
        })
        .unwrap();

    let after = handle
        .update(cx, |session, _, cx| session.tab_titles(cx))
        .unwrap();
    assert_eq!(
        after.len(),
        before.len() + 1,
        "the console should open once, not twice"
    );
}

#[gpui_kit::test]
fn the_clear_button_empties_the_log(cx: &mut TestAppContext) {
    let (_database, handle) = session_with_objects(cx);

    prepare_editor(cx, handle, "select 1", 8);
    press(cx, handle, "secondary-enter");
    cx.run_until_parked();

    handle
        .update(cx, |session, window, cx| {
            session.open_console_for_test(window, cx)
        })
        .unwrap();
    // The refresh snapshots the log on the background executor.
    cx.run_until_parked();

    let console = handle
        .update(cx, |session, _, cx| session.active_console_view(cx))
        .unwrap()
        .expect("the active tab should be the console");
    assert!(console.read_with(cx, |console, _| console.entry_count()) > 0);

    cx.update_window(handle.into(), |_, window, cx| {
        window.draw(cx).clear(cx);
        window.click("clear-console", cx);
    })
    .unwrap();
    cx.run_until_parked();

    assert_eq!(console.read_with(cx, |console, _| console.entry_count()), 0);
}