@Test public void testRenameColumnCannotRemoveSomeMetadataPrev() throws Exception { renameColumn(new TestFilesFacade() { int count = 5; @Override public boolean exists(LPSZ path) { if (Chars.contains(path, TableUtils.META_PREV_FILE_NAME) && --count > 0) { return true; } return super.exists(path); } @Override public boolean remove(LPSZ name) { return !Chars.contains(name, TableUtils.META_PREV_FILE_NAME) && super.remove(name); } @Override public boolean wasCalled() { return count <= 0; } }); }
public void renameColumn(CharSequence currentName, CharSequence newName) { checkDistressed(); final int index = getColumnIndex(currentName); final int type = metadata.getColumnType(index); LOG.info().$("renaming column '").utf8(currentName).$("' to '").utf8(newName).$("' from ").$(path).$(); commit(); this.metaSwapIndex = renameColumnFromMeta(index, newName); metaMem.close(); renameMetaToMetaPrev(currentName); writeRestoreMetaTodo(currentName); renameSwapMetaToMeta(currentName); try { openMetaFile(); removeTodoFile(); renameColumnFiles(currentName, newName, type); } catch (CairoException err) { throwDistressException(err); } bumpStructureVersion(); metadata.renameColumn(currentName, newName); LOG.info().$("RENAMED column '").utf8(currentName).$("' to '").utf8(newName).$("' from ").$(path).$(); }
TableWriter implements Closeable { public void renameColumn(CharSequence currentName, CharSequence newName) { checkDistressed(); final int index = getColumnIndex(currentName); final int type = metadata.getColumnType(index); LOG.info().$("renaming column '").utf8(currentName).$("' to '").utf8(newName).$("' from ").$(path).$(); commit(); this.metaSwapIndex = renameColumnFromMeta(index, newName); metaMem.close(); renameMetaToMetaPrev(currentName); writeRestoreMetaTodo(currentName); renameSwapMetaToMeta(currentName); try { openMetaFile(); removeTodoFile(); renameColumnFiles(currentName, newName, type); } catch (CairoException err) { throwDistressException(err); } bumpStructureVersion(); metadata.renameColumn(currentName, newName); LOG.info().$("RENAMED column '").utf8(currentName).$("' to '").utf8(newName).$("' from ").$(path).$(); } }
TableWriter implements Closeable { public void renameColumn(CharSequence currentName, CharSequence newName) { checkDistressed(); final int index = getColumnIndex(currentName); final int type = metadata.getColumnType(index); LOG.info().$("renaming column '").utf8(currentName).$("' to '").utf8(newName).$("' from ").$(path).$(); commit(); this.metaSwapIndex = renameColumnFromMeta(index, newName); metaMem.close(); renameMetaToMetaPrev(currentName); writeRestoreMetaTodo(currentName); renameSwapMetaToMeta(currentName); try { openMetaFile(); removeTodoFile(); renameColumnFiles(currentName, newName, type); } catch (CairoException err) { throwDistressException(err); } bumpStructureVersion(); metadata.renameColumn(currentName, newName); LOG.info().$("RENAMED column '").utf8(currentName).$("' to '").utf8(newName).$("' from ").$(path).$(); } TableWriter(CairoConfiguration configuration, CharSequence name);  TableWriter(CairoConfiguration configuration, CharSequence name, MessageBus messageBus);  TableWriter(
            CairoConfiguration configuration,
            CharSequence name,
            @Nullable MessageBus messageBus,
            boolean lock,
            LifecycleManager lifecycleManager
    );  TableWriter(
            CairoConfiguration configuration,
            CharSequence name,
            @Nullable MessageBus messageBus,
            boolean lock,
            LifecycleManager lifecycleManager,
            CharSequence root
    ); }
