public void testAddNewColumnToExistedDescriptor()

in timescaledb-connector/src/integration-test/java/com/epam/deltix/timebase/connector/service/timescale/TimescaleMigrationServiceTest.java [175:225]

38 lines of code
5 McCabe index (conditional complexity)


    public void testAddNewColumnToExistedDescriptor() {
        applyTimescaleSchema();

        SchemaChangeMessage changeMessage = new SchemaChangeMessage();
        SchemaDescriptorChangeAction alterDescriptorAction = new SchemaDescriptorChangeAction();
        alterDescriptorAction.setChangeTypes(SchemaDescriptorChangeType.FIELDS_CHANGE);

        ClassDescriptorInfo previousDescriptor = null;
        ObjectArrayList<ClassDescriptorInfo> previousState = getDescriptorMessages();
        for (ClassDescriptorInfo d : previousState) {
            if (d.getName().equals("com.epam.deltix.timebase.connector.model.SecondTestClass"))
                previousDescriptor = d;
        }

        DataField newDataField = new NonStaticDataField();
        newDataField.setName("newField");
        newDataField.setDataType(new VarcharDataType());

        ClassDescriptorInfo newDescriptor = null;
        ObjectArrayList<ClassDescriptorInfo> newState = getDescriptorMessages();
        for (ClassDescriptorInfo d : newState) {
            if (d.getName().equals("com.epam.deltix.timebase.connector.model.SecondTestClass")) {
                RecordClassDescriptor rcd = (RecordClassDescriptor) d;

                rcd.getDataFields().add(newDataField);
                newDescriptor = rcd;
            }
        }

        changeMessage.setNewState(newState);
        changeMessage.setPreviousState(previousState);

        alterDescriptorAction.setPreviousState(previousDescriptor);
        alterDescriptorAction.setNewState(newDescriptor);

        ObjectArrayList<SchemaFieldChangeActionInfo> filedActions = new ObjectArrayList<>();
        SchemaFieldChangeAction filedAction = new SchemaFieldChangeAction();
        filedAction.setChangeTypes(SchemaFieldChangeType.ADD);
        filedAction.setNewState(newDataField);

        filedActions.add(filedAction);

        alterDescriptorAction.setFieldChangeActions(filedActions);

        ObjectArrayList<SchemaDescriptorChangeActionInfo> actions = new ObjectArrayList<>();
        actions.add(alterDescriptorAction);

        changeMessage.setDescriptorChangeActions(actions);

        migrationService.apply(changeMessage, "events");
    }