Function register_array_prepend

src/functions/array_functions.rs:203–239

array_prepend(element, array) - Prepend element to array

(conn: &Connection)

/// array_prepend(element, array) - Prepend element to array
fn register_array_prepend(conn: &Connection) -> Result<()> {
    conn.create_scalar_function(
        "array_prepend",
        2,
        FunctionFlags::SQLITE_UTF8 | FunctionFlags::SQLITE_DETERMINISTIC,
        |ctx| {
            // Handle element parameter of different types
            let elem_value = match ctx.get_raw(0) {
                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)))
                }
            };
            
            let array_json: String = ctx.get(1)?;
            
            match serde_json::from_str::<JsonValue>(&array_json) {
                Ok(JsonValue::Array(mut arr)) => {
                    arr.insert(0, elem_value);
                    Ok(serde_json::to_string(&arr).ok())
                }
                _ => Ok(None),
            }
        },
    )?;
    
    Ok(())
}

/// array_cat(array1, array2) - Concatenate two arrays
fn register_array_cat(conn: &Connection) -> Result<()> {