We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6f5a42d commit 726ab5dCopy full SHA for 726ab5d
tests/sqlparser_common.rs
@@ -3320,6 +3320,23 @@ fn parse_explain() {
3320
);
3321
}
3322
3323
+#[test]
3324
+fn parse_flush() {
3325
+ let ast = verified_stmt("FLUSH ALL SOURCES");
3326
+ assert_eq!(
3327
+ ast,
3328
+ Statement::FlushAllSources,
3329
+ );
3330
+
3331
+ let ast = verified_stmt("FLUSH SOURCE foo");
3332
3333
3334
+ Statement::FlushSource {
3335
+ name: ObjectName(vec![Ident::new("foo")])
3336
+ }
3337
3338
+}
3339
3340
fn parse_sql_statements(sql: &str) -> Result<Vec<Statement>, ParserError> {
3341
all_dialects().parse_sql_statements(sql)
3342
0 commit comments