use crate::begin_batch::BeginBatch;
use crate::common::{FQName, Operand, RelationElement, TtlTimestamp};
use crate::delete::IndexedColumn;
use itertools::Itertools;
use std::fmt::{Display, Formatter};
#[derive(PartialEq, Debug, Clone)]
pub struct Update {
pub begin_batch: Option<BeginBatch>,
pub table_name: FQName,
pub using_ttl: Option<TtlTimestamp>,
pub assignments: Vec<AssignmentElement>,
pub where_clause: Vec<RelationElement>,
pub if_clause: Vec<RelationElement>,
pub if_exists: bool,
}
impl Display for Update {
fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
write!(
f,
"{}UPDATE {}{} SET {} WHERE {}{}",
self.begin_batch
.as_ref()
.map_or("".to_string(), |x| x.to_string()),
self.table_name,
self.using_ttl
.as_ref()
.map_or("".to_string(), |x| x.to_string()),
self.assignments.iter().map(|a| a.to_string()).join(", "),
self.where_clause.iter().join(" AND "),
if !self.if_clause.is_empty() {
format!(" IF {}", self.if_clause.iter().join(" AND "))
} else if self.if_exists {
" IF EXISTS".to_string()
} else {
"".to_string()
}
)
}
}
#[derive(PartialEq, Debug, Clone)]
pub struct AssignmentElement {
pub name: IndexedColumn,
pub value: Operand,
pub operator: Option<AssignmentOperator>,
}
impl Display for AssignmentElement {
fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
match &self.operator {
Some(x) => write!(f, "{} = {}{}", self.name, self.value, x),
None => write!(f, "{} = {}", self.name, self.value),
}
}
}
#[derive(PartialEq, Debug, Clone)]
pub enum AssignmentOperator {
Plus(Operand),
Minus(Operand),
}
impl Display for AssignmentOperator {
fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
match self {
AssignmentOperator::Plus(op) => write!(f, " + {}", op),
AssignmentOperator::Minus(op) => write!(f, " - {}", op),
}
}
}