mysql_binlog_connector_rust/command/
query_command.rs

1use std::io::Write;
2
3use byteorder::WriteBytesExt;
4
5use crate::binlog_error::BinlogError;
6
7use super::command_type::CommandType;
8
9pub struct QueryCommand {
10    pub sql: String,
11}
12
13impl QueryCommand {
14    pub fn to_bytes(&mut self) -> Result<Vec<u8>, BinlogError> {
15        let mut buf = Vec::new();
16        buf.write_u8(CommandType::Query as u8)?;
17        buf.write_all(self.sql.as_bytes())?;
18        Ok(buf)
19    }
20}