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 1cb68feba2..dd1b18f553 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 @@ -945,6 +945,26 @@ public class MySqlStatementParser extends SQLStatementParser { return stmt; } + + if (identifierEquals("RELAYLOG")) { + lexer.nextToken(); + acceptIdentifier("EVENTS"); + MySqlShowRelayLogEventsStatement stmt = new MySqlShowRelayLogEventsStatement(); + + if (lexer.token() == Token.IN) { + lexer.nextToken(); + stmt.setLogName(this.exprParser.primary()); + } + + if (lexer.token() == Token.FROM) { + lexer.nextToken(); + stmt.setFrom(this.exprParser.primary()); + } + + stmt.setLimit(this.parseLimit()); + + return stmt; + } if (identifierEquals("RELAYLOG")) { lexer.nextToken();