Method bind

src/protocol/serializer.rs:186–228

(config: &BindConfig)

    }

    pub fn bind(config: &BindConfig) -> Vec<u8> {
        let mut writer = BufferWriter::default();
        let mut param_writer = BufferWriter::default();

        let portal = config.portal.as_deref().unwrap_or("");
        let statement = config.statement.as_deref().unwrap_or("");
        let values = &config.values;
        let len = values.len() as i16;

        writer.add_cstring(portal).add_cstring(statement);
        writer.add_int16(len);

        for (idx, value) in values.iter().enumerate() {
            let mapped = if let Some(mapper) = &config.value_mapper {
                mapper(value, idx)
            } else {
                value.clone()
            };

            match mapped {
                BindValue::Null => {
                    writer.add_int16(0);
                    param_writer.add_int32(-1);
                }
                BindValue::Binary(bytes) => {
                    writer.add_int16(1);
                    param_writer.add_int32(bytes.len() as i32);
                    param_writer.add_bytes(&bytes);
                }
                BindValue::Text(text) => {
                    writer.add_int16(0);
                    param_writer.add_int32(byte_length_utf8(&text) as i32);
                    param_writer.add_string(&text);
                }
            }
        }

        writer.add_int16(len);
        let param_body = param_writer.flush(None);
        writer.add_bytes(&param_body);
        writer.add_int16(if config.binary { 1 } else { 0 });
        writer.flush(Some(CODE_BIND))
    }

    pub fn execute(config: Option<&ExecConfig>) -> Vec<u8> {
        let Some(cfg) = config else {