Method parse_query

src/protocol/parser.rs:205–219

(&self, cursor: &mut Cursor<&[u8]>, length: u32)

    }

    pub async fn parse_query(&self, cursor: &mut Cursor<&[u8]>, length: u32) -> Result<FrontendMessage, ParseError> {
        let sql = self.read_cstring_with_length(cursor, length as usize).await?;

        // Security: basic SQL injection detection
        let sql_lower = sql.to_lowercase();
        if sql_lower.contains("drop table") ||
           sql_lower.contains("delete from") ||
           sql_lower.contains("truncate") ||
           sql_lower.contains("' or '1'='1") ||
           sql_lower.contains("union select") {
            events::sql_injection_attempt(None, None, &sql, "Suspicious SQL pattern detected");
        }

        Ok(FrontendMessage::Query(sql))
    }

    async fn parse_ssl_request(&self, cursor: &mut Cursor<&[u8]>) -> Result<FrontendMessage, ParseError> {
        // SSL request has a specific format: 8 bytes total