public void testTimescaleAddColumnsGeneration()

in timescaledb-connector/src/integration-test/java/com/epam/deltix/timebase/connector/service/timescale/TimescaleSqlGeneratorTest.java [107:134]

• 24 lines of code
• 1 McCabe index (conditional complexity)

    public void testTimescaleAddColumnsGeneration() {
        String schemaName = "orders-123";
        TimescaleSchema schema = getValidSchema();

        TimescaleColumn newColumn1 = TimescaleColumn.builder()
                .dataType(TimescaleColumn.TimescaleDataType.VARCHAR)
                .name("newColumn1")
                .build();
        TimescaleColumn newColumn2 = TimescaleColumn.builder()
                .dataType(TimescaleColumn.TimescaleDataType.VARCHAR)
                .name("newColumn2")
                .build();
        Set<TimescaleColumn> columns = new HashSet<>();
        columns.add(newColumn1);
        columns.add(newColumn2);

        String createTableStatement = sqlGenerator.generateCreateTableStatement(schema);
        String createHypertableStatement = sqlGenerator.generateHypertableStatement(schema);
        String addColumnsStatement = sqlGenerator.generateAddColumnStatement(schemaName, columns);

        dataService.executeQuery(createTableStatement);
        dataService.executeQuery(createHypertableStatement);
        dataService.executeQuery(addColumnsStatement);

        assertThat(addColumnsStatement, is(Matchers.oneOf(
                "ALTER TABLE \"orders-123\" ADD COLUMN IF NOT EXISTS newColumn2 VARCHAR, ADD COLUMN IF NOT EXISTS newColumn1 VARCHAR",
                "ALTER TABLE \"orders-123\" ADD COLUMN IF NOT EXISTS newColumn1 VARCHAR, ADD COLUMN IF NOT EXISTS newColumn2 VARCHAR")));
    }