1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160
use std::collections::VecDeque; use indexmap::IndexMap as Map; use crate::sql::Expr; use crate::sql::Selector; use crate::sql::SelectorNode; use crate::value::PqlValue; #[derive(Debug, Default, Clone)] pub struct Env { data: Map<String, Expr>, } impl From<PqlValue> for Env { fn from(value: PqlValue) -> Self { let mut env = Self::default(); env.insert("", &Expr::from(value)); env } } impl Env { pub fn insert(&mut self, alias: &str, expr: &Expr) -> Option<Expr> { self.data.insert(alias.to_string(), expr.to_owned()) } pub fn insert_from_selector(&mut self, alias: &str, selector: &Selector) -> Option<Expr> { let value = Expr::Selector(selector.to_owned()); self.insert(alias, &value) } pub fn insert_from_pqlval(&mut self, alias: &str, value: &PqlValue) -> Option<Expr> { let value = Expr::Value(value.to_owned()); self.insert(alias, &value) } pub fn get(&self, key: &str) -> Option<Expr> { self.data.get(key).map(|e| e.to_owned()) } pub fn get_mut(&mut self, key: &str) -> Option<&mut Expr> { self.data.get_mut(key) } pub fn get_by_selector(&self, selector: &Selector) -> Option<PqlValue> { if let Some((head, tail)) = selector.split_first() { if let Some(expr) = self.get(head.to_string().as_str()) { match expr { Expr::Value(value) => { let v = if tail.data.len() > 0 { value.select_by_selector(&tail) } else { Some(value) }; v } _ => todo!(), } } else { todo!() } } else { unreachable!() } } pub fn get_as_selector(&self, key: &str) -> Option<Selector> { match self.get(key) { Some(Expr::Selector(selector)) => Some(selector), _ => None, } } fn rec_get_full_path(&self, selector: &Selector, trace_path: &mut Selector) { if let Some((first, tail)) = selector.split_first() { if let Some(alias_path) = self.get_as_selector(&first.to_string()) { self.rec_get_full_path(&alias_path, trace_path) } else { (*trace_path) .data .push_back(SelectorNode::String(first.to_string())); } if tail.data.len() > 0 { let tail_path = Selector::from(tail); let mut vec_path = tail_path .to_vec() .into_iter() .map(|s| SelectorNode::String(s.to_string())) .collect::<VecDeque<_>>(); (*trace_path).data.append(&mut vec_path); } } } pub fn expand_fullpath_as_selector(&self, selector: &Selector) -> Selector { let mut trace_path = Selector::default(); self.rec_get_full_path(selector, &mut trace_path); trace_path } pub fn expand_fullpath(&self, expr: &Expr) -> Expr { expr.expand_fullpath(self) } } #[cfg(test)] mod tests { use std::str::FromStr; use super::Env; use crate::planner::Drain; use crate::sql::Expr; use crate::sql::Field; use crate::sql::Sql; #[test] fn get_full_path() -> anyhow::Result<()> { let sql = Sql::from_str( r#" SELECT e.name AS employeeName, p.name AS projectName FROM hr.employeesNest AS e, e.projects AS p "#, )?; let mut env = Env::default(); Drain(sql.from_clause).execute(&mut env); assert_eq!( env.expand_fullpath(&Field::from_str("e.name AS employeeName")?.expr) .to_string(), "hr.employeesNest.name", ); assert_eq!( env.expand_fullpath(&Field::from_str("p.name AS projectName")?.expr) .to_string(), "hr.employeesNest.projects.name", ); Ok(()) } #[test] fn test_update_env() -> anyhow::Result<()> { let mut env = Env::default(); env.insert("name", &Expr::from("Alice")); if let Some(name) = env.get_mut("name") { *name = Expr::from("Bob"); } assert_eq!(env.get("name"), Some(Expr::from("Bob"))); Ok(()) } }