diff --git a/src/main/java/com/alibaba/druid/sql/dialect/mysql/parser/MySqlStatementParser.java b/src/main/java/com/alibaba/druid/sql/dialect/mysql/parser/MySqlStatementParser.java index d1dcc91d3f..8e4833cd32 100644 --- a/src/main/java/com/alibaba/druid/sql/dialect/mysql/parser/MySqlStatementParser.java +++ b/src/main/java/com/alibaba/druid/sql/dialect/mysql/parser/MySqlStatementParser.java @@ -457,6 +457,11 @@ public class MySqlStatementParser extends SQLStatementParser { return parseCreateMaterializedView(); } + if(lexer.identifierEquals(FnvHash.Constants.ROLE)) { + lexer.reset(mark); + return parseCreateRole(); + } + throw new ParserException("TODO " + lexer.info()); } diff --git a/src/test/java/com/alibaba/druid/bvt/sql/mysql/issues/Issue4444.java b/src/test/java/com/alibaba/druid/bvt/sql/mysql/issues/Issue4444.java new file mode 100644 index 0000000000..e35e1096ab --- /dev/null +++ b/src/test/java/com/alibaba/druid/bvt/sql/mysql/issues/Issue4444.java @@ -0,0 +1,24 @@ +package com.alibaba.druid.bvt.sql.mysql.issues; + +import com.alibaba.druid.sql.ast.SQLStatement; +import com.alibaba.druid.sql.dialect.mysql.parser.MySqlStatementParser; +import com.alibaba.druid.sql.dialect.mysql.visitor.MySqlSchemaStatVisitor; +import com.alibaba.druid.stat.TableStat; +import org.junit.Test; + +import java.util.Map; + +import static org.junit.Assert.assertEquals; +import static org.junit.Assert.assertFalse; + +public class Issue4444 { + @Test + public void test_idle2() throws Exception { + String sql = "create role 'role1'"; + MySqlStatementParser parser = new MySqlStatementParser(sql); + SQLStatement statement = parser.parseStatement(); + MySqlSchemaStatVisitor visitor = new MySqlSchemaStatVisitor(); + statement.accept(visitor); + assertEquals("CREATE ROLE 'role1'", statement.toString()); + } +}