Method do_execute

examples/proxy_cloudflare_worker_example/src/orm.rs:103–166

(env: Arc<Env>, statement: Statement)

    }

    async fn do_execute(env: Arc<Env>, statement: Statement) -> Result<ProxyExecResult> {
        let sql = statement.sql.clone();
        let values = match statement.values {
            Some(Values(values)) => values
                .iter()
                .map(|val| match &val {
                    Value::BigInt(Some(val)) => JsValue::from(val.to_string()),
                    Value::BigUnsigned(Some(val)) => JsValue::from(val.to_string()),
                    Value::Int(Some(val)) => JsValue::from(*val),
                    Value::Unsigned(Some(val)) => JsValue::from(*val),
                    Value::SmallInt(Some(val)) => JsValue::from(*val),
                    Value::SmallUnsigned(Some(val)) => JsValue::from(*val),
                    Value::TinyInt(Some(val)) => JsValue::from(*val),
                    Value::TinyUnsigned(Some(val)) => JsValue::from(*val),

                    Value::Float(Some(val)) => JsValue::from_f64(*val as f64),
                    Value::Double(Some(val)) => JsValue::from_f64(*val),

                    Value::Bool(Some(val)) => JsValue::from(*val),
                    Value::Bytes(Some(val)) => JsValue::from(format!(
                        "X'{}'",
                        val.iter()
                            .map(|byte| format!("{:02x}", byte))
                            .collect::<String>()
                    )),
                    Value::Char(Some(val)) => JsValue::from(val.to_string()),
                    Value::Json(Some(val)) => JsValue::from(val.to_string()),
                    Value::String(Some(val)) => JsValue::from(val.to_string()),

                    Value::ChronoDate(Some(val)) => JsValue::from(val.to_string()),
                    Value::ChronoDateTime(Some(val)) => JsValue::from(val.to_string()),
                    Value::ChronoDateTimeLocal(Some(val)) => JsValue::from(val.to_string()),
                    Value::ChronoDateTimeUtc(Some(val)) => JsValue::from(val.to_string()),
                    Value::ChronoDateTimeWithTimeZone(Some(val)) => JsValue::from(val.to_string()),

                    _ => JsValue::NULL,
                })
                .collect(),
            None => Vec::new(),
        };

        let ret = env
            .d1("test-d1")?
            .prepare(sql)
            .bind(&values)?
            .run()
            .await?
            .meta()?;
        console_log!("SQL execute result: {:?}", ret);

        let last_insert_id = ret
            .as_ref()
            .map(|meta| meta.last_row_id.unwrap_or(0))
            .unwrap_or(0) as u64;
        let rows_affected = ret
            .as_ref()
            .map(|meta| meta.rows_written.unwrap_or(0))
            .unwrap_or(0) as u64;