Function encode_data_row

src/protocol/codec.rs:266–292

(values: &[Option<Vec<u8>>], dst: &mut BytesMut)

}

fn encode_data_row(values: &[Option<Vec<u8>>], dst: &mut BytesMut) {
    // Debug logging for array fields
    if values.len() == 1
        && let Some(Some(data)) = values.first()
            && data.len() == 41 {
                println!("DEBUG: encode_data_row sending 41-byte field (likely array with nulls)");
                println!("  Data length being written: {}", data.len());
            }

    dst.put_u8(b'D');
    let len_pos = dst.len();
    dst.put_i32(0); // Placeholder

    dst.put_i16(values.len() as i16);

    for value in values {
        match value {
            None => dst.put_i32(-1),
            Some(data) => {
                dst.put_i32(data.len() as i32);
                dst.put_slice(data);
            }
        }
    }

    update_message_length(dst, len_pos);
}

fn encode_command_complete(tag: &str, dst: &mut BytesMut) {
    dst.put_u8(b'C');