Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions fuzz/fuzz_seeds/mssql_2702_alter_role_rename.sql
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
ALTER ROLE old_name WITH NAME = new_name
1 change: 1 addition & 0 deletions fuzz/fuzz_seeds/mssql_2702_declare_list.sql
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
DECLARE @foo CURSOR, @bar INT, @baz AS TEXT = 'foobar'
11 changes: 11 additions & 0 deletions src/ast/dcl.rs
Original file line number Diff line number Diff line change
Expand Up @@ -150,6 +150,14 @@ pub enum AlterRoleOperation {
},
/// MS SQL Server
/// <https://learn.microsoft.com/en-us/sql/t-sql/statements/alter-role-transact-sql>
///
/// `ALTER ROLE role_name WITH NAME = new_name`
RenameRoleWithName {
/// New name for the role.
role_name: Ident,
},
/// MS SQL Server
/// <https://learn.microsoft.com/en-us/sql/t-sql/statements/alter-role-transact-sql>
AddMember {
/// Member name to add to the role.
member_name: Ident,
Expand Down Expand Up @@ -197,6 +205,9 @@ impl fmt::Display for AlterRoleOperation {
AlterRoleOperation::RenameRole { role_name } => {
write!(f, "RENAME TO {role_name}")
}
AlterRoleOperation::RenameRoleWithName { role_name } => {
write!(f, "WITH NAME = {role_name}")
}
AlterRoleOperation::AddMember { member_name } => {
write!(f, "ADD MEMBER {member_name}")
}
Expand Down
26 changes: 24 additions & 2 deletions src/ast/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -3097,6 +3097,19 @@ impl fmt::Display for DeclareAssignment {
}
}

/// The delimiter separating the declarations collected by a `DECLARE`
/// statement ([Statement::Declare]).
#[derive(Debug, Clone, Copy, PartialEq, PartialOrd, Eq, Ord, Hash)]
#[cfg_attr(feature = "serde", derive(Serialize, Deserialize))]
#[cfg_attr(feature = "visitor", derive(Visit, VisitMut))]
pub enum DeclareDelimiter {
/// Comma-separated declarations, e.g. `DECLARE @a INT, @b INT` (MsSql).
Comma,
/// Semicolon-separated declarations, e.g. `DECLARE a INT; b INT`
/// (Snowflake).
Semicolon,
}

/// Represents the type of a `DECLARE` statement.
#[derive(Debug, Clone, PartialEq, PartialOrd, Eq, Ord, Hash)]
#[cfg_attr(feature = "serde", derive(Serialize, Deserialize))]
Expand Down Expand Up @@ -4088,6 +4101,8 @@ pub enum Statement {
Declare {
/// Cursor declaration statements collected by `DECLARE`.
stmts: Vec<Declare>,
/// The delimiter used between the collected declarations.
delimiter: DeclareDelimiter,
},
/// ```sql
/// CREATE EXTENSION [ IF NOT EXISTS ] extension_name
Expand Down Expand Up @@ -5266,9 +5281,16 @@ impl fmt::Display for Statement {
write!(f, "{statement}")
}
Statement::Query(s) => s.fmt(f),
Statement::Declare { stmts } => {
Statement::Declare { stmts, delimiter } => {
write!(f, "DECLARE ")?;
write!(f, "{}", display_separated(stmts, "; "))
match delimiter {
DeclareDelimiter::Comma => {
write!(f, "{}", display_comma_separated(stmts))
}
DeclareDelimiter::Semicolon => {
write!(f, "{}", display_separated(stmts, "; "))
}
}
}
Statement::Fetch {
name,
Expand Down
2 changes: 1 addition & 1 deletion src/parser/alter.rs
Original file line number Diff line number Diff line change
Expand Up @@ -356,7 +356,7 @@ impl Parser<'_> {
} else if self.parse_keywords(&[Keyword::WITH, Keyword::NAME]) {
if self.consume_token(&Token::Eq) {
let role_name = self.parse_identifier()?;
AlterRoleOperation::RenameRole { role_name }
AlterRoleOperation::RenameRoleWithName { role_name }
} else {
return self.expected_ref("= after WITH NAME ", self.peek_token_ref());
}
Expand Down
12 changes: 10 additions & 2 deletions src/parser/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -8004,6 +8004,7 @@ impl<'a> Parser<'a> {
let query = Some(self.parse_query()?);

Ok(Statement::Declare {
delimiter: DeclareDelimiter::Comma,
stmts: vec![Declare {
names: vec![name],
data_type: None,
Expand Down Expand Up @@ -8047,6 +8048,7 @@ impl<'a> Parser<'a> {
};

Ok(Statement::Declare {
delimiter: DeclareDelimiter::Comma,
stmts: vec![Declare {
names,
data_type,
Expand Down Expand Up @@ -8174,7 +8176,10 @@ impl<'a> Parser<'a> {
break;
}

Ok(Statement::Declare { stmts })
Ok(Statement::Declare {
stmts,
delimiter: DeclareDelimiter::Semicolon,
})
}

/// Parse a [MsSql] `DECLARE` statement.
Expand All @@ -8191,7 +8196,10 @@ impl<'a> Parser<'a> {
pub fn parse_mssql_declare(&mut self) -> Result<Statement, ParserError> {
let stmts = self.parse_comma_separated(Parser::parse_mssql_declare_stmt)?;

Ok(Statement::Declare { stmts })
Ok(Statement::Declare {
stmts,
delimiter: DeclareDelimiter::Comma,
})
}

/// Parse the body of a [MsSql] `DECLARE`statement.
Expand Down
2 changes: 1 addition & 1 deletion tests/sqlparser_bigquery.rs
Original file line number Diff line number Diff line change
Expand Up @@ -2191,7 +2191,7 @@ fn parse_big_query_declare() {
),
] {
match bigquery().verified_stmt(sql) {
Statement::Declare { mut stmts } => {
Statement::Declare { mut stmts, .. } => {
assert_eq!(1, stmts.len());
let Declare {
names,
Expand Down
12 changes: 8 additions & 4 deletions tests/sqlparser_mssql.rs
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,7 @@ use test_utils::*;

use sqlparser::ast::DataType::{Int, Text, Varbinary};
use sqlparser::ast::DeclareAssignment::MsSqlAssignment;
use sqlparser::ast::DeclareDelimiter;
use sqlparser::ast::Value::SingleQuotedString;
use sqlparser::ast::*;
use sqlparser::dialect::{GenericDialect, MsSqlDialect};
Expand Down Expand Up @@ -800,21 +801,21 @@ fn parse_mssql_create_role() {
fn parse_alter_role() {
let sql = "ALTER ROLE old_name WITH NAME = new_name";
assert_eq!(
ms().parse_sql_statements(sql).unwrap(),
[Statement::AlterRole {
ms().verified_stmt(sql),
Statement::AlterRole {
name: Ident {
value: "old_name".into(),
quote_style: None,
span: Span::empty(),
},
operation: AlterRoleOperation::RenameRole {
operation: AlterRoleOperation::RenameRoleWithName {
role_name: Ident {
value: "new_name".into(),
quote_style: None,
span: Span::empty(),
}
},
}]
}
);

let sql = "ALTER ROLE role_name ADD MEMBER new_member";
Expand Down Expand Up @@ -1423,10 +1424,12 @@ fn parse_substring_in_select() {
#[test]
fn parse_mssql_declare() {
let sql = "DECLARE @foo CURSOR, @bar INT, @baz AS TEXT = 'foobar';";
let _ = ms().verified_stmt("DECLARE @foo CURSOR, @bar INT, @baz TEXT = 'foobar'");
let ast = ms().parse_sql_statements(sql).unwrap();

assert_eq!(
vec![Statement::Declare {
delimiter: DeclareDelimiter::Comma,
stmts: vec![
Declare {
names: vec![Ident {
Expand Down Expand Up @@ -1485,6 +1488,7 @@ fn parse_mssql_declare() {
assert_eq!(
vec![
Statement::Declare {
delimiter: DeclareDelimiter::Comma,
stmts: vec![Declare {
names: vec![Ident::new("@bar"),],
data_type: Some(Int(None)),
Expand Down
10 changes: 5 additions & 5 deletions tests/sqlparser_snowflake.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1739,7 +1739,7 @@ fn parse_snowflake_declare_cursor() {
),
] {
match snowflake().verified_stmt(sql) {
Statement::Declare { mut stmts } => {
Statement::Declare { mut stmts, .. } => {
assert_eq!(1, stmts.len());
let Declare {
names,
Expand Down Expand Up @@ -1807,7 +1807,7 @@ fn parse_snowflake_declare_result_set() {
("DECLARE res RESULTSET", "res", None),
] {
match snowflake().verified_stmt(sql) {
Statement::Declare { mut stmts } => {
Statement::Declare { mut stmts, .. } => {
assert_eq!(1, stmts.len());
let Declare {
names,
Expand Down Expand Up @@ -1860,7 +1860,7 @@ fn parse_snowflake_declare_exception() {
("DECLARE ex EXCEPTION", "ex", None),
] {
match snowflake().verified_stmt(sql) {
Statement::Declare { mut stmts } => {
Statement::Declare { mut stmts, .. } => {
assert_eq!(1, stmts.len());
let Declare {
names,
Expand Down Expand Up @@ -1900,7 +1900,7 @@ fn parse_snowflake_declare_variable() {
("DECLARE profit", "profit", None, None),
] {
match snowflake().verified_stmt(sql) {
Statement::Declare { mut stmts } => {
Statement::Declare { mut stmts, .. } => {
assert_eq!(1, stmts.len());
let Declare {
names,
Expand Down Expand Up @@ -1950,7 +1950,7 @@ fn parse_snowflake_declare_multi_statements() {
"ex EXCEPTION (-20003, 'ERROR: Could not create table.')"
);
match snowflake().verified_stmt(sql) {
Statement::Declare { stmts } => {
Statement::Declare { stmts, .. } => {
let actual = stmts
.iter()
.map(|stmt| (stmt.names[0].value.as_str(), stmt.declare_type.clone()))
Expand Down
Loading