Function register_array_append

src/functions/array_functions.rs:164–200

array_append(array, element) - Append element to array

(conn: &Connection)

/// array_append(array, element) - Append element to array
fn register_array_append(conn: &Connection) -> Result<()> {
    conn.create_scalar_function(
        "array_append",
        2,
        FunctionFlags::SQLITE_UTF8 | FunctionFlags::SQLITE_DETERMINISTIC,
        |ctx| {
            let array_json: String = ctx.get(0)?;
            
            // Handle element parameter of different types
            let elem_value = match ctx.get_raw(1) {
                rusqlite::types::ValueRef::Text(s) => {
                    let text = std::str::from_utf8(s).unwrap_or("");
                    serde_json::from_str::<JsonValue>(text)
                        .unwrap_or_else(|_| JsonValue::String(text.to_string()))
                }
                rusqlite::types::ValueRef::Integer(i) => JsonValue::Number(serde_json::Number::from(i)),
                rusqlite::types::ValueRef::Real(f) => {
                    JsonValue::Number(serde_json::Number::from_f64(f).unwrap_or_else(|| serde_json::Number::from(0)))
                }
                rusqlite::types::ValueRef::Null => JsonValue::Null,
                rusqlite::types::ValueRef::Blob(b) => {
                    JsonValue::String(format!("\\x{}", hex::encode(b)))
                }
            };
            
            match serde_json::from_str::<JsonValue>(&array_json) {
                Ok(JsonValue::Array(mut arr)) => {
                    arr.push(elem_value);
                    Ok(serde_json::to_string(&arr).ok())
                }
                _ => Ok(None),
            }
        },
    )?;
    
    Ok(())
}

/// array_prepend(element, array) - Prepend element to array
fn register_array_prepend(conn: &Connection) -> Result<()> {