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

use core::ops::Range;

use crate::{
  database::client::mysql::{
    ExecutorBuffer, MysqlExecutor, MysqlStatement, misc::send_packet,
    mysql_protocol::query_req::QueryReq,
  },
  misc::{LeaseMut, Stream, Vector, partitioned_filled_buffer::PartitionedFilledBuffer},
};

impl<E, EB, S> MysqlExecutor<E, EB, S>
where
  E: From<crate::Error>,
  EB: LeaseMut<ExecutorBuffer>,
  S: Stream,
{
  #[inline]
  pub(crate) async fn simple_query_execute(
    (capabilities, sequence_id): (&mut u64, &mut u8),
    cmd: &str,
    encode_buffer: &mut Vector<u8>,
    net_buffer: &mut PartitionedFilledBuffer,
    records_params: &mut Vector<(Range<usize>, Range<usize>)>,
    stream: &mut S,
    values_params: &mut Vector<(bool, Range<usize>)>,
    mut cb: impl FnMut(u64) -> Result<(), E>,
  ) -> Result<(), E> {
    send_packet(
      (capabilities, sequence_id),
      encode_buffer,
      QueryReq { query: cmd.as_bytes() },
      stream,
    )
    .await?;
    Self::fetch_cmd::<false, false>(
      *capabilities,
      net_buffer,
      records_params,
      sequence_id,
      &MysqlStatement::default(),
      stream,
      values_params,
      |num| {
        cb(num)?;
        Ok(())
      },
      |_| Ok(()),
    )
    .await?;
    Ok(())
  }
}