iridium_server 0.1.12

TDS 7.4 server for Iridium SQL
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

mod decode;
mod parser;
mod render;
mod types;

pub use parser::{
    parse_rpc, CatalogProc, CursorOp, CursorRpcRequest, RpcProc, RpcRequest, SqlRpcRequest,
};
pub use render::{build_param_preamble, build_param_preamble_with_decls};
pub use types::{RpcParam, RpcRequest as RpcRequestType};

pub use parser::{
    parse_param_decl, CatalogRpcRequest, ExecuteRpcRequest, PrepExecRpcRequest, PrepareRpcRequest,
    UnprepareRpcRequest,
};

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

    #[test]
    fn build_param_preamble_scalar_and_tvp() {
        let params = vec![
            RpcParam {
                name: "@x".to_string(),
                type_name: "INT".to_string(),
                value_sql: "42".to_string(),
                tvp_rows: None,
            },
            RpcParam {
                name: "@tvp".to_string(),
                type_name: "dbo.IntList READONLY".to_string(),
                value_sql: "NULL".to_string(),
                tvp_rows: Some(vec![vec!["1".to_string()], vec!["2".to_string()]]),
            },
        ];
        let sql = build_param_preamble(&params);
        assert!(sql.contains("DECLARE @x INT = 42;"));
        assert!(sql.contains("DECLARE @tvp dbo.IntList;"));
        assert!(sql.contains("INSERT INTO @tvp VALUES (1);"));
        assert!(sql.contains("INSERT INTO @tvp VALUES (2);"));
    }

    #[test]
    fn normalize_decl_type_strips_readonly() {
        assert_eq!(render::normalize_decl_type("dbo.T READONLY"), "dbo.T");
        assert_eq!(render::normalize_decl_type("dbo.T"), "dbo.T");
    }
}