@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");
}