INNER CODE UNIT · Rust

handle

fcoury/oxide · src/commands/aggregate/mod.rs:28

    fn handle(
        &self,
        request: &Request,
        docs: &Vec<Document>,
    ) -> Result<Document, CommandExecutionError> {
        let doc = &docs[0];
        let db = doc.get_str("$db").unwrap();
        let collection = doc.get_str("aggregate").unwrap();
        let pipeline = doc.get_array("pipeline").unwrap();
        let sp = SqlParam::new(db, collection);

        let mut client = request.get_client();

        let sql = build_sql(&sp, pipeline);
        match sql {
            Ok(sql) => {
                log::debug!("SQL: {}", sql);

View source record →