sqlness 0.6.1

SQL integration test harness
Documentation 
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

// Copyright 2022 CeresDB Project Authors. Licensed under Apache-2.0.

use crate::case::QueryContext;
use crate::error::Result;
use crate::interceptor::{Interceptor, InterceptorFactory, InterceptorRef};

pub const PREFIX: &str = "ARG";

/// Pass arguments to the [QueryContext].
///
/// # Example
/// ``` sql
/// -- SQLNESS ARG arg1=value1 arg2=value2
/// SELECT * FROM t;
/// ```
///
/// # Format
/// The arguments are in the format of `key=value`, without space. The key should not contains
/// equal marker (`=`), and value can be any string without space. The arguments are separated
/// by spaces.
///
/// It will overwrite existing key-value pair in context if the key name is same.
#[derive(Debug)]
pub struct ArgInterceptor {
    args: Vec<(String, String)>,
}

impl Interceptor for ArgInterceptor {
    fn before_execute(&self, _: &mut Vec<String>, context: &mut QueryContext) {
        for (key, value) in &self.args {
            context.context.insert(key.to_string(), value.to_string());
        }
    }
}

pub struct ArgInterceptorFactory;

impl InterceptorFactory for ArgInterceptorFactory {
    fn try_new(&self, ctx: &str) -> Result<InterceptorRef> {
        let args = Self::separate_key_value_pairs(ctx);
        Ok(Box::new(ArgInterceptor { args }))
    }
}

impl ArgInterceptorFactory {
    fn separate_key_value_pairs(input: &str) -> Vec<(String, String)> {
        let mut result = Vec::new();
        for pair in input.split(' ') {
            if let Some((key, value)) = pair.split_once('=') {
                result.push((key.to_string(), value.to_string()));
            }
        }
        result
    }
}

#[cfg(test)]
mod test {
    use super::*;

    #[test]
    fn cut_arg_string() {
        let input = "arg1=value1 arg2=value2 arg3=a=b=c arg4= arg5=,,,";
        let expected = vec![
            ("arg1".to_string(), "value1".to_string()),
            ("arg2".to_string(), "value2".to_string()),
            ("arg3".to_string(), "a=b=c".to_string()),
            ("arg4".to_string(), "".to_string()),
            ("arg5".to_string(), ",,,".to_string()),
        ];

        let args = ArgInterceptorFactory::separate_key_value_pairs(input);
        assert_eq!(args, expected);
    }
}