graphitesql 0.1.3

A pure, safe, no_std Rust re-implementation of SQLite, compatible with the SQLite 3 file format.
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

//! `Connection::last_insert_rowid()`, `changes()`, and `total_changes()` — the
//! `sqlite3_last_insert_rowid()`/`sqlite3_changes()`/`sqlite3_total_changes()`
//! accessors — match the SQL `last_insert_rowid()`/`changes()`/`total_changes()`
//! functions and SQLite's documented semantics.

#![cfg(feature = "std")]

use graphitesql::{Connection, Value};

fn int(conn: &Connection, sql: &str) -> i64 {
    match conn.query(sql).unwrap().rows[0][0] {
        Value::Integer(i) => i,
        ref v => panic!("expected integer, got {v:?}"),
    }
}

#[test]
fn change_and_rowid_accessors() {
    let mut c = Connection::open_memory().unwrap();
    // No inserts yet.
    assert_eq!(c.last_insert_rowid(), 0);
    assert_eq!(c.total_changes(), 0);

    c.execute_batch("CREATE TABLE t(a INTEGER PRIMARY KEY, b);")
        .unwrap();
    // DDL does not count as a change.
    assert_eq!(c.total_changes(), 0);

    c.execute("INSERT INTO t VALUES(NULL, 'x')").unwrap();
    assert_eq!(c.last_insert_rowid(), 1);
    assert_eq!(c.changes(), 1);
    assert_eq!(c.total_changes(), 1);
    // The Rust accessor agrees with the SQL function.
    assert_eq!(int(&c, "SELECT last_insert_rowid()"), 1);
    assert_eq!(int(&c, "SELECT changes()"), 1);
    assert_eq!(int(&c, "SELECT total_changes()"), 1);

    // A multi-row insert: last rowid is the last assigned, changes = 3.
    c.execute("INSERT INTO t VALUES(NULL,'a'),(NULL,'b'),(NULL,'c')")
        .unwrap();
    assert_eq!(c.last_insert_rowid(), 4);
    assert_eq!(c.changes(), 3);
    assert_eq!(c.total_changes(), 4);

    // An explicit rowid updates last_insert_rowid.
    c.execute("INSERT INTO t VALUES(100, 'z')").unwrap();
    assert_eq!(c.last_insert_rowid(), 100);
    assert_eq!(c.changes(), 1);

    // UPDATE counts toward changes/total but not last_insert_rowid.
    c.execute("UPDATE t SET b='Y' WHERE a<=4").unwrap();
    assert_eq!(c.changes(), 4);
    assert_eq!(c.last_insert_rowid(), 100);
    assert_eq!(c.total_changes(), 9);

    // A SELECT leaves the counters untouched.
    let _ = c.query("SELECT count(*) FROM t").unwrap();
    assert_eq!(c.changes(), 4);
    assert_eq!(c.last_insert_rowid(), 100);

    // DELETE.
    c.execute("DELETE FROM t WHERE a>=100").unwrap();
    assert_eq!(c.changes(), 1);
    assert_eq!(c.total_changes(), 10);
}

#[test]
fn is_autocommit_reflects_transaction_state() {
    let mut c = Connection::open_memory().unwrap();
    c.execute_batch("CREATE TABLE t(a);").unwrap();
    // Autocommit on by default.
    assert!(c.is_autocommit());

    c.execute_batch("BEGIN;").unwrap();
    assert!(!c.is_autocommit());
    c.execute_batch("INSERT INTO t VALUES(1);").unwrap();
    assert!(!c.is_autocommit());
    c.execute_batch("COMMIT;").unwrap();
    assert!(c.is_autocommit());

    // ROLLBACK also restores autocommit.
    c.execute_batch("BEGIN;").unwrap();
    assert!(!c.is_autocommit());
    c.execute_batch("ROLLBACK;").unwrap();
    assert!(c.is_autocommit());

    // An outermost SAVEPOINT turns autocommit off until it is released.
    c.execute_batch("SAVEPOINT s;").unwrap();
    assert!(!c.is_autocommit());
    c.execute_batch("SAVEPOINT s2;").unwrap();
    assert!(!c.is_autocommit());
    c.execute_batch("RELEASE s2;").unwrap();
    assert!(!c.is_autocommit());
    c.execute_batch("RELEASE s;").unwrap();
    assert!(c.is_autocommit());
}