Method pg_array_to_json

src/protocol/binary.rs:187–262

Convert PostgreSQL text array format to JSON format PostgreSQL format: {1,2,3} or {"a","b","c"} JSON format: [1,2,3] or ["a","b","c"]

(pg_array: &str)

    /// PostgreSQL format: {1,2,3} or {"a","b","c"}
    /// JSON format: [1,2,3] or ["a","b","c"]
    fn pg_array_to_json(pg_array: &str) -> Result<String, String> {
        let trimmed = pg_array.trim();

        // If it's already JSON format, return as-is
        if trimmed.starts_with('[') && trimmed.ends_with(']') {
            return Ok(trimmed.to_string());
        }

        // Must be PostgreSQL format
        if !trimmed.starts_with('{') || !trimmed.ends_with('}') {
            return Err(format!("Invalid array format: {}", pg_array));
        }

        // Extract the content between { and }
        let inner = &trimmed[1..trimmed.len()-1];

        // Handle empty array
        if inner.is_empty() {
            return Ok("[]".to_string());
        }

        let mut json_elements = Vec::new();
        let mut current = String::new();
        let mut in_quotes = false;
        let mut escape_next = false;

        for ch in inner.chars() {
            if escape_next {
                current.push(ch);
                escape_next = false;
                continue;
            }

            if ch == '\\' && in_quotes {
                escape_next = true;
                current.push(ch);
                continue;
            }

            if ch == '"' {
                in_quotes = !in_quotes;
                current.push(ch);
            } else if ch == ',' && !in_quotes {
                // End of element
                let elem = current.trim();
                if elem == "NULL" {
                    json_elements.push("null".to_string());
                } else if elem.starts_with('"') && elem.ends_with('"') {
                    // Already quoted string
                    json_elements.push(elem.to_string());
                } else {
                    // Numeric or boolean value
                    json_elements.push(elem.to_string());
                }
                current.clear();
            } else {
                current.push(ch);
            }