wtx 0.28.0

A collection of different transport implementations and related tools focused primarily on web technologies.
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

/// ```sql
/// SELECT a,b,c,d FROM table WHERE e = $1 AND f = $2
/// ```
///
/// The columns are "a", "b", "c", "d" and the types are "$1" and "$2".
#[derive(Clone, Debug, Eq, PartialEq)]
pub(crate) struct Statement<'stmts, A, C, T> {
  pub(crate) aux: A,
  pub(crate) columns_len: usize,
  pub(crate) tys_len: usize,
  pub(crate) values: &'stmts [(C, T)],
}

impl<'stmts, A, C, T> Statement<'stmts, A, C, T> {
  #[inline]
  pub(crate) const fn new(
    aux: A,
    columns_len: usize,
    tys_len: usize,
    values: &'stmts [(C, T)],
  ) -> Self {
    Self { aux, columns_len, tys_len, values }
  }

  #[inline]
  pub(crate) fn _column(&self, idx: usize) -> Option<&C> {
    let columns = self.values.get(..self.columns_len)?;
    Some(&columns.get(idx)?.0)
  }

  #[inline]
  pub(crate) fn _columns(&self) -> impl Iterator<Item = &C> {
    let columns = self.values.get(..self.columns_len).unwrap_or_default();
    columns.iter().map(|el| &el.0)
  }

  #[cfg(test)]
  #[inline]
  pub(crate) fn _ty(&self, idx: usize) -> Option<&T> {
    Some(&self.values.get(..self.tys_len)?.get(idx)?.1)
  }

  #[inline]
  pub(crate) fn _tys(&self) -> impl Iterator<Item = &T> {
    self.values.get(..self.tys_len).unwrap_or_default().iter().map(|el| &el.1)
  }
}

impl<A, C, T> Default for Statement<'_, A, C, T>
where
  A: Default,
{
  #[inline]
  fn default() -> Self {
    Self { aux: A::default(), columns_len: 0, tys_len: 0, values: &mut [] }
  }
}

impl<'stmts, A, C, T> From<StatementMut<'stmts, A, C, T>> for Statement<'stmts, A, C, T> {
  #[inline]
  fn from(from: StatementMut<'stmts, A, C, T>) -> Self {
    Self::new(from.aux, *from.columns_len, *from.tys_len, from.values)
  }
}

#[derive(Debug, Eq, PartialEq)]
pub(crate) struct StatementMut<'stmts, A, C, T> {
  pub(crate) aux: A,
  pub(crate) columns_len: &'stmts mut usize,
  pub(crate) tys_len: &'stmts mut usize,
  pub(crate) values: &'stmts mut [(C, T)],
}

impl<'stmts, A, C, T> StatementMut<'stmts, A, C, T> {
  #[inline]
  pub(crate) const fn new(
    aux: A,
    columns_len: &'stmts mut usize,
    tys_len: &'stmts mut usize,
    values: &'stmts mut [(C, T)],
  ) -> Self {
    Self { aux, columns_len, tys_len, values }
  }

  #[inline]
  pub(crate) fn _tys_mut(&mut self) -> impl Iterator<Item = &mut T> {
    self.values.get_mut(..*self.tys_len).unwrap_or_default().iter_mut().map(|el| &mut el.1)
  }
}