cartel-sqlite 0.24.0

SQLite driver for the dope runtime
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

use crate::{api, catalogs, row};
use api::exec;
use dope_fiber::abi;
use std::{marker, mem, ops, result};

/// A bounded row scan tied to the connection or transaction that issued it.
/// Borrowed rows are valid only for one visitor invocation and cannot be
/// retained by a later invocation.
pub struct Cursor<
    'query,
    'connection: 'query,
    'd: 'connection,
    R,
    Q: catalogs::TypedQuery,
    P = (),
    I: catalogs::Catalog = catalogs::Empty,
> where
    I: catalogs::HasQuery<Q>,
{
    machine: exec::Machine<'query, 'connection, 'd, I, P, catalogs::Statement<I, Q>>,
    marker: marker::PhantomData<fn() -> R>,
}

impl<'query, 'connection: 'query, 'd: 'connection, R, Q, P, I>
    Cursor<'query, 'connection, 'd, R, Q, P, I>
where
    Q: catalogs::TypedQuery,
    I: catalogs::Catalog + catalogs::HasQuery<Q>,
{
    const LAYOUT: () = assert!(
        mem::size_of::<Self>()
            == mem::size_of::<
                exec::Machine<'query, 'connection, 'd, I, P, catalogs::Statement<I, Q>>,
            >()
    );

    pub(super) const fn new(
        machine: exec::Machine<'query, 'connection, 'd, I, P, catalogs::Statement<I, Q>>,
    ) -> Self {
        let () = Self::LAYOUT;
        Self {
            machine,
            marker: marker::PhantomData,
        }
    }
}

impl<
    'query,
    'connection: 'query,
    'd: 'connection,
    R: row::raw::Decode,
    Q: catalogs::TypedQuery,
    P: api::Bind,
    I: catalogs::Catalog + catalogs::HasQuery<Q>,
> Cursor<'query, 'connection, 'd, R, Q, P, I>
{
    pub fn visit<V>(
        self,
        visitor: V,
    ) -> impl abi::Fiber<'d, Output = result::Result<(), crate::Error>>
    + use<'query, 'connection, 'd, R, Q, P, I, V>
    where
        V: for<'row> FnMut(R::Borrowed<'row>) -> ops::ControlFlow<()>,
    {
        exec::Rows::<I, Q, R, P, _>::new(self.machine, exec::Visit::new(visitor))
    }
}