rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-05-31 20:30:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: implement statement/execution timeout session variable (#4792)

Browse Source 
* support set and show on statement/execution timeout session variables.

* implement statement timeout for mysql read, and postgres queries

* add mysql test with max execution time
This commit is contained in:
Lanqing Yang
2024-11-14 22:19:39 -08:00
committed by GitHub
parent 42bf7e9965
commit cdba7b442f
13 changed files with 330 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

58
src/sql/src/parsers/set_var_parser.rs
View File

@@ -58,47 +58,83 @@ mod tests {
use crate::dialect::GreptimeDbDialect;
use crate::parser::ParseOptions;
fn assert_mysql_parse_result(sql: &str) {
fn assert_mysql_parse_result(sql: &str, indent_str: &str, expr: Expr) {
let result =
ParserContext::create_with_dialect(sql, &GreptimeDbDialect {}, ParseOptions::default());
let mut stmts = result.unwrap();
assert_eq!(
stmts.pop().unwrap(),
Statement::SetVariables(SetVariables {
variable: ObjectName(vec![Ident::new("time_zone")]),
value: vec![Expr::Value(Value::SingleQuotedString("UTC".to_string()))]
variable: ObjectName(vec![Ident::new(indent_str)]),
value: vec![expr]
})
);
}
fn assert_pg_parse_result(sql: &str) {
fn assert_pg_parse_result(sql: &str, indent: &str, expr: Expr) {
let result =
ParserContext::create_with_dialect(sql, &GreptimeDbDialect {}, ParseOptions::default());
let mut stmts = result.unwrap();
assert_eq!(
stmts.pop().unwrap(),
Statement::SetVariables(SetVariables {
variable: ObjectName(vec![Ident::new("TIMEZONE")]),
value: vec![Expr::Value(Value::SingleQuotedString("UTC".to_string()))],
variable: ObjectName(vec![Ident::new(indent)]),
value: vec![expr],
})
);
}
#[test]
pub fn test_set_timezone() {
let expected_utc_expr = Expr::Value(Value::SingleQuotedString("UTC".to_string()));
// mysql style
let sql = "SET time_zone = 'UTC'";
assert_mysql_parse_result(sql);
assert_mysql_parse_result(sql, "time_zone", expected_utc_expr.clone());
// session or local style
let sql = "SET LOCAL time_zone = 'UTC'";
assert_mysql_parse_result(sql);
assert_mysql_parse_result(sql, "time_zone", expected_utc_expr.clone());
let sql = "SET SESSION time_zone = 'UTC'";
assert_mysql_parse_result(sql);
assert_mysql_parse_result(sql, "time_zone", expected_utc_expr.clone());
// postgresql style
let sql = "SET TIMEZONE TO 'UTC'";
assert_pg_parse_result(sql);
assert_pg_parse_result(sql, "TIMEZONE", expected_utc_expr.clone());
let sql = "SET TIMEZONE 'UTC'";
assert_pg_parse_result(sql);
assert_pg_parse_result(sql, "TIMEZONE", expected_utc_expr);
}
#[test]
pub fn test_set_query_timeout() {
let expected_query_timeout_expr = Expr::Value(Value::Number("5000".to_string(), false));
// mysql style
let sql = "SET MAX_EXECUTION_TIME = 5000";
assert_mysql_parse_result(
sql,
"MAX_EXECUTION_TIME",
expected_query_timeout_expr.clone(),
);
// session or local style
let sql = "SET LOCAL MAX_EXECUTION_TIME = 5000";
assert_mysql_parse_result(
sql,
"MAX_EXECUTION_TIME",
expected_query_timeout_expr.clone(),
);
let sql = "SET SESSION MAX_EXECUTION_TIME = 5000";
assert_mysql_parse_result(
sql,
"MAX_EXECUTION_TIME",
expected_query_timeout_expr.clone(),
);
// postgresql style
let sql = "SET STATEMENT_TIMEOUT = 5000";
assert_pg_parse_result(
sql,
"STATEMENT_TIMEOUT",
expected_query_timeout_expr.clone(),
);
let sql = "SET STATEMENT_TIMEOUT TO 5000";
assert_pg_parse_result(sql, "STATEMENT_TIMEOUT", expected_query_timeout_expr);
}
}