MysqlSchemaManager implements MysqlSchemaArchiver { public List<MysqlColumn> getTableColumns(String database, String table) { return isSchemaVersionEnabled ? schemaStore.get(database, table).getColumns() : schemaReader.getTableColumns(database, table); }  List<MysqlColumn> getTableColumns(String database, String table); void processDDL(QueryEvent event, String gtid); void initialize(BinlogFilePos pos); @Override void archive(); void compress();  }
@Test public void testSchemaVersionDisabled() { final MysqlSchemaManager schemaManagerWithSchemaVersionDisabled = new MysqlSchemaManager("test_source", null, null, schemaReader, mysqlClient, false); when(schemaReader.getTableColumns("db", "table")).thenReturn(TABLE1_COLUMNS); List<MysqlColumn> columns = schemaManagerWithSchemaVersionDisabled.getTableColumns("db", "table"); assertEquals(TABLE1_COLUMNS, columns); verify(schemaReader).getTableColumns("db", "table"); }