use crate::lexer::{Token, TokenList, tokenize_internal};
use crate::keywords::{RegexToken, sql_regex, init_trie};
use crate::filters::{Filter, StmtFilter, TokenListFilter};
use crate::trie::TokenTypeTrie;
use super::splitter::StatementSplitter;
pub struct FilterStack {
regs: Vec<RegexToken>,
trie: TokenTypeTrie,
spliter: StatementSplitter,
pub preprocess: Vec<Box<dyn Filter>>,
pub stmtprocess: Vec<Box<dyn StmtFilter>>,
pub tlistprocess: Vec<Box<dyn TokenListFilter>>,
pub postprocess: Vec<Box<dyn StmtFilter>>,
}
impl FilterStack {
pub fn new() -> Self {
Self {
regs: sql_regex(),
trie: init_trie(),
spliter: StatementSplitter::default(),
preprocess: vec![],
stmtprocess: vec![],
postprocess: vec![],
tlistprocess: vec![],
}
}
pub fn run(&self, sql: &str, grouping: bool) -> Vec<Token> {
let mut tokens = tokenize_internal(sql, &self.regs, &self.trie);
if grouping {
tokens = super::grouping::group(tokens);
}
tokens
}
pub fn run_multi(&self, sql: &str, grouping: bool) -> Vec<Vec<Token>> {
let tokens = tokenize_internal(sql, &self.regs, &self.trie);
let stmts = self.spliter.process(tokens);
stmts.into_iter().map(|tokens| if grouping { super::grouping::group(tokens) } else { tokens }).collect()
}
pub fn format(&mut self, sql: &str, grouping: bool) -> Vec<Vec<Token>> {
let mut tokens = tokenize_internal(sql, &self.regs, &self.trie);
for token in tokens.iter_mut() {
self.preprocess.iter().for_each(|filter| filter.process(token));
}
let stmts = self.spliter.process(tokens);
let mut format_tokens = vec![];
for mut tokens in stmts.into_iter() {
if grouping {
tokens = super::grouping::group(tokens);
}
self.stmtprocess.iter().for_each(|filter| filter.process(&mut tokens));
let mut token_list = TokenList{ tokens: tokens };
self.tlistprocess.iter_mut().for_each(|filter| filter.process(&mut token_list));
tokens = std::mem::replace(&mut token_list.tokens, vec![]);
self.postprocess.iter().for_each(|filter| filter.process(&mut tokens));
format_tokens.push(tokens);
}
format_tokens
}
}