Skip to content

Commit fd4934e

Browse files
authored
Add support for + char in Snowflake stage names (#1935)
1 parent 8f1414e commit fd4934e

File tree

2 files changed

+21
-0
lines changed

2 files changed

+21
-0
lines changed

src/dialect/snowflake.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -735,6 +735,7 @@ pub fn parse_stage_name_identifier(parser: &mut Parser) -> Result<Ident, ParserE
735735
Token::Tilde => ident.push('~'),
736736
Token::Mod => ident.push('%'),
737737
Token::Div => ident.push('/'),
738+
Token::Plus => ident.push('+'),
738739
Token::Word(w) => ident.push_str(&w.to_string()),
739740
_ => return parser.expected("stage name identifier", parser.peek_token()),
740741
}

tests/sqlparser_snowflake.rs

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2581,6 +2581,26 @@ fn test_snowflake_copy_into() {
25812581
}
25822582
_ => unreachable!(),
25832583
}
2584+
2585+
// Test for non-ident characters in stage names
2586+
let sql = "COPY INTO a.b FROM @namespace.stage_name/x@x~x%x+";
2587+
assert_eq!(snowflake().verified_stmt(sql).to_string(), sql);
2588+
match snowflake().verified_stmt(sql) {
2589+
Statement::CopyIntoSnowflake { into, from_obj, .. } => {
2590+
assert_eq!(
2591+
into,
2592+
ObjectName::from(vec![Ident::new("a"), Ident::new("b")])
2593+
);
2594+
assert_eq!(
2595+
from_obj,
2596+
Some(ObjectName::from(vec![
2597+
Ident::new("@namespace"),
2598+
Ident::new("stage_name/x@x~x%x+")
2599+
]))
2600+
)
2601+
}
2602+
_ => unreachable!(),
2603+
}
25842604
}
25852605

25862606
#[test]

0 commit comments

Comments
 (0)