hyperdb-api 0.1.0

Pure Rust API for Hyper database
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
110
111
112
113
114
115
116
117
118
119

// Copyright (c) 2026, Salesforce, Inc. All rights reserved.
// SPDX-License-Identifier: Apache-2.0 OR MIT

//! Integration tests for the extended [`AsyncTransaction`] API.
//!
//! Sync `Transaction` exposes `execute_query`, `fetch_*`, `query_count`
//! and parameterized queries. This test file locks in that every one of
//! those has a working async delegation.

mod common;

use common::{test_hyper_params, test_result_path};
use hyperdb_api::{AsyncConnection, CreateMode, HyperProcess, Result};

async fn fresh_async_conn(name: &str) -> Result<(HyperProcess, AsyncConnection)> {
    let db_path = test_result_path(name, "hyper")?;
    let params = test_hyper_params(name)?;
    let hyper = HyperProcess::new(None, Some(&params))?;
    let endpoint = hyper.require_endpoint()?.to_string();
    let conn = AsyncConnection::connect(
        &endpoint,
        db_path.to_str().expect("path"),
        CreateMode::CreateAndReplace,
    )
    .await?;
    Ok((hyper, conn))
}

#[tokio::test(flavor = "current_thread")]
async fn fetch_inside_txn() {
    let (_hyper, mut conn) = fresh_async_conn("async_txn_fetch").await.unwrap();

    conn.execute_command("CREATE TABLE t (id INT NOT NULL, val INT)")
        .await
        .unwrap();
    conn.execute_command("INSERT INTO t VALUES (1, 10), (2, 20), (3, 30)")
        .await
        .unwrap();

    {
        let txn = conn.transaction().await.unwrap();
        // Read inside transaction — previously impossible through high-level API.
        let sum: i64 = txn.fetch_scalar("SELECT SUM(val) FROM t").await.unwrap();
        assert_eq!(sum, 60);

        // Parameterized query inside transaction.
        let rs = txn
            .query_params("SELECT id FROM t WHERE val > $1 ORDER BY id", &[&15i32])
            .await
            .unwrap();
        let rows = rs.collect_rows().await.unwrap();
        assert_eq!(rows.len(), 2);

        // Count helper.
        let n = txn.query_count("SELECT COUNT(*) FROM t").await.unwrap();
        assert_eq!(n, 3);

        txn.commit().await.unwrap();
    }

    conn.close().await.unwrap();
}

#[tokio::test(flavor = "current_thread")]
async fn read_modify_write_in_txn() {
    let (_hyper, mut conn) = fresh_async_conn("async_txn_rmw").await.unwrap();

    conn.execute_command("CREATE TABLE counters (k TEXT, v INT NOT NULL)")
        .await
        .unwrap();
    conn.execute_command("INSERT INTO counters VALUES ('x', 10)")
        .await
        .unwrap();

    {
        let txn = conn.transaction().await.unwrap();
        let cur: i32 = txn
            .fetch_scalar("SELECT v FROM counters WHERE k = 'x'")
            .await
            .unwrap();
        txn.command_params("UPDATE counters SET v = $1 WHERE k = 'x'", &[&(cur + 5)])
            .await
            .unwrap();
        txn.commit().await.unwrap();
    }

    let final_v: i32 = conn
        .fetch_scalar("SELECT v FROM counters WHERE k = 'x'")
        .await
        .unwrap();
    assert_eq!(final_v, 15);

    conn.close().await.unwrap();
}

#[tokio::test(flavor = "current_thread")]
async fn rollback_discards_writes() {
    let (_hyper, mut conn) = fresh_async_conn("async_txn_rollback").await.unwrap();

    conn.execute_command("CREATE TABLE t (v INT NOT NULL)")
        .await
        .unwrap();

    {
        let txn = conn.transaction().await.unwrap();
        txn.execute_command("INSERT INTO t VALUES (1)")
            .await
            .unwrap();
        txn.execute_command("INSERT INTO t VALUES (2)")
            .await
            .unwrap();
        txn.rollback().await.unwrap();
    }

    let count: i64 = conn.fetch_scalar("SELECT COUNT(*) FROM t").await.unwrap();
    assert_eq!(count, 0);

    conn.close().await.unwrap();
}