diff --git a/src/main/java/com/zendesk/maxwell/schema/ddl/SchemaChange.java b/src/main/java/com/zendesk/maxwell/schema/ddl/SchemaChange.java index fde6c1048..2f057e459 100644 --- a/src/main/java/com/zendesk/maxwell/schema/ddl/SchemaChange.java +++ b/src/main/java/com/zendesk/maxwell/schema/ddl/SchemaChange.java @@ -39,6 +39,7 @@ public abstract class SchemaChange { SQL_BLACKLIST.add(Pattern.compile("\\A\\s*ANALYZE\\s+TABLE", Pattern.CASE_INSENSITIVE | Pattern.MULTILINE)); SQL_BLACKLIST.add(Pattern.compile("\\A\\s*SET\\s+PASSWORD", Pattern.CASE_INSENSITIVE | Pattern.MULTILINE)); SQL_BLACKLIST.add(Pattern.compile("\\A\\s*(ALTER|CREATE|DROP|RENAME)\\s+USER", Pattern.CASE_INSENSITIVE | Pattern.MULTILINE)); + SQL_BLACKLIST.add(Pattern.compile("\\A\\s*ALTER\\s+INSTANCE.*", Pattern.CASE_INSENSITIVE | Pattern.MULTILINE)); SQL_BLACKLIST.add(Pattern.compile("\\A\\s*(ALTER|CREATE|DROP)\\s+TEMPORARY\\s+TABLE", Pattern.CASE_INSENSITIVE | Pattern.MULTILINE)); SQL_BLACKLIST.add(Pattern.compile("\\A\\s*(ALTER|CREATE|DROP)\\s+TABLESPACE", Pattern.CASE_INSENSITIVE | Pattern.MULTILINE)); diff --git a/src/test/java/com/zendesk/maxwell/schema/ddl/DDLParserTest.java b/src/test/java/com/zendesk/maxwell/schema/ddl/DDLParserTest.java index 2c3c30fd7..6412a2603 100644 --- a/src/test/java/com/zendesk/maxwell/schema/ddl/DDLParserTest.java +++ b/src/test/java/com/zendesk/maxwell/schema/ddl/DDLParserTest.java @@ -620,4 +620,18 @@ public void testPolardbXCreateIndexSQL(){ assertThat(changes,is(nullValue())); } + + @Test + public void testServerInstanceOperations(){ + + List parse = parse("ALTER INSTANCE ROTATE INNODB MASTER KEY"); + List parse1 = parse("ALTER INSTANCE ROTATE BINLOG MASTER KEY"); + List parse2 = parse("ALTER INSTANCE RELOAD TLS"); + List parse3 = parse("ALTER INSTANCE RELOAD TLS NO ROLLBACK ON ERROR"); + + assertThat(parse,is(nullValue())); + assertThat(parse1,is(nullValue())); + assertThat(parse2,is(nullValue())); + assertThat(parse3,is(nullValue())); + } }