public void createMigrationTable()

in timescaledb-connector/src/main/java/com/epam/deltix/timebase/connector/service/timescale/TimescaleMigrationMetadataService.java [40:81]
41 lines of code
1 McCabe index (conditional complexity)

    public void createMigrationTable() {
        TimescaleSchema migrationTable = TimescaleSchema.builder()
                .name("migrations_tracker")
                .columns(Arrays.asList(
                        TimescaleColumn.builder()
                                .name("Id")
                                .dataType(TimescaleColumn.TimescaleDataType.SERIAL)
                                .relatedDescriptors(Collections.emptyList())
                                .build(),
                        TimescaleColumn.builder()
                                .name("Stream")
                                .dataType(TimescaleColumn.TimescaleDataType.VARCHAR)
                                .relatedDescriptors(Collections.emptyList())
                                .build(),
                        TimescaleColumn.builder()
                                .name("Version")
                                .dataType(TimescaleColumn.TimescaleDataType.LONG)
                                .relatedDescriptors(Collections.emptyList())
                                .build(),
                        TimescaleColumn.builder()
                                .name("IsSuccess")
                                .dataType(TimescaleColumn.TimescaleDataType.BOOLEAN)
                                .relatedDescriptors(Collections.emptyList())
                                .build(),
                        TimescaleColumn.builder()
                                .name("MigrationDateTime")
                                .dataType(TimescaleColumn.TimescaleDataType.DATETIME)
                                .relatedDescriptors(Collections.emptyList())
                                .build()
                ))
                .primaryKey(new TimescaleColumn[]{
                        TimescaleColumn.builder()
                                .name("Id")
                                .dataType(TimescaleColumn.TimescaleDataType.SERIAL)
                                .relatedDescriptors(Collections.emptyList())
                                .build()
                })
                .build();

        String createTableStatement = sqlGenerator.generateCreateTableStatement(migrationTable);
        dataService.executeQuery(createTableStatement);
    }