Struct PacketReader 

pub struct PacketReader<'a> { /* private fields */ }

A reader for MySQL protocol data.

Implementations

impl<'a> PacketReader<'a>

pub fn new(data: &'a [u8]) -> Self

Create a new reader from a byte slice.

pub fn remaining(&self) -> usize

Get remaining bytes in the buffer.

pub fn is_empty(&self) -> bool

Check if we’ve reached the end of the data.

pub fn peek(&self) -> Option<u8>

Peek at the next byte without advancing.

pub fn read_u8(&mut self) -> Option<u8>

Read a single byte.

pub fn read_u16_le(&mut self) -> Option<u16>

Read a u16 (little-endian).

pub fn read_u24_le(&mut self) -> Option<u32>

Read a u24 (little-endian, 3 bytes).

pub fn read_u32_le(&mut self) -> Option<u32>

Read a u32 (little-endian).

pub fn read_u64_le(&mut self) -> Option<u64>

Read a u64 (little-endian).

pub fn read_lenenc_int(&mut self) -> Option<u64>

Read a length-encoded integer.

MySQL uses a variable-length integer encoding:

• 0x00-0xFA: 1-byte value
• 0xFC: 2-byte value follows
• 0xFD: 3-byte value follows
• 0xFE: 8-byte value follows
• 0xFB: NULL (special case for length-encoded strings)

pub fn read_lenenc_string(&mut self) -> Option<String>

Read a length-encoded string.

pub fn read_lenenc_bytes(&mut self) -> Option<Vec<u8>>

Read a length-encoded byte slice.

pub fn read_null_string(&mut self) -> Option<String>

Read a null-terminated string.

pub fn read_string(&mut self, len: usize) -> Option<String>

Read a fixed-length string.

pub fn read_rest_string(&mut self) -> String

Read remaining data as a string.

pub fn read_bytes(&mut self, len: usize) -> Option<&'a [u8]>

Read a fixed number of bytes.

pub fn read_rest(&mut self) -> &'a [u8]

Read remaining bytes.

pub fn skip(&mut self, n: usize) -> bool

Skip a number of bytes.

pub fn read_packet_header(&mut self) -> Option<PacketHeader>

Read a packet header from raw bytes.

pub fn parse_ok_packet(&mut self) -> Option<OkPacket>

Parse an OK packet from the current position.

OK packet format (protocol 4.1+):

• 0x00 header (already consumed)
• affected_rows: lenenc int
• last_insert_id: lenenc int
• status_flags: 2 bytes
• warnings: 2 bytes
• info: rest of packet (optional)

pub fn parse_err_packet(&mut self) -> Option<ErrPacket>

Parse an Error packet from the current position.

ERR packet format (protocol 4.1+):

• 0xFF header (already consumed)
• error_code: 2 bytes
• ‘#’ marker
• sql_state: 5 bytes
• error_message: rest of packet

pub fn parse_eof_packet(&mut self) -> Option<EofPacket>

Parse an EOF packet from the current position.

EOF packet format:

• 0xFE header (already consumed)
• warnings: 2 bytes
• status_flags: 2 bytes

Trait Implementations

impl<'a> Debug for PacketReader<'a>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.