datafusion_cli/
highlighter.rs1use std::{
21 borrow::Cow::{self, Borrowed},
22 fmt::Display,
23};
24
25use datafusion::sql::sqlparser::{
26 dialect::{dialect_from_str, Dialect, GenericDialect},
27 keywords::Keyword,
28 tokenizer::{Token, Tokenizer},
29};
30use rustyline::highlight::{CmdKind, Highlighter};
31
32#[derive(Debug)]
34pub struct SyntaxHighlighter {
35 dialect: Box<dyn Dialect>,
36}
37
38impl SyntaxHighlighter {
39 pub fn new(dialect: &str) -> Self {
40 let dialect = dialect_from_str(dialect).unwrap_or(Box::new(GenericDialect {}));
41 Self { dialect }
42 }
43}
44
45pub struct NoSyntaxHighlighter {}
46
47impl Highlighter for NoSyntaxHighlighter {}
48
49impl Highlighter for SyntaxHighlighter {
50 fn highlight<'l>(&self, line: &'l str, _: usize) -> Cow<'l, str> {
51 let mut out_line = String::new();
52
53 let mut tokenizer =
55 Tokenizer::new(self.dialect.as_ref(), line).with_unescape(false);
56 let tokens = tokenizer.tokenize();
57 match tokens {
58 Ok(tokens) => {
59 for token in tokens.iter() {
60 match token {
61 Token::Word(w) if w.keyword != Keyword::NoKeyword => {
62 out_line.push_str(&Color::red(token));
63 }
64 Token::SingleQuotedString(_) => {
65 out_line.push_str(&Color::green(token));
66 }
67 other => out_line.push_str(&format!("{other}")),
68 }
69 }
70 out_line.into()
71 }
72 Err(_) => Borrowed(line),
73 }
74 }
75
76 fn highlight_char(&self, line: &str, _pos: usize, _cmd: CmdKind) -> bool {
77 !line.is_empty()
78 }
79}
80
81struct Color {}
83
84impl Color {
85 fn green(s: impl Display) -> String {
86 format!("\x1b[92m{s}\x1b[0m")
87 }
88
89 fn red(s: impl Display) -> String {
90 format!("\x1b[91m{s}\x1b[0m")
91 }
92}
93
94#[cfg(test)]
95mod tests {
96 use super::SyntaxHighlighter;
97 use rustyline::highlight::Highlighter;
98
99 #[test]
100 fn highlighter_valid() {
101 let s = "SElect col_a from tab_1;";
102 let highlighter = SyntaxHighlighter::new("generic");
103 let out = highlighter.highlight(s, s.len());
104 assert_eq!(
105 "\u{1b}[91mSElect\u{1b}[0m col_a \u{1b}[91mfrom\u{1b}[0m tab_1;",
106 out
107 );
108 }
109
110 #[test]
111 fn highlighter_valid_with_new_line() {
112 let s = "SElect col_a from tab_1\n WHERE col_b = 'なにか';";
113 let highlighter = SyntaxHighlighter::new("generic");
114 let out = highlighter.highlight(s, s.len());
115 assert_eq!(
116 "\u{1b}[91mSElect\u{1b}[0m col_a \u{1b}[91mfrom\u{1b}[0m tab_1\n \u{1b}[91mWHERE\u{1b}[0m col_b = \u{1b}[92m'なにか'\u{1b}[0m;",
117 out
118 );
119 }
120
121 #[test]
122 fn highlighter_invalid() {
123 let s = "SElect col_a from tab_1 WHERE col_b = ';";
124 let highlighter = SyntaxHighlighter::new("generic");
125 let out = highlighter.highlight(s, s.len());
126 assert_eq!("SElect col_a from tab_1 WHERE col_b = ';", out);
127 }
128}