TableWriter implements Closeable { public void renameColumn(CharSequence currentName, CharSequence newName) { checkDistressed(); final int index = getColumnIndex(currentName); final int type = metadata.getColumnType(index); LOG.info().$("renaming column '").utf8(currentName).$("' to '").utf8(newName).$("' from ").$(path).$(); commit(); this.metaSwapIndex = renameColumnFromMeta(index, newName); metaMem.close(); renameMetaToMetaPrev(currentName); writeRestoreMetaTodo(currentName); renameSwapMetaToMeta(currentName); try { openMetaFile(); removeTodoFile(); renameColumnFiles(currentName, newName, type); } catch (CairoException err) { throwDistressException(err); } bumpStructureVersion(); metadata.renameColumn(currentName, newName); LOG.info().$("RENAMED column '").utf8(currentName).$("' to '").utf8(newName).$("' from ").$(path).$(); } TableWriter(CairoConfiguration configuration, CharSequence name);  TableWriter(CairoConfiguration configuration, CharSequence name, MessageBus messageBus);  TableWriter(
            CairoConfiguration configuration,
            CharSequence name,
            @Nullable MessageBus messageBus,
            boolean lock,
            LifecycleManager lifecycleManager
    );  TableWriter(
            CairoConfiguration configuration,
            CharSequence name,
            @Nullable MessageBus messageBus,
            boolean lock,
            LifecycleManager lifecycleManager,
            CharSequence root
    ); static TimestampFormat selectPartitionDirFmt(int partitionBy); void addColumn(CharSequence name, int type); void addColumn(
            CharSequence name,
            int type,
            int symbolCapacity,
            boolean symbolCacheFlag,
            boolean isIndexed,
            int indexValueBlockCapacity,
            boolean isSequential
    ); void addIndex(CharSequence columnName, int indexValueBlockSize); void changeCacheFlag(int columnIndex, boolean cache); @Override void close(); void commit(); void commit(int commitMode); int getColumnIndex(CharSequence name); long getMaxTimestamp(); RecordMetadata getMetadata(); CharSequence getName(); int getPartitionBy(); long getStructureVersion(); boolean inTransaction(); boolean isOpen(); Row newRow(long timestamp); Row newRow(); long partitionNameToTimestamp(CharSequence partitionName); void removeColumn(CharSequence name); void renameColumn(CharSequence currentName, CharSequence newName); boolean removePartition(long timestamp); void rollback(); void setLifecycleManager(LifecycleManager lifecycleManager); long size(); @Override String toString(); void transferLock(long lockFd); final void truncate(); void updateMetadataVersion(); void warmUp(); }
TableWriter implements Closeable { public void renameColumn(CharSequence currentName, CharSequence newName) { checkDistressed(); final int index = getColumnIndex(currentName); final int type = metadata.getColumnType(index); LOG.info().$("renaming column '").utf8(currentName).$("' to '").utf8(newName).$("' from ").$(path).$(); commit(); this.metaSwapIndex = renameColumnFromMeta(index, newName); metaMem.close(); renameMetaToMetaPrev(currentName); writeRestoreMetaTodo(currentName); renameSwapMetaToMeta(currentName); try { openMetaFile(); removeTodoFile(); renameColumnFiles(currentName, newName, type); } catch (CairoException err) { throwDistressException(err); } bumpStructureVersion(); metadata.renameColumn(currentName, newName); LOG.info().$("RENAMED column '").utf8(currentName).$("' to '").utf8(newName).$("' from ").$(path).$(); } TableWriter(CairoConfiguration configuration, CharSequence name);  TableWriter(CairoConfiguration configuration, CharSequence name, MessageBus messageBus);  TableWriter(
            CairoConfiguration configuration,
            CharSequence name,
            @Nullable MessageBus messageBus,
            boolean lock,
            LifecycleManager lifecycleManager
    );  TableWriter(
            CairoConfiguration configuration,
            CharSequence name,
            @Nullable MessageBus messageBus,
            boolean lock,
            LifecycleManager lifecycleManager,
            CharSequence root
    ); static TimestampFormat selectPartitionDirFmt(int partitionBy); void addColumn(CharSequence name, int type); void addColumn(
            CharSequence name,
            int type,
            int symbolCapacity,
            boolean symbolCacheFlag,
            boolean isIndexed,
            int indexValueBlockCapacity,
            boolean isSequential
    ); void addIndex(CharSequence columnName, int indexValueBlockSize); void changeCacheFlag(int columnIndex, boolean cache); @Override void close(); void commit(); void commit(int commitMode); int getColumnIndex(CharSequence name); long getMaxTimestamp(); RecordMetadata getMetadata(); CharSequence getName(); int getPartitionBy(); long getStructureVersion(); boolean inTransaction(); boolean isOpen(); Row newRow(long timestamp); Row newRow(); long partitionNameToTimestamp(CharSequence partitionName); void removeColumn(CharSequence name); void renameColumn(CharSequence currentName, CharSequence newName); boolean removePartition(long timestamp); void rollback(); void setLifecycleManager(LifecycleManager lifecycleManager); long size(); @Override String toString(); void transferLock(long lockFd); final void truncate(); void updateMetadataVersion(); void warmUp();  }