use super::{view::ViewRef, Expression, IntoExpression, Visitor};
use crate::Tuple;
use std::{
cell::{RefCell, RefMut},
marker::PhantomData,
rc::Rc,
};
#[derive(Clone)]
pub struct Product<L, R, Left, Right, T>
where
L: Tuple,
R: Tuple,
T: Tuple,
Left: Expression<L>,
Right: Expression<R>,
{
left: Left,
right: Right,
mapper: Rc<RefCell<dyn FnMut(&L, &R) -> T>>,
relation_deps: Vec<String>,
view_deps: Vec<ViewRef>,
}
impl<L, R, Left, Right, T> Product<L, R, Left, Right, T>
where
L: Tuple,
R: Tuple,
T: Tuple,
Left: Expression<L>,
Right: Expression<R>,
{
pub fn new<IL, IR>(left: IL, right: IR, project: impl FnMut(&L, &R) -> T + 'static) -> Self
where
IL: IntoExpression<L, Left>,
IR: IntoExpression<R, Right>,
{
use super::dependency;
let left = left.into_expression();
let right = right.into_expression();
let mut deps = dependency::DependencyVisitor::new();
left.visit(&mut deps);
right.visit(&mut deps);
let (relation_deps, view_deps) = deps.into_dependencies();
Self {
left,
right,
mapper: Rc::new(RefCell::new(project)),
relation_deps: relation_deps.into_iter().collect(),
view_deps: view_deps.into_iter().collect(),
}
}
#[inline(always)]
pub fn left(&self) -> &Left {
&self.left
}
#[inline(always)]
pub fn right(&self) -> &Right {
&self.right
}
#[inline(always)]
pub fn mapper_mut(&self) -> RefMut<dyn FnMut(&L, &R) -> T> {
self.mapper.borrow_mut()
}
#[inline(always)]
pub(crate) fn relation_deps(&self) -> &[String] {
&self.relation_deps
}
#[inline(always)]
pub(crate) fn view_deps(&self) -> &[ViewRef] {
&self.view_deps
}
}
impl<L, R, Left, Right, T> Expression<T> for Product<L, R, Left, Right, T>
where
L: Tuple,
R: Tuple,
T: Tuple,
Left: Expression<L>,
Right: Expression<R>,
{
fn visit<V>(&self, visitor: &mut V)
where
V: Visitor,
{
visitor.visit_product(&self);
}
}
#[derive(Debug)]
struct Debuggable<L, R, Left, Right>
where
L: Tuple,
R: Tuple,
Left: Expression<L>,
Right: Expression<R>,
{
left: Left,
right: Right,
_marker: PhantomData<(L, R)>,
}
impl<L, R, Left, Right, T> std::fmt::Debug for Product<L, R, Left, Right, T>
where
L: Tuple,
R: Tuple,
T: Tuple,
Left: Expression<L>,
Right: Expression<R>,
{
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
Debuggable {
left: self.left.clone(),
right: self.right.clone(),
_marker: PhantomData,
}
.fmt(f)
}
}
#[cfg(test)]
mod tests {
use super::*;
use crate::{Database, Tuples};
#[test]
fn test_clone() {
let mut database = Database::new();
let r = database.add_relation::<i32>("r").unwrap();
let s = database.add_relation::<i32>("s").unwrap();
database.insert(&r, vec![1, 10].into()).unwrap();
database.insert(&s, vec![1, 100].into()).unwrap();
let v = Product::new(&r, &s, |&l, &r| l + r).clone();
assert_eq!(
Tuples::from(vec![2, 11, 101, 110]),
database.evaluate(&v).unwrap()
);
}
